org.apache.spark.internal

Interface Logging

All Known Subinterfaces:

AFTSurvivalRegressionParams, GeneralizedLinearRegressionBase, IsotonicRegressionBase, ListenerBus<L,E>, LookupCatalog, MLEvents, SparkListenerBus

All Known Implementing Classes:

AFTSurvivalRegression, AFTSurvivalRegressionModel, ALS, ALS, ALSModel, AssociationRules, AsyncEventQueue, AsyncRDDActions, BarrierTaskContext, BaseRRDD, BasicBlockReplicationPolicy, Binarizer, BinaryClassificationMetrics, BisectingKMeans, BisectingKMeans, BisectingKMeansModel, BisectingKMeansModel, BlockMatrix, Broadcast, BucketedRandomProjectionLSH, BucketedRandomProjectionLSHModel, Bucketizer, ChiSqSelector, ChiSqSelectorModel, ClassificationModel, Classifier, CoGroupedRDD, Column, ColumnName, ColumnPruner, ConstantInputDStream, CountVectorizer, CountVectorizerModel, CreateHiveTableAsSelectCommand, CrossValidator, CrossValidatorModel, CrossValidatorModel.CrossValidatorModelWriter, DataFrameReader, DataStreamReader, DCT, DecisionTree, DecisionTreeClassificationModel, DecisionTreeClassifier, DecisionTreeRegressionModel, DecisionTreeRegressor, DedicatedMessageLoop, DefaultTopologyMapper, DetermineTableStats, DistributedLDAModel, DoubleRDDFunctions, DriverPluginContainer, DStream, EdgeRDD, EdgeRDDImpl, ElementwiseProduct, Estimator, ExecutionListenerManager, ExecutorPluginContainer, FeatureHasher, FileBasedTopologyMapper, FileCommitProtocol, FPGrowth, FPGrowth, FPGrowthModel, GaussianMixture, GaussianMixtureModel, GBTClassificationModel, GBTClassifier, GBTRegressionModel, GBTRegressor, GeneralizedLinearAlgorithm, GeneralizedLinearRegression, GeneralizedLinearRegressionModel, GeneralMLWriter, org.apache.spark.sql.catalyst.planning.GenericStrategy, GradientBoostedTrees, GradientDescent, HadoopMapRedCommitProtocol, HadoopMapReduceCommitProtocol, HadoopRDD, HashingTF, HiveFileFormat, HiveStrategies.HiveTableScans$, HiveStrategies.Scripts$, IDF, IDFModel, Imputer, ImputerModel, IndexToString, InputDStream, InputFormatInfo, InsertIntoHiveDirCommand, InsertIntoHiveTable, Interaction, IsotonicRegression, IsotonicRegressionModel, JdbcRDD, KMeans, KMeans, KMeansModel, KryoSerializer, LassoWithSGD, LBFGS, LDA, LDA, LDAModel, LinearRegression, LinearRegressionModel, LinearRegressionWithSGD, LinearSVC, LinearSVCModel, LocalLDAModel, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan, LogisticRegression, LogisticRegressionModel, LogisticRegressionWithLBFGS, LogisticRegressionWithSGD, MapWithStateDStream, MatrixFactorizationModel, MaxAbsScaler, MaxAbsScalerModel, MessageLoop, MinHashLSH, MinHashLSHModel, MinMaxScaler, MinMaxScalerModel, MLWriter, Model, MultilayerPerceptronClassificationModel, MultilayerPerceptronClassifier, NaiveBayes, NaiveBayes, NaiveBayesModel, NewHadoopRDD, NGram, Node, Normalizer, OneHotEncoder, OneHotEncoderModel, OneVsRest, OneVsRestModel, OnlineLDAOptimizer, OptimizedCreateHiveTableAsSelectCommand, OrderedRDDFunctions, PairRDDFunctions, PairwiseRRDD, PartitionPruningRDD, PCA, PCAModel, Pipeline, PipelineModel, PipelineStage, PlanDynamicPruningFilters, PluginContextImpl, PluginEndpoint, PolynomialExpansion, PredictionModel, Predictor, PrefixSpan, ProbabilisticClassificationModel, ProbabilisticClassifier, QuantileDiscretizer, RandomBlockReplicationPolicy, RandomForest, RandomForestClassificationModel, RandomForestClassifier, RandomForestRegressionModel, RandomForestRegressor, RankingMetrics, RBackendAuthHandler, RDD, ReceiverInputDStream, RegexTokenizer, RegressionMetrics, RegressionModel, Regressor, RelationConversions, ResolveHiveSerdeTable, RFormula, RFormulaModel, RidgeRegressionWithSGD, RobustScaler, RobustScalerModel, RowMatrix, RRDD, org.apache.spark.sql.catalyst.rules.Rule, ScriptTransformationExec, ScriptTransformationWriterThread, SequenceFileRDDFunctions, SharedMessageLoop, ShuffledRDD, SparkConf, SparkContext, SparkEnv, org.apache.spark.sql.execution.SparkPlan, SparkSession, SparkSession.Builder, org.apache.spark.sql.execution.SparkStrategy, SQLContext, SQLTransformer, StandardScaler, StandardScaler, StandardScalerModel, StatsReportListener, StopWordsRemover, StreamingContext, StreamingKMeans, StreamingKMeansModel, StreamingLinearAlgorithm, StreamingLinearRegressionWithSGD, StreamingLogisticRegressionWithSGD, StreamingQueryManager, StreamingTest, StringIndexer, StringIndexerModel, StringRRDD, SVMWithSGD, Tokenizer, TrainValidationSplit, TrainValidationSplitModel, TrainValidationSplitModel.TrainValidationSplitModelWriter, Transformer, TypedColumn, UDFRegistration, UnaryTransformer, UnionRDD, VectorAssembler, VectorAttributeRewriter, VectorIndexer, VectorIndexerModel, VectorSizeHint, VectorSlicer, VertexRDD, VertexRDDImpl, Word2Vec, Word2Vec, Word2VecModel

public interface Logging

Utility trait for classes that want to log data. Creates a SLF4J logger for the class and allows logging messages at different levels using methods that only evaluate parameters lazily if the log level is enabled.

Method Summary

Modifier and Type	Method and Description
void	initializeForcefully(boolean isInterpreter, boolean silent)
void	initializeLogging(boolean isInterpreter, boolean silent)
void	initializeLogIfNecessary(boolean isInterpreter)
boolean	initializeLogIfNecessary(boolean isInterpreter, boolean silent)
boolean	isTraceEnabled()
org.slf4j.Logger	log()
void	logDebug(scala.Function0<String> msg)
void	logDebug(scala.Function0<String> msg, Throwable throwable)
void	logError(scala.Function0<String> msg)
void	logError(scala.Function0<String> msg, Throwable throwable)
void	logInfo(scala.Function0<String> msg)
void	logInfo(scala.Function0<String> msg, Throwable throwable)
String	logName()
void	logTrace(scala.Function0<String> msg)
void	logTrace(scala.Function0<String> msg, Throwable throwable)
void	logWarning(scala.Function0<String> msg)
void	logWarning(scala.Function0<String> msg, Throwable throwable)

Method Detail

logName

String logName()

log

org.slf4j.Logger log()

logInfo

void logInfo(scala.Function0<String> msg)

logDebug

void logDebug(scala.Function0<String> msg)

logTrace

void logTrace(scala.Function0<String> msg)

logWarning

void logWarning(scala.Function0<String> msg)

logError

void logError(scala.Function0<String> msg)

logInfo

void logInfo(scala.Function0<String> msg,
             Throwable throwable)

logDebug

void logDebug(scala.Function0<String> msg,
              Throwable throwable)

logTrace

void logTrace(scala.Function0<String> msg,
              Throwable throwable)

logWarning

void logWarning(scala.Function0<String> msg,
                Throwable throwable)

logError

void logError(scala.Function0<String> msg,
              Throwable throwable)

isTraceEnabled

boolean isTraceEnabled()

initializeLogIfNecessary

void initializeLogIfNecessary(boolean isInterpreter)

initializeLogIfNecessary

boolean initializeLogIfNecessary(boolean isInterpreter,
                                 boolean silent)

initializeForcefully

void initializeForcefully(boolean isInterpreter,
                          boolean silent)

initializeLogging

void initializeLogging(boolean isInterpreter,
                       boolean silent)