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
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()
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()
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()
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()
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()
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()
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()
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()
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()
private Object readResolve()
private Object readResolve()
Expression expression
DataType dataType
private Object readResolve()
private Object readResolve()
String name
Expression[] children
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
AggregateFunc[] aggregateExpressions
Expression[] groupByExpressions
Expression input
boolean isDistinct
Expression input
boolean isDistinct
String name
boolean isDistinct
Expression[] children
Expression input
Expression input
Expression input
boolean isDistinct
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> supportedFunctions
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
private Object readResolve()
int BINARY_FLOAT
int BINARY_DOUBLE
int TIMESTAMPTZ
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()
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
scala.math.BigDecimal org$apache$spark$sql$types$Decimal$$BIG_DEC_ZERO
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
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()
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
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()