org.apache.parquet.hadoop.metadata.ColumnPath columnPath
Class<T> columnType
org.apache.parquet.filter2.predicate.Operators.UserDefined<T extends Comparable<T>,U extends org.apache.parquet.filter2.predicate.UserDefinedPredicate<T>> udp
String toString
org.apache.parquet.filter2.predicate.FilterPredicate predicate
String toString
org.apache.parquet.filter2.predicate.Operators.Column<T extends Comparable<T>> column
java.util.Set<E> values
org.apache.parquet.filter2.predicate.Operators.Column<T extends Comparable<T>> column
Class<T> udpClass
String toString
String toString
org.apache.parquet.filter2.predicate.UserDefinedPredicate<T extends Comparable<T>> udpInstance
private Object readResolve()
private Object readResolve()
java.util.Timer org$apache$spark$BarrierTaskContext$$timer
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.Enumeration.Value PRETTY
scala.Enumeration.Value MINIMAL
scala.Enumeration.Value STANDARD
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.Enumeration.Value BARRIER
scala.Enumeration.Value ALL_GATHER
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.collection.immutable.Map<K,V> deprecatedConfigs
scala.collection.immutable.Map<K,V> org$apache$spark$SparkConf$$configsWithAlternatives
scala.collection.immutable.Map<K,V> allAlternatives
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
boolean enabled
scala.Option<A> port
scala.Option<A> keyStore
scala.Option<A> keyStorePassword
scala.Option<A> keyPassword
scala.Option<A> keyStoreType
boolean needClientAuth
scala.Option<A> trustStore
scala.Option<A> trustStorePassword
scala.Option<A> trustStoreType
scala.Option<A> protocol
scala.collection.immutable.Set<A> enabledAlgorithms
scala.collection.immutable.Set<A> supportedAlgorithms
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
ThreadLocal<T> taskContext
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.Enumeration.Value LAUNCHING
scala.Enumeration.Value RUNNING
scala.Enumeration.Value FINISHED
scala.Enumeration.Value FAILED
scala.Enumeration.Value KILLED
scala.Enumeration.Value LOST
scala.collection.immutable.Set<A> FINISHED_STATES
private Object readResolve()
private Object readResolve()
scala.Function0<R> intWritableConverterFn
scala.Function0<R> longWritableConverterFn
scala.Function0<R> doubleWritableConverterFn
scala.Function0<R> floatWritableConverterFn
scala.Function0<R> booleanWritableConverterFn
scala.Function0<R> bytesWritableConverterFn
scala.Function0<R> stringWritableConverterFn
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
Object value
private Object readResolve()
private Object readResolve()
private Object readResolve()
org.apache.spark.util.KeyLock<K> org$apache$spark$broadcast$TorrentBroadcast$$torrentBroadcastLock
private Object readResolve()
byte attr$mcB$sp
char attr$mcC$sp
double attr$mcD$sp
float attr$mcF$sp
int attr$mcI$sp
long attr$mcJ$sp
boolean attr$mcZ$sp
private Object readResolve()
EdgeDirection In
EdgeDirection Out
EdgeDirection Either
EdgeDirection Both
private Object readResolve()
private Object readResolve()
private Object readResolve()
boolean useSrc
boolean useDst
boolean useEdge
private Object readResolve()
byte[] org$apache$spark$graphx$impl$EdgePartition$$data$mcB$sp
int[] localSrcIds
int[] localDstIds
byte[] data$mcB$sp
org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> index
org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> global2local
long[] local2global
Object vertexAttrs
scala.Option<A> activeSet
scala.reflect.ClassTag<T> evidence$1
scala.reflect.ClassTag<T> evidence$2
char[] org$apache$spark$graphx$impl$EdgePartition$$data$mcC$sp
int[] localSrcIds
int[] localDstIds
char[] data$mcC$sp
org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> index
org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> global2local
long[] local2global
Object vertexAttrs
scala.Option<A> activeSet
scala.reflect.ClassTag<T> evidence$1
scala.reflect.ClassTag<T> evidence$2
double[] org$apache$spark$graphx$impl$EdgePartition$$data$mcD$sp
int[] localSrcIds
int[] localDstIds
double[] data$mcD$sp
org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> index
org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> global2local
long[] local2global
Object vertexAttrs
scala.Option<A> activeSet
scala.reflect.ClassTag<T> evidence$1
scala.reflect.ClassTag<T> evidence$2
float[] org$apache$spark$graphx$impl$EdgePartition$$data$mcF$sp
int[] localSrcIds
int[] localDstIds
float[] data$mcF$sp
org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> index
org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> global2local
long[] local2global
Object vertexAttrs
scala.Option<A> activeSet
scala.reflect.ClassTag<T> evidence$1
scala.reflect.ClassTag<T> evidence$2
int[] org$apache$spark$graphx$impl$EdgePartition$$data$mcI$sp
int[] localSrcIds
int[] localDstIds
int[] data$mcI$sp
org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> index
org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> global2local
long[] local2global
Object vertexAttrs
scala.Option<A> activeSet
scala.reflect.ClassTag<T> evidence$1
scala.reflect.ClassTag<T> evidence$2
long[] org$apache$spark$graphx$impl$EdgePartition$$data$mcJ$sp
int[] localSrcIds
int[] localDstIds
long[] data$mcJ$sp
org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> index
org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> global2local
long[] local2global
Object vertexAttrs
scala.Option<A> activeSet
scala.reflect.ClassTag<T> evidence$1
scala.reflect.ClassTag<T> evidence$2
boolean[] org$apache$spark$graphx$impl$EdgePartition$$data$mcZ$sp
int[] localSrcIds
int[] localDstIds
boolean[] data$mcZ$sp
org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> index
org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> global2local
long[] local2global
Object vertexAttrs
scala.Option<A> activeSet
scala.reflect.ClassTag<T> evidence$1
scala.reflect.ClassTag<T> evidence$2
private Object readResolve()
private Object readResolve()
byte attr$mcB$sp
char attr$mcC$sp
double attr$mcD$sp
float attr$mcF$sp
int attr$mcI$sp
long attr$mcJ$sp
short attr$mcS$sp
scala.runtime.BoxedUnit attr$mcV$sp
boolean attr$mcZ$sp
private Object readResolve()
private Object readResolve()
org.apache.spark.graphx.impl.RoutingTablePartition empty
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.reflect.ClassTag<T> evidence$3
scala.reflect.ClassTag<T> evidence$3
scala.reflect.ClassTag<T> evidence$3
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.collection.Seq<A> youngGenerationGarbageCollector
scala.collection.Seq<A> oldGenerationGarbageCollector
scala.collection.Seq<A> nonBuiltInCollectors
scala.collection.Seq<A> names
scala.collection.Seq<A> YOUNG_GENERATION_BUILTIN_GARBAGE_COLLECTORS
scala.collection.Seq<A> OLD_GENERATION_BUILTIN_GARBAGE_COLLECTORS
byte bitmap$0
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.collection.Seq<A> names
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
BinaryAttribute defaultAttr
private Object readResolve()
NominalAttribute defaultAttr
private Object readResolve()
NumericAttribute defaultAttr
private Object readResolve()
private Object readResolve()
private Object readResolve()
String[] supportedImpurities
private Object readResolve()
private Object readResolve()
private Object readResolve()
String org$apache$spark$ml$classification$GBTClassificationModel$$numFeaturesKey
String org$apache$spark$ml$classification$GBTClassificationModel$$numTreesKey
private Object readResolve()
String[] supportedLossTypes
private Object readResolve()
private Object readResolve()
private Object readResolve()
String[] supportedFamilyNames
private Object readResolve()
private Object readResolve()
private Object readResolve()
String LBFGS
String GD
String[] supportedSolvers
private Object readResolve()
String Multinomial
String Bernoulli
String Gaussian
String Complement
scala.collection.immutable.Set<A> supportedModelTypes
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
String[] supportedImpurities
String[] supportedFeatureSubsetStrategies
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
int MAX_NUM_FEATURES
private Object readResolve()
private Object readResolve()
String RANDOM
String K_MEANS_PARALLEL
String[] supportedInitModes
String EUCLIDEAN
String COSINE
String ROW
String BLOCK
String AUTO
String[] supportedSolvers
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
String[] org$apache$spark$ml$evaluation$MulticlassClassificationEvaluator$$supportedMetricNames
private Object readResolve()
String[] org$apache$spark$ml$evaluation$MultilabelClassificationEvaluator$$supportedMetricNames
private Object readResolve()
String[] org$apache$spark$ml$evaluation$RankingEvaluator$$supportedMetricNames
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
String SKIP_INVALID
String ERROR_INVALID
String KEEP_INVALID
String[] supportedHandleInvalids
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
int seed
private Object readResolve()
int SPARK_2_MURMUR3_HASH
int SPARK_3_MURMUR3_HASH
private Object readResolve()
private Object readResolve()
private Object readResolve()
String mean
String median
String mode
String[] supportedStrategies
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
double DefaultBlockSizeInMB
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
int HASH_PRIME
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
String KEEP_INVALID
String ERROR_INVALID
String[] supportedHandleInvalids
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.collection.immutable.Set<A> supportedLanguages
private Object readResolve()
String SKIP_INVALID
String ERROR_INVALID
String KEEP_INVALID
String[] supportedHandleInvalids
String frequencyDesc
String frequencyAsc
String alphabetDesc
String alphabetAsc
String[] supportedStringOrderType
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
String SKIP_INVALID
String ERROR_INVALID
String KEEP_INVALID
String[] supportedHandleInvalids
private Object readResolve()
private Object readResolve()
String SKIP_INVALID
String ERROR_INVALID
String KEEP_INVALID
String[] supportedHandleInvalids
private Object readResolve()
private Object readResolve()
String OPTIMISTIC_INVALID
String ERROR_INVALID
String SKIP_INVALID
String[] supportedHandleInvalids
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
int nativeL1Threshold
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
int MAX_NUM_FEATURES
scala.Product[] supportedSolvers
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
int[] srcIds$mcI$sp
scala.reflect.ClassTag<T> evidence$2
long[] srcIds$mcJ$sp
scala.reflect.ClassTag<T> evidence$2
int user$mcI$sp
int item$mcI$sp
long user$mcJ$sp
long item$mcJ$sp
int[] srcIds$mcI$sp
int[] dstIds$mcI$sp
scala.reflect.ClassTag<T> evidence$3
long[] srcIds$mcJ$sp
long[] dstIds$mcJ$sp
scala.reflect.ClassTag<T> evidence$3
scala.reflect.ClassTag<T> evidence$4
scala.reflect.ClassTag<T> evidence$4
private Object readResolve()
String org$apache$spark$ml$recommendation$ALSModel$$NaN
String org$apache$spark$ml$recommendation$ALSModel$$Drop
String[] supportedColdStartStrategies
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
String[] supportedImpurities
private Object readResolve()
String GD
String AdamW
String[] supportedSolvers
String LogisticLoss
String SquaredError
String[] supportedRegressorLosses
String[] supportedClassifierLosses
String[] supportedLosses
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
String[] supportedLossTypes
private Object readResolve()
scala.collection.immutable.Set<A> supportedFamilyAndLinkPairs
String[] supportedFamilyNames
String[] supportedLinkNames
String IRLS
String[] supportedSolvers
double epsilon
byte bitmap$0
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
int MAX_FEATURES_FOR_NORMAL_SOLVER
String Auto
String Normal
String LBFGS
String[] supportedSolvers
String SquaredError
String Huber
String[] supportedLosses
private Object readResolve()
private Object readResolve()
private Object readResolve()
String[] supportedImpurities
String[] supportedFeatureSubsetStrategies
private Object readResolve()
String NUM_FEATURES
String VECTOR_TYPE
String DENSE_VECTOR_TYPE
String SPARSE_VECTOR_TYPE
private Object readResolve()
String[] supportedLossTypes
private Object readResolve()
String[] supportedLossTypes
private Object readResolve()
String[] supportedImpurities
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
String[] supportedImpurities
private Object readResolve()
String[] supportedFeatureSubsetStrategies
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
String Multinomial
String Bernoulli
scala.collection.immutable.Set<A> supportedModelTypes
private Object readResolve()
double[] labels
double[] pi
double[][] theta
private Object readResolve()
double[] labels
double[] pi
double[][] theta
String modelType
private Object readResolve()
private Object readResolve()
private Object readResolve()
Vector weights
double intercept
scala.Option<A> threshold
private Object readResolve()
private Object readResolve()
long org$apache$spark$mllib$clustering$BisectingKMeans$$ROOT_INDEX
long MAX_DIVISIBLE_CLUSTER_INDEX
double org$apache$spark$mllib$clustering$BisectingKMeans$$LEVEL_LIMIT
private Object readResolve()
private Object readResolve()
String EUCLIDEAN
String COSINE
Vector globalTopicTotals
private Object readResolve()
long srcId
long dstId
double tokenCounts
private Object readResolve()
long id
Vector topicWeights
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
int MAX_NUM_FEATURES
private Object readResolve()
private Object readResolve()
private Object readResolve()
String RANDOM
String K_MEANS_PARALLEL
private Object readResolve()
private Object readResolve()
Vector topic
int index
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
String NumTopFeatures
String Percentile
String FPR
String FDR
String FWE
String[] supportedSelectorTypes
private Object readResolve()
int feature
private Object readResolve()
private Object readResolve()
String Native
String Murmur3
int seed
private Object readResolve()
private Object readResolve()
private Object readResolve()
String word
float[] vector
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
int nativeL1Threshold
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
double boundary
double prediction
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
Vector weights
double intercept
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.collection.immutable.Map<K,V> TEST_NAME_TO_OBJECT
private Object readResolve()
com.twitter.chill.MeatLocker<T> tTester
private Object readResolve()
com.twitter.chill.MeatLocker<T> tTester
private Object readResolve()
private Object readResolve()
private Object readResolve()
String[] supportedFeatureSubsetStrategies
scala.Enumeration.Value Classification
scala.Enumeration.Value Regression
private Object readResolve()
scala.Enumeration.Value Average
scala.Enumeration.Value Sum
scala.Enumeration.Value Vote
scala.Enumeration.Value Continuous
scala.Enumeration.Value Categorical
scala.Enumeration.Value Sort
scala.Enumeration.Value MinMax
scala.Enumeration.Value ApproxHist
private Object readResolve()
private Object readResolve()
double _log2
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
int treeId
int nodeId
org.apache.spark.mllib.tree.model.DecisionTreeModel$SaveLoadV1_0$PredictData predict
double impurity
boolean isLeaf
scala.Option<A> split
scala.Option<A> leftNodeId
scala.Option<A> rightNodeId
scala.Option<A> infoGain
private Object readResolve()
double predict
double prob
private Object readResolve()
int feature
double threshold
int featureType
scala.collection.Seq<A> categories
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
int treeId
org.apache.spark.mllib.tree.model.DecisionTreeModel$SaveLoadV1_0$NodeData node
private Object readResolve()
String algo
String treeAlgo
String combiningStrategy
double[] treeWeights
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.concurrent.ExecutionContextExecutorService futureExecutionContext
scala.Enumeration.Value Initialized
scala.Enumeration.Value CheckpointingInProgress
scala.Enumeration.Value Checkpointed
private Object readResolve()
private Object readResolve()
scala.Enumeration.Value DETERMINATE
scala.Enumeration.Value UNORDERED
scala.Enumeration.Value INDETERMINATE
private Object readResolve()
Object CONFIGURATION_INSTANTIATION_LOCK
int RECORDS_BETWEEN_BYTES_READ_METRIC_UPDATES
private Object readResolve()
private Object readResolve()
StorageLevel DEFAULT_STORAGE_LEVEL
private Object readResolve()
private Object readResolve()
private Object readResolve()
Object CONFIGURATION_INSTANTIATION_LOCK
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
String STDIN_WRITER_THREAD_PREFIX
String STDERR_READER_THREAD_PREFIX
private Object readResolve()
String CHECKPOINT_ALL_MARKED_ANCESTORS
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.collection.parallel.ForkJoinTaskSupport partitionEvalTaskSupport
boolean bitmap$0
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
String exampleJson
boolean bitmap$0
private Object readResolve()
private Object readResolve()
java.util.concurrent.atomic.AtomicInteger nextProfileId
String CPUS
String CORES
String MEMORY
String OFFHEAP_MEM
String OVERHEAD_MEM
String PYSPARK_MEM
int UNKNOWN_RESOURCE_PROFILE_ID
int DEFAULT_RESOURCE_PROFILE_ID
long MEMORY_OVERHEAD_MIN_MIB
Object DEFAULT_PROFILE_LOCK
scala.Option<A> defaultProfile
scala.Option<A> defaultProfileExecutorResources
String PYSPARK_MEMORY_LOCAL_PROPERTY
String EXECUTOR_CORES_LOCAL_PROPERTY
boolean bitmap$0
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
String ERROR_MESSAGE_RUN_BARRIER_WITH_UNSUPPORTED_RDD_CHAIN_PATTERN
String ERROR_MESSAGE_RUN_BARRIER_WITH_DYN_ALLOCATION
String ERROR_MESSAGE_BARRIER_REQUIRE_MORE_SLOTS_THAN_CURRENT_TOTAL_NUMBER
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
String msgPrefix
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
int SHUFFLE_PUSH_DUMMY_NUM_REDUCES
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.Enumeration.Value FAIR
scala.Enumeration.Value FIFO
scala.Enumeration.Value NONE
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.Enumeration.Value PROCESS_LOCAL
scala.Enumeration.Value NODE_LOCAL
scala.Enumeration.Value NO_PREF
scala.Enumeration.Value RACK_LOCAL
scala.Enumeration.Value ANY
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
public void readExternal(java.io.ObjectInput in)
public void writeExternal(java.io.ObjectOutput out)
private Object readResolve()
scala.collection.Seq<A> org$apache$spark$serializer$KryoSerializer$$loadableSparkClasses
scala.collection.Seq<A> org$apache$spark$serializer$KryoSerializer$$toRegister
scala.collection.immutable.Map<K,V> org$apache$spark$serializer$KryoSerializer$$toRegisterSerializer
boolean bitmap$0
private Object readResolve()
private Object readResolve()
java.util.concurrent.atomic.AtomicLong curId
String DATASET_ID_KEY
String COL_POS_KEY
org.apache.spark.sql.catalyst.trees.TreeNodeTag<T> DATASET_ID_TAG
private Object readResolve()
private Object readResolve()
private Object readResolve()
Row empty
private Object readResolve()
java.util.concurrent.atomic.AtomicBoolean org$apache$spark$sql$SparkSession$$listenerRegistered
InheritableThreadLocal<T> org$apache$spark$sql$SparkSession$$activeThreadSession
java.util.concurrent.atomic.AtomicReference<V> org$apache$spark$sql$SparkSession$$defaultSession
String HIVE_SESSION_STATE_BUILDER_CLASS_NAME
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.collection.immutable.Set<A> org$apache$spark$sql$jdbc$DB2Dialect$$distinctUnsupportedAggregateFunctions
scala.collection.immutable.Set<A> supportedAggregateFunctions
scala.collection.immutable.Set<A> supportedFunctions
private Object readResolve()
scala.collection.immutable.Set<A> supportedAggregateFunctions
scala.collection.immutable.Set<A> supportedFunctions
private Object readResolve()
scala.collection.immutable.Set<A> org$apache$spark$sql$jdbc$H2Dialect$$distinctUnsupportedAggregateFunctions
scala.collection.immutable.Set<A> supportedAggregateFunctions
scala.collection.immutable.Set<A> supportedFunctions
java.util.Map<K,V> functionMap
private Object readResolve()
private Object readResolve()
scala.collection.immutable.Set<A> supportedAggregateFunctions
scala.collection.immutable.Set<A> supportedFunctions
private Object readResolve()
scala.collection.immutable.Set<A> org$apache$spark$sql$jdbc$MySQLDialect$$distinctUnsupportedAggregateFunctions
scala.collection.immutable.Set<A> supportedAggregateFunctions
scala.collection.immutable.Set<A> supportedFunctions
private Object readResolve()
private Object readResolve()
int BINARY_FLOAT
int BINARY_DOUBLE
int TIMESTAMPTZ
scala.collection.immutable.Set<A> org$apache$spark$sql$jdbc$OracleDialect$$distinctUnsupportedAggregateFunctions
scala.collection.immutable.Set<A> supportedAggregateFunctions
scala.collection.immutable.Set<A> supportedFunctions
private Object readResolve()
scala.collection.immutable.Set<A> supportedAggregateFunctions
scala.collection.immutable.Set<A> supportedFunctions
private Object readResolve()
scala.collection.immutable.Set<A> supportedAggregateFunctions
scala.collection.immutable.Set<A> supportedFunctions
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
long DEFAULT_NUM_OUTPUT_ROWS
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
byte DAY
byte HOUR
byte MINUTE
byte SECOND
scala.collection.Seq<A> dayTimeFields
scala.collection.immutable.Map<K,V> stringToField
DayTimeIntervalType DEFAULT
private Object readResolve()
int[] minBytesForPrecision
scala.Enumeration.Value ROUND_HALF_UP
scala.Enumeration.Value ROUND_HALF_EVEN
scala.Enumeration.Value ROUND_CEILING
scala.Enumeration.Value ROUND_FLOOR
int MAX_INT_DIGITS
int MAX_LONG_DIGITS
long[] POW_10
java.math.MathContext org$apache$spark$sql$types$Decimal$$MATH_CONTEXT
Decimal ZERO
Decimal ONE
boolean bitmap$0
private Object readResolve()
private Object readResolve()
int MAX_PRECISION
int MAX_SCALE
int DEFAULT_SCALE
DecimalType SYSTEM_DEFAULT
DecimalType USER_DEFAULT
int MINIMUM_ADJUSTED_SCALE
DecimalType BooleanDecimal
DecimalType ByteDecimal
DecimalType ShortDecimal
DecimalType IntDecimal
DecimalType LongDecimal
DecimalType FloatDecimal
DecimalType DoubleDecimal
DecimalType BigIntDecimal
private Object readResolve()
int intUpperBound
int intLowerBound
long longUpperBound
long longLowerBound
private Object readResolve()
private Object readResolve()
int intUpperBound
int intLowerBound
long longUpperBound
long longLowerBound
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
Metadata _empty
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.collection.mutable.Map<K,V> udtMap
boolean bitmap$0
private Object readResolve()
private Object readResolve()
private Object readResolve()
byte YEAR
byte MONTH
scala.collection.Seq<A> yearMonthFields
scala.collection.immutable.Map<K,V> stringToField
YearMonthIntervalType DEFAULT
ColumnVector data
int offset
int length
int rowId
ColumnVector[] columns
ColumnarArray keys
ColumnarArray values
int length
ColumnVector data
int rowId
int numFields
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
int bitField0_
long id_
Object name_
Object update_
Object value_
byte memoizedIsInitialized
int bitField0_
Object attemptId_
long startTime_
long endTime_
long lastUpdated_
long duration_
Object sparkUser_
boolean completed_
Object appSparkVersion_
byte memoizedIsInitialized
StoreTypes.RuntimeInfo runtime_
java.util.List<E> sparkProperties_
java.util.List<E> hadoopProperties_
java.util.List<E> systemProperties_
java.util.List<E> metricsProperties_
java.util.List<E> classpathEntries_
java.util.List<E> resourceProfiles_
byte memoizedIsInitialized
StoreTypes.ApplicationEnvironmentInfo info_
byte memoizedIsInitialized
int bitField0_
Object id_
Object name_
int coresGranted_
int maxCores_
int coresPerExecutor_
int memoryPerExecutorMb_
java.util.List<E> attempts_
byte memoizedIsInitialized
StoreTypes.ApplicationInfo info_
byte memoizedIsInitialized
int numCompletedJobs_
int numCompletedStages_
byte memoizedIsInitialized
int bitField0_
long stageId_
int stageAttemptId_
Object quantile_
long taskCount_
double duration_
double executorDeserializeTime_
double executorDeserializeCpuTime_
double executorRunTime_
double executorCpuTime_
double resultSize_
double jvmGcTime_
double resultSerializationTime_
double gettingResultTime_
double schedulerDelay_
double peakExecutionMemory_
double memoryBytesSpilled_
double diskBytesSpilled_
double bytesRead_
double recordsRead_
double bytesWritten_
double recordsWritten_
double shuffleReadBytes_
double shuffleRecordsRead_
double shuffleRemoteBlocksFetched_
double shuffleLocalBlocksFetched_
double shuffleFetchWaitTime_
double shuffleRemoteBytesRead_
double shuffleRemoteBytesReadToDisk_
double shuffleTotalBlocksFetched_
double shuffleWriteBytes_
double shuffleWriteRecords_
double shuffleWriteTime_
double shuffleCorruptMergedBlockChunks_
double shuffleMergedFetchFallbackCount_
double shuffleMergedRemoteBlocksFetched_
double shuffleMergedLocalBlocksFetched_
double shuffleMergedRemoteChunksFetched_
double shuffleMergedLocalChunksFetched_
double shuffleMergedRemoteBytesRead_
double shuffleMergedLocalBytesRead_
double shuffleRemoteReqsDuration_
double shuffleMergedRemoteReqsDuration_
byte memoizedIsInitialized
com.google.protobuf.MapField<K,V> metrics_
byte memoizedIsInitialized
com.google.protobuf.Internal.DoubleList quantiles_
int quantilesMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList taskTime_
int taskTimeMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList failedTasks_
int failedTasksMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList succeededTasks_
int succeededTasksMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList killedTasks_
int killedTasksMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList inputBytes_
int inputBytesMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList inputRecords_
int inputRecordsMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList outputBytes_
int outputBytesMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList outputRecords_
int outputRecordsMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList shuffleRead_
int shuffleReadMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList shuffleReadRecords_
int shuffleReadRecordsMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList shuffleWrite_
int shuffleWriteMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList shuffleWriteRecords_
int shuffleWriteRecordsMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList memoryBytesSpilled_
int memoryBytesSpilledMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList diskBytesSpilled_
int diskBytesSpilledMemoizedSerializedSize
StoreTypes.ExecutorPeakMetricsDistributions peakMemoryMetrics_
byte memoizedIsInitialized
com.google.protobuf.Internal.DoubleList quantiles_
int quantilesMemoizedSerializedSize
java.util.List<E> executorMetrics_
byte memoizedIsInitialized
int bitField0_
Object resourceName_
long amount_
Object discoveryScript_
Object vendor_
byte memoizedIsInitialized
int bitField0_
long taskTime_
int failedTasks_
int succeededTasks_
int killedTasks_
long inputBytes_
long inputRecords_
long outputBytes_
long outputRecords_
long shuffleRead_
long shuffleReadRecords_
long shuffleWrite_
long shuffleWriteRecords_
long memoryBytesSpilled_
long diskBytesSpilled_
boolean isBlacklistedForStage_
StoreTypes.ExecutorMetrics peakMemoryMetrics_
boolean isExcludedForStage_
byte memoizedIsInitialized
int bitField0_
long stageId_
int stageAttemptId_
Object executorId_
StoreTypes.ExecutorStageSummary info_
byte memoizedIsInitialized
int bitField0_
Object id_
Object hostPort_
boolean isActive_
int rddBlocks_
long memoryUsed_
long diskUsed_
int totalCores_
int maxTasks_
int activeTasks_
int failedTasks_
int completedTasks_
int totalTasks_
long totalDuration_
long totalGcTime_
long totalInputBytes_
long totalShuffleRead_
long totalShuffleWrite_
boolean isBlacklisted_
long maxMemory_
long addTime_
long removeTime_
Object removeReason_
com.google.protobuf.MapField<K,V> executorLogs_
StoreTypes.MemoryMetrics memoryMetrics_
com.google.protobuf.Internal.LongList blacklistedInStages_
int blacklistedInStagesMemoizedSerializedSize
StoreTypes.ExecutorMetrics peakMemoryMetrics_
com.google.protobuf.MapField<K,V> attributes_
com.google.protobuf.MapField<K,V> resources_
int resourceProfileId_
boolean isExcluded_
com.google.protobuf.Internal.LongList excludedInStages_
int excludedInStagesMemoizedSerializedSize
byte memoizedIsInitialized
StoreTypes.ExecutorSummary info_
byte memoizedIsInitialized
com.google.protobuf.Internal.DoubleList bytesRead_
int bytesReadMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList recordsRead_
int recordsReadMemoizedSerializedSize
byte memoizedIsInitialized
long bytesRead_
long recordsRead_
byte memoizedIsInitialized
int bitField0_
long jobId_
Object name_
Object description_
long submissionTime_
long completionTime_
com.google.protobuf.Internal.LongList stageIds_
int stageIdsMemoizedSerializedSize
Object jobGroup_
int status_
int numTasks_
int numActiveTasks_
int numCompletedTasks_
int numSkippedTasks_
int numFailedTasks_
int numKilledTasks_
int numCompletedIndices_
int numActiveStages_
int numCompletedStages_
int numSkippedStages_
int numFailedStages_
com.google.protobuf.MapField<K,V> killTasksSummary_
byte memoizedIsInitialized
int bitField0_
StoreTypes.JobData info_
com.google.protobuf.Internal.IntList skippedStages_
int skippedStagesMemoizedSerializedSize
long sqlExecutionId_
byte memoizedIsInitialized
long usedOnHeapStorageMemory_
long usedOffHeapStorageMemory_
long totalOnHeapStorageMemory_
long totalOffHeapStorageMemory_
byte memoizedIsInitialized
com.google.protobuf.Internal.DoubleList bytesWritten_
int bytesWrittenMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList recordsWritten_
int recordsWrittenMemoizedSerializedSize
byte memoizedIsInitialized
long bytesWritten_
long recordsWritten_
byte memoizedIsInitialized
int bitField0_
Object value1_
Object value2_
byte memoizedIsInitialized
int bitField0_
Object name_
com.google.protobuf.Internal.LongList stageIds_
int stageIdsMemoizedSerializedSize
byte memoizedIsInitialized
int bitField0_
Object id_
Object hostPort_
boolean isActive_
int totalCores_
long addTime_
long removeTime_
com.google.protobuf.MapField<K,V> processLogs_
byte memoizedIsInitialized
StoreTypes.ProcessSummary info_
byte memoizedIsInitialized
int bitField0_
Object address_
long memoryUsed_
long memoryRemaining_
long diskUsed_
long onHeapMemoryUsed_
long offHeapMemoryUsed_
long onHeapMemoryRemaining_
long offHeapMemoryRemaining_
byte memoizedIsInitialized
int bitField0_
Object id_
Object name_
java.util.List<E> childNodes_
java.util.List<E> childClusters_
byte memoizedIsInitialized
int fromId_
int toId_
byte memoizedIsInitialized
long stageId_
java.util.List<E> edges_
java.util.List<E> outgoingEdges_
java.util.List<E> incomingEdges_
StoreTypes.RDDOperationClusterWrapper rootCluster_
byte memoizedIsInitialized
int bitField0_
int id_
Object name_
boolean cached_
boolean barrier_
Object callsite_
int outputDeterministicLevel_
byte memoizedIsInitialized
int bitField0_
Object blockName_
Object storageLevel_
long memoryUsed_
long diskUsed_
com.google.protobuf.LazyStringList executors_
byte memoizedIsInitialized
int bitField0_
int id_
Object name_
int numPartitions_
int numCachedPartitions_
Object storageLevel_
long memoryUsed_
long diskUsed_
java.util.List<E> dataDistribution_
java.util.List<E> partitions_
byte memoizedIsInitialized
StoreTypes.RDDStorageInfo info_
byte memoizedIsInitialized
int bitField0_
Object name_
com.google.protobuf.LazyStringList addresses_
byte memoizedIsInitialized
int id_
com.google.protobuf.MapField<K,V> executorResources_
com.google.protobuf.MapField<K,V> taskResources_
byte memoizedIsInitialized
StoreTypes.ResourceProfileInfo rpInfo_
byte memoizedIsInitialized
int bitField0_
Object javaVersion_
Object javaHome_
Object scalaVersion_
byte memoizedIsInitialized
com.google.protobuf.Internal.DoubleList corruptMergedBlockChunks_
int corruptMergedBlockChunksMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList mergedFetchFallbackCount_
int mergedFetchFallbackCountMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList remoteMergedBlocksFetched_
int remoteMergedBlocksFetchedMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList localMergedBlocksFetched_
int localMergedBlocksFetchedMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList remoteMergedChunksFetched_
int remoteMergedChunksFetchedMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList localMergedChunksFetched_
int localMergedChunksFetchedMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList remoteMergedBytesRead_
int remoteMergedBytesReadMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList localMergedBytesRead_
int localMergedBytesReadMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList remoteMergedReqsDuration_
int remoteMergedReqsDurationMemoizedSerializedSize
byte memoizedIsInitialized
long corruptMergedBlockChunks_
long mergedFetchFallbackCount_
long remoteMergedBlocksFetched_
long localMergedBlocksFetched_
long remoteMergedChunksFetched_
long localMergedChunksFetched_
long remoteMergedBytesRead_
long localMergedBytesRead_
long remoteMergedReqsDuration_
byte memoizedIsInitialized
com.google.protobuf.Internal.DoubleList readBytes_
int readBytesMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList readRecords_
int readRecordsMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList remoteBlocksFetched_
int remoteBlocksFetchedMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList localBlocksFetched_
int localBlocksFetchedMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList fetchWaitTime_
int fetchWaitTimeMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList remoteBytesRead_
int remoteBytesReadMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList remoteBytesReadToDisk_
int remoteBytesReadToDiskMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList totalBlocksFetched_
int totalBlocksFetchedMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList remoteReqsDuration_
int remoteReqsDurationMemoizedSerializedSize
StoreTypes.ShufflePushReadMetricDistributions shufflePushReadMetricsDist_
byte memoizedIsInitialized
long remoteBlocksFetched_
long localBlocksFetched_
long fetchWaitTime_
long remoteBytesRead_
long remoteBytesReadToDisk_
long localBytesRead_
long recordsRead_
long remoteReqsDuration_
StoreTypes.ShufflePushReadMetrics shufflePushReadMetrics_
byte memoizedIsInitialized
com.google.protobuf.Internal.DoubleList writeBytes_
int writeBytesMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList writeRecords_
int writeRecordsMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList writeTime_
int writeTimeMemoizedSerializedSize
byte memoizedIsInitialized
long bytesWritten_
long writeTime_
long recordsWritten_
byte memoizedIsInitialized
int bitField0_
Object description_
long numOutputRows_
com.google.protobuf.MapField<K,V> metrics_
byte memoizedIsInitialized
int bitField0_
Object description_
Object startOffset_
Object endOffset_
Object latestOffset_
long numInputRows_
double inputRowsPerSecond_
double processedRowsPerSecond_
com.google.protobuf.MapField<K,V> metrics_
byte memoizedIsInitialized
int bitField0_
long id_
Object name_
Object desc_
java.util.List<E> nodes_
java.util.List<E> metrics_
byte memoizedIsInitialized
long fromId_
long toId_
byte memoizedIsInitialized
int bitField0_
long id_
Object name_
Object desc_
java.util.List<E> metrics_
byte memoizedIsInitialized
int wrapperCase_
Object wrapper_
byte memoizedIsInitialized
long executionId_
java.util.List<E> nodes_
java.util.List<E> edges_
byte memoizedIsInitialized
int numTasks_
int numActiveTasks_
int numCompletedTasks_
int numFailedTasks_
int numKilledTasks_
byte memoizedIsInitialized
long stageId_
int stageAttemptId_
StoreTypes.SpeculationStageSummary info_
byte memoizedIsInitialized
int bitField0_
long executionId_
long rootExecutionId_
Object description_
Object details_
Object physicalPlanDescription_
com.google.protobuf.MapField<K,V> modifiedConfigs_
java.util.List<E> metrics_
long submissionTime_
long completionTime_
Object errorMessage_
com.google.protobuf.MapField<K,V> jobs_
com.google.protobuf.Internal.LongList stages_
int stagesMemoizedSerializedSize
boolean metricValuesIsNull_
com.google.protobuf.MapField<K,V> metricValues_
byte memoizedIsInitialized
int bitField0_
Object name_
long accumulatorId_
Object metricType_
byte memoizedIsInitialized
int bitField0_
int status_
long stageId_
int attemptId_
int numTasks_
int numActiveTasks_
int numCompleteTasks_
int numFailedTasks_
int numKilledTasks_
int numCompletedIndices_
long submissionTime_
long firstTaskLaunchedTime_
long completionTime_
Object failureReason_
long executorDeserializeTime_
long executorDeserializeCpuTime_
long executorRunTime_
long executorCpuTime_
long resultSize_
long jvmGcTime_
long resultSerializationTime_
long memoryBytesSpilled_
long diskBytesSpilled_
long peakExecutionMemory_
long inputBytes_
long inputRecords_
long outputBytes_
long outputRecords_
long shuffleRemoteBlocksFetched_
long shuffleLocalBlocksFetched_
long shuffleFetchWaitTime_
long shuffleRemoteBytesRead_
long shuffleRemoteBytesReadToDisk_
long shuffleLocalBytesRead_
long shuffleReadBytes_
long shuffleReadRecords_
long shuffleWriteBytes_
long shuffleWriteTime_
long shuffleWriteRecords_
Object name_
Object description_
Object details_
Object schedulingPool_
com.google.protobuf.Internal.LongList rddIds_
int rddIdsMemoizedSerializedSize
java.util.List<E> accumulatorUpdates_
com.google.protobuf.MapField<K,V> tasks_
com.google.protobuf.MapField<K,V> executorSummary_
StoreTypes.SpeculationStageSummary speculationSummary_
com.google.protobuf.MapField<K,V> killedTasksSummary_
int resourceProfileId_
StoreTypes.ExecutorMetrics peakExecutorMetrics_
StoreTypes.TaskMetricDistributions taskMetricsDistributions_
StoreTypes.ExecutorMetricsDistributions executorMetricsDistributions_
long shuffleCorruptMergedBlockChunks_
long shuffleMergedFetchFallbackCount_
long shuffleMergedRemoteBlocksFetched_
long shuffleMergedLocalBlocksFetched_
long shuffleMergedRemoteChunksFetched_
long shuffleMergedLocalChunksFetched_
long shuffleMergedRemoteBytesRead_
long shuffleMergedLocalBytesRead_
long shuffleRemoteReqsDuration_
long shuffleMergedRemoteReqsDuration_
boolean isShufflePushEnabled_
int shuffleMergersCount_
byte memoizedIsInitialized
StoreTypes.StageData info_
com.google.protobuf.Internal.LongList jobIds_
int jobIdsMemoizedSerializedSize
com.google.protobuf.MapField<K,V> locality_
byte memoizedIsInitialized
int bitField0_
Object operatorName_
long numRowsTotal_
long numRowsUpdated_
long allUpdatesTimeMs_
long numRowsRemoved_
long allRemovalsTimeMs_
long commitTimeMs_
long memoryUsedBytes_
long numRowsDroppedByWatermark_
long numShufflePartitions_
long numStateStoreInstances_
com.google.protobuf.MapField<K,V> customMetrics_
byte memoizedIsInitialized
int bitField0_
Object name_
Object executorId_
Object hostPort_
Object storageLevel_
boolean useMemory_
boolean useDisk_
boolean deserialized_
long memSize_
long diskSize_
byte memoizedIsInitialized
int bitField0_
Object name_
Object id_
Object runId_
boolean isActive_
Object exception_
long startTimestamp_
long endTimestamp_
byte memoizedIsInitialized
int bitField0_
Object id_
Object runId_
Object name_
Object timestamp_
long batchId_
long batchDuration_
com.google.protobuf.MapField<K,V> durationMs_
com.google.protobuf.MapField<K,V> eventTime_
java.util.List<E> stateOperators_
java.util.List<E> sources_
StoreTypes.SinkProgress sink_
com.google.protobuf.MapField<K,V> observedMetrics_
byte memoizedIsInitialized
StoreTypes.StreamingQueryProgress progress_
byte memoizedIsInitialized
int bitField0_
long taskId_
int index_
int attempt_
int partitionId_
long launchTime_
long resultFetchStart_
long duration_
Object executorId_
Object host_
Object status_
Object taskLocality_
boolean speculative_
java.util.List<E> accumulatorUpdates_
Object errorMessage_
StoreTypes.TaskMetrics taskMetrics_
com.google.protobuf.MapField<K,V> executorLogs_
long schedulerDelay_
long gettingResultTime_
byte memoizedIsInitialized
int bitField0_
long taskId_
int index_
int attempt_
int partitionId_
long launchTime_
long resultFetchStart_
long duration_
Object executorId_
Object host_
Object status_
Object taskLocality_
boolean speculative_
java.util.List<E> accumulatorUpdates_
Object errorMessage_
boolean hasMetrics_
long executorDeserializeTime_
long executorDeserializeCpuTime_
long executorRunTime_
long executorCpuTime_
long resultSize_
long jvmGcTime_
long resultSerializationTime_
long memoryBytesSpilled_
long diskBytesSpilled_
long peakExecutionMemory_
long inputBytesRead_
long inputRecordsRead_
long outputBytesWritten_
long outputRecordsWritten_
long shuffleRemoteBlocksFetched_
long shuffleLocalBlocksFetched_
long shuffleFetchWaitTime_
long shuffleRemoteBytesRead_
long shuffleRemoteBytesReadToDisk_
long shuffleLocalBytesRead_
long shuffleRecordsRead_
long shuffleBytesWritten_
long shuffleWriteTime_
long shuffleRecordsWritten_
long stageId_
int stageAttemptId_
long shuffleCorruptMergedBlockChunks_
long shuffleMergedFetchFallbackCount_
long shuffleMergedRemoteBlocksFetched_
long shuffleMergedLocalBlocksFetched_
long shuffleMergedRemoteChunksFetched_
long shuffleMergedLocalChunksFetched_
long shuffleMergedRemoteBytesRead_
long shuffleMergedLocalBytesRead_
long shuffleRemoteReqsDuration_
long shuffleMergedRemoteReqDuration_
byte memoizedIsInitialized
com.google.protobuf.Internal.DoubleList quantiles_
int quantilesMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList duration_
int durationMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList executorDeserializeTime_
int executorDeserializeTimeMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList executorDeserializeCpuTime_
int executorDeserializeCpuTimeMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList executorRunTime_
int executorRunTimeMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList executorCpuTime_
int executorCpuTimeMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList resultSize_
int resultSizeMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList jvmGcTime_
int jvmGcTimeMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList resultSerializationTime_
int resultSerializationTimeMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList gettingResultTime_
int gettingResultTimeMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList schedulerDelay_
int schedulerDelayMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList peakExecutionMemory_
int peakExecutionMemoryMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList memoryBytesSpilled_
int memoryBytesSpilledMemoizedSerializedSize
com.google.protobuf.Internal.DoubleList diskBytesSpilled_
int diskBytesSpilledMemoizedSerializedSize
StoreTypes.InputMetricDistributions inputMetrics_
StoreTypes.OutputMetricDistributions outputMetrics_
StoreTypes.ShuffleReadMetricDistributions shuffleReadMetrics_
StoreTypes.ShuffleWriteMetricDistributions shuffleWriteMetrics_
byte memoizedIsInitialized
long executorDeserializeTime_
long executorDeserializeCpuTime_
long executorRunTime_
long executorCpuTime_
long resultSize_
long jvmGcTime_
long resultSerializationTime_
long memoryBytesSpilled_
long diskBytesSpilled_
long peakExecutionMemory_
StoreTypes.InputMetrics inputMetrics_
StoreTypes.OutputMetrics outputMetrics_
StoreTypes.ShuffleReadMetrics shuffleReadMetrics_
StoreTypes.ShuffleWriteMetrics shuffleWriteMetrics_
byte memoizedIsInitialized
int bitField0_
Object resourceName_
double amount_
byte memoizedIsInitialized
private Object readResolve()
public void readExternal(java.io.ObjectInput in)
public void writeExternal(java.io.ObjectOutput out)
private Object readResolve()
com.google.common.cache.LoadingCache<K,V> blockManagerIdCache
String SHUFFLE_MERGER_IDENTIFIER
String INVALID_EXECUTOR_ID
public void readExternal(java.io.ObjectInput in)
public void writeExternal(java.io.ObjectOutput out)
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
public void readExternal(java.io.ObjectInput in)
public void writeExternal(java.io.ObjectOutput out)
private Object readResolve()
StorageLevel NONE
StorageLevel DISK_ONLY
StorageLevel DISK_ONLY_2
StorageLevel DISK_ONLY_3
StorageLevel MEMORY_ONLY
StorageLevel MEMORY_ONLY_2
StorageLevel MEMORY_ONLY_SER
StorageLevel MEMORY_ONLY_SER_2
StorageLevel MEMORY_AND_DISK
StorageLevel MEMORY_AND_DISK_2
StorageLevel MEMORY_AND_DISK_SER
StorageLevel MEMORY_AND_DISK_SER_2
StorageLevel OFF_HEAP
java.util.concurrent.ConcurrentHashMap<K,V> storageLevelCache
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
String PREFIX
scala.util.matching.Regex REGEX
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.math.Ordering<T> ordering
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.util.matching.Regex SPARK_CLASS_REGEX
scala.util.matching.Regex SPARK_STREAMING_TESTCLASS_REGEX
scala.util.matching.Regex SPARK_EXAMPLES_CLASS_REGEX
scala.util.matching.Regex SCALA_CLASS_REGEX
private Object readResolve()
private Object readResolve()
int org$apache$spark$streaming$dstream$InternalMapWithStateDStream$$DEFAULT_CHECKPOINT_DURATION_MULTIPLIER
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
java.util.Date timestamp
private Object readResolve()
String DEFAULT_KINESIS_ENDPOINT_URL
String DEFAULT_KINESIS_REGION_NAME
org.apache.spark.streaming.kinesis.KinesisInitialPosition DEFAULT_INITIAL_POSITION
StorageLevel DEFAULT_STORAGE_LEVEL
com.amazonaws.services.kinesis.metrics.interfaces.MetricsLevel DEFAULT_METRICS_LEVEL
scala.collection.immutable.Set<A> DEFAULT_METRICS_ENABLED_DIMENSIONS
private Object readResolve()
String RETRY_MAX_ATTEMPTS_KEY
String RETRY_WAIT_TIME_KEY
int DEFAULT_MAX_RETRIES
String DEFAULT_RETRY_WAIT_TIME
int DEFAULT_RETRY_TIMEOUT
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
scala.Enumeration.Value INACTIVE
scala.Enumeration.Value SCHEDULED
scala.Enumeration.Value ACTIVE
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
String METADATA_KEY_DESCRIPTION
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
int DELTA_CHAIN_LENGTH_THRESHOLD
int DEFAULT_INITIAL_CAPACITY
private Object readResolve()
private Object readResolve()
private Object readResolve()
int months
int days
long microseconds
public void readExternal(java.io.ObjectInput arg0) throws java.io.IOException, ClassNotFoundException
java.io.IOException
ClassNotFoundException
public void writeExternal(java.io.ObjectOutput arg0) throws java.io.IOException
java.io.IOException
private Object readResolve()
protected final Object writeReplace()
private Object readResolve()
String SHORT_FORM
String LONG_FORM
org.apache.spark.util.CallSite empty
private Object readResolve()
private Object readResolve()
private Object readResolve()
char _1$mcC$sp
char _2$mcC$sp
char _1$mcC$sp
double _2$mcD$sp
char _1$mcC$sp
int _2$mcI$sp
char _1$mcC$sp
long _2$mcJ$sp
char _1$mcC$sp
boolean _2$mcZ$sp
double _1$mcD$sp
char _2$mcC$sp
double _1$mcD$sp
double _2$mcD$sp
double _1$mcD$sp
int _2$mcI$sp
double _1$mcD$sp
long _2$mcJ$sp
double _1$mcD$sp
boolean _2$mcZ$sp
int _1$mcI$sp
char _2$mcC$sp
int _1$mcI$sp
double _2$mcD$sp
int _1$mcI$sp
int _2$mcI$sp
int _1$mcI$sp
long _2$mcJ$sp
int _1$mcI$sp
boolean _2$mcZ$sp
long _1$mcJ$sp
char _2$mcC$sp
long _1$mcJ$sp
double _2$mcD$sp
long _1$mcJ$sp
int _2$mcI$sp
long _1$mcJ$sp
long _2$mcJ$sp
long _1$mcJ$sp
boolean _2$mcZ$sp
boolean _1$mcZ$sp
char _2$mcC$sp
boolean _1$mcZ$sp
double _2$mcD$sp
boolean _1$mcZ$sp
int _2$mcI$sp
boolean _1$mcZ$sp
long _2$mcJ$sp
boolean _1$mcZ$sp
boolean _2$mcZ$sp
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
double defaultMaxGapSamplingFraction
double rngEpsilon
double roundingEpsilon
private Object readResolve()