Serialized Form

Package org.apache.hadoop.hive.ql.io.orc

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.BinaryStatistics extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

sum_

long sum_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.BloomFilter extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

numHashFunctions_

int numHashFunctions_

bitset_

java.util.List<E> bitset_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.BloomFilterIndex extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bloomFilter_

java.util.List<E> bloomFilter_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.BucketStatistics extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

count_

java.util.List<E> count_

countMemoizedSerializedSize

int countMemoizedSerializedSize

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.ColumnEncoding extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

kind_

org.apache.hadoop.hive.ql.io.orc.OrcProto.ColumnEncoding.Kind kind_

dictionarySize_

int dictionarySize_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.ColumnStatistics extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

numberOfValues_

long numberOfValues_

intStatistics_

org.apache.hadoop.hive.ql.io.orc.OrcProto.IntegerStatistics intStatistics_

doubleStatistics_

org.apache.hadoop.hive.ql.io.orc.OrcProto.DoubleStatistics doubleStatistics_

stringStatistics_

org.apache.hadoop.hive.ql.io.orc.OrcProto.StringStatistics stringStatistics_

bucketStatistics_

org.apache.hadoop.hive.ql.io.orc.OrcProto.BucketStatistics bucketStatistics_

decimalStatistics_

org.apache.hadoop.hive.ql.io.orc.OrcProto.DecimalStatistics decimalStatistics_

dateStatistics_

org.apache.hadoop.hive.ql.io.orc.OrcProto.DateStatistics dateStatistics_

binaryStatistics_

org.apache.hadoop.hive.ql.io.orc.OrcProto.BinaryStatistics binaryStatistics_

timestampStatistics_

org.apache.hadoop.hive.ql.io.orc.OrcProto.TimestampStatistics timestampStatistics_

hasNull_

boolean hasNull_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.DateStatistics extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

minimum_

int minimum_

maximum_

int maximum_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.DecimalStatistics extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

minimum_

java.lang.Object minimum_

maximum_

java.lang.Object maximum_

sum_

java.lang.Object sum_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.DoubleStatistics extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

minimum_

double minimum_

maximum_

double maximum_

sum_

double sum_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.Footer extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

headerLength_

long headerLength_

contentLength_

long contentLength_

stripes_

java.util.List<E> stripes_

types_

java.util.List<E> types_

metadata_

java.util.List<E> metadata_

numberOfRows_

long numberOfRows_

statistics_

java.util.List<E> statistics_

rowIndexStride_

int rowIndexStride_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.IntegerStatistics extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

minimum_

long minimum_

maximum_

long maximum_

sum_

long sum_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.Metadata extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

stripeStats_

java.util.List<E> stripeStats_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.PostScript extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

footerLength_

long footerLength_

compression_

org.apache.hadoop.hive.ql.io.orc.OrcProto.CompressionKind compression_

compressionBlockSize_

long compressionBlockSize_

version_

java.util.List<E> version_

versionMemoizedSerializedSize

int versionMemoizedSerializedSize

metadataLength_

long metadataLength_

writerVersion_

int writerVersion_

magic_

java.lang.Object magic_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.RowIndex extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

entry_

java.util.List<E> entry_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.RowIndexEntry extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

positions_

java.util.List<E> positions_

positionsMemoizedSerializedSize

int positionsMemoizedSerializedSize

statistics_

org.apache.hadoop.hive.ql.io.orc.OrcProto.ColumnStatistics statistics_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.Stream extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

kind_

org.apache.hadoop.hive.ql.io.orc.OrcProto.Stream.Kind kind_

column_

int column_

length_

long length_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.StringStatistics extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

minimum_

java.lang.Object minimum_

maximum_

java.lang.Object maximum_

sum_

long sum_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.StripeFooter extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

streams_

java.util.List<E> streams_

columns_

java.util.List<E> columns_

writerTimezone_

java.lang.Object writerTimezone_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.StripeInformation extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

offset_

long offset_

indexLength_

long indexLength_

dataLength_

long dataLength_

footerLength_

long footerLength_

numberOfRows_

long numberOfRows_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.StripeStatistics extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

colStats_

java.util.List<E> colStats_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.TimestampStatistics extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

minimum_

long minimum_

maximum_

long maximum_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.Type extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

kind_

org.apache.hadoop.hive.ql.io.orc.OrcProto.Type.Kind kind_

subtypes_

java.util.List<E> subtypes_

subtypesMemoizedSerializedSize

int subtypesMemoizedSerializedSize

fieldNames_

org.apache.hive.com.google.protobuf.LazyStringList fieldNames_

maximumLength_

int maximumLength_

precision_

int precision_

scale_

int scale_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.hadoop.hive.ql.io.orc.OrcProto.UserMetadataItem extends org.apache.hive.com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialization Methods

writeReplace

protected java.lang.Object writeReplace()
                                 throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

unknownFields

org.apache.hive.com.google.protobuf.UnknownFieldSet unknownFields

bitField0_

int bitField0_

name_

java.lang.Object name_

value_

org.apache.hive.com.google.protobuf.ByteString value_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Package org.apache.spark

Class org.apache.spark.Accumulable extends java.lang.Object implements Serializable

Class org.apache.spark.Accumulator extends Accumulable<T,T> implements Serializable

Class org.apache.spark.Accumulator$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.AccumulatorParam.DoubleAccumulatorParam$ extends java.lang.Object implements Serializable

Class org.apache.spark.AccumulatorParam.FloatAccumulatorParam$ extends java.lang.Object implements Serializable

Class org.apache.spark.AccumulatorParam.IntAccumulatorParam$ extends java.lang.Object implements Serializable

Class org.apache.spark.AccumulatorParam.LongAccumulatorParam$ extends java.lang.Object implements Serializable

Class org.apache.spark.AccumulatorParam.StringAccumulatorParam$ extends java.lang.Object implements Serializable

Class org.apache.spark.AccumulatorParam$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.Aggregator extends java.lang.Object implements Serializable

Class org.apache.spark.Aggregator$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.CleanAccum extends java.lang.Object implements Serializable

Class org.apache.spark.CleanAccum$ extends scala.runtime.AbstractFunction1<java.lang.Object,CleanAccum> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.CleanBroadcast extends java.lang.Object implements Serializable

Class org.apache.spark.CleanBroadcast$ extends scala.runtime.AbstractFunction1<java.lang.Object,CleanBroadcast> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.CleanCheckpoint extends java.lang.Object implements Serializable

Class org.apache.spark.CleanCheckpoint$ extends scala.runtime.AbstractFunction1<java.lang.Object,CleanCheckpoint> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.CleanRDD extends java.lang.Object implements Serializable

Class org.apache.spark.CleanRDD$ extends scala.runtime.AbstractFunction1<java.lang.Object,CleanRDD> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.CleanShuffle extends java.lang.Object implements Serializable

Class org.apache.spark.CleanShuffle$ extends scala.runtime.AbstractFunction1<java.lang.Object,CleanShuffle> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.Dependency extends java.lang.Object implements Serializable

Class org.apache.spark.ExceptionFailure extends java.lang.Object implements Serializable

Class org.apache.spark.ExceptionFailure$ extends scala.runtime.AbstractFunction7<java.lang.String,java.lang.String,java.lang.StackTraceElement[],java.lang.String,scala.Option<org.apache.spark.ThrowableSerializationWrapper>,scala.collection.Seq<AccumulableInfo>,scala.collection.Seq<AccumulatorV2<?,?>>,ExceptionFailure> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ExecutorLostFailure extends java.lang.Object implements Serializable

Class org.apache.spark.ExecutorLostFailure$ extends scala.runtime.AbstractFunction3<java.lang.String,java.lang.Object,scala.Option<java.lang.String>,ExecutorLostFailure> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ExecutorRegistered extends java.lang.Object implements Serializable

Class org.apache.spark.ExecutorRegistered$ extends scala.runtime.AbstractFunction1<java.lang.String,ExecutorRegistered> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ExecutorRemoved extends java.lang.Object implements Serializable

Class org.apache.spark.ExecutorRemoved$ extends scala.runtime.AbstractFunction1<java.lang.String,ExecutorRemoved> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ExpireDeadHosts$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.FetchFailed extends java.lang.Object implements Serializable

Class org.apache.spark.FetchFailed$ extends scala.runtime.AbstractFunction5<BlockManagerId,java.lang.Object,java.lang.Object,java.lang.Object,java.lang.String,FetchFailed> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.GetMapOutputMessage$ extends scala.runtime.AbstractFunction2<java.lang.Object,org.apache.spark.rpc.RpcCallContext,org.apache.spark.GetMapOutputMessage> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.GetMapOutputStatuses$ extends scala.runtime.AbstractFunction1<java.lang.Object,org.apache.spark.GetMapOutputStatuses> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.HashPartitioner extends Partitioner implements Serializable

Class org.apache.spark.Heartbeat$ extends scala.runtime.AbstractFunction3<java.lang.String,scala.Tuple2<java.lang.Object,scala.collection.Seq<AccumulatorV2<?,?>>>[],BlockManagerId,org.apache.spark.Heartbeat> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.HeartbeatResponse$ extends scala.runtime.AbstractFunction1<java.lang.Object,org.apache.spark.HeartbeatResponse> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.NarrowDependency extends Dependency<T> implements Serializable

Class org.apache.spark.OneToOneDependency extends NarrowDependency<T> implements Serializable

Class org.apache.spark.Partitioner extends java.lang.Object implements Serializable

Class org.apache.spark.Partitioner$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.RangeDependency extends NarrowDependency<T> implements Serializable

Class org.apache.spark.RangePartitioner extends Partitioner implements Serializable

Serialization Methods

readObject

private void readObject(java.io.ObjectInputStream in)
                 throws java.io.IOException

Throws:

java.io.IOException

writeObject

private void writeObject(java.io.ObjectOutputStream out)
                  throws java.io.IOException

Throws:

java.io.IOException

Class org.apache.spark.RangePartitioner$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.Resubmitted$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.SerializableWritable extends java.lang.Object implements Serializable

Serialization Methods

readObject

private void readObject(java.io.ObjectInputStream in)

writeObject

private void writeObject(java.io.ObjectOutputStream out)

Class org.apache.spark.ShuffleDependency extends Dependency<scala.Product2<K,V>> implements Serializable

Class org.apache.spark.ShuffleDependency$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.SparkException extends java.lang.Exception implements Serializable

Class org.apache.spark.SparkExecutorInfoImpl extends java.lang.Object implements Serializable

Class org.apache.spark.SparkHadoopWriter$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.SparkJobInfoImpl extends java.lang.Object implements Serializable

Class org.apache.spark.SparkStageInfoImpl extends java.lang.Object implements Serializable

Class org.apache.spark.SparkUserAppException$ extends scala.runtime.AbstractFunction1<java.lang.Object,org.apache.spark.SparkUserAppException> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.SSLOptions$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.StopMapOutputTracker$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.Success$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.TaskCommitDenied extends java.lang.Object implements Serializable

Class org.apache.spark.TaskCommitDenied$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.Object,java.lang.Object,TaskCommitDenied> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.TaskContext extends java.lang.Object implements Serializable

Class org.apache.spark.TaskContext$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

taskContext

java.lang.ThreadLocal<T> taskContext

Class org.apache.spark.TaskContextImpl$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.TaskKilled$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.TaskKilledException extends java.lang.RuntimeException implements Serializable

Class org.apache.spark.TaskResultLost$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.TaskSchedulerIsSet$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.TaskState$ extends scala.Enumeration implements Serializable

Serialized Fields

LAUNCHING

scala.Enumeration.Value LAUNCHING

RUNNING

scala.Enumeration.Value RUNNING

FINISHED

scala.Enumeration.Value FINISHED

FAILED

scala.Enumeration.Value FAILED

KILLED

scala.Enumeration.Value KILLED

LOST

scala.Enumeration.Value LOST

FINISHED_STATES

scala.collection.immutable.Set<A> FINISHED_STATES

Class org.apache.spark.UnknownReason$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.WritableConverter$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.WritableFactory$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.api.java

Class org.apache.spark.api.java.JavaDoubleRDD extends org.apache.spark.api.java.AbstractJavaRDDLike<java.lang.Double,JavaDoubleRDD> implements Serializable

Class org.apache.spark.api.java.JavaDoubleRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.api.java.JavaHadoopRDD extends JavaPairRDD<K,V> implements Serializable

Class org.apache.spark.api.java.JavaNewHadoopRDD extends JavaPairRDD<K,V> implements Serializable

Class org.apache.spark.api.java.JavaPairRDD extends org.apache.spark.api.java.AbstractJavaRDDLike<scala.Tuple2<K,V>,JavaPairRDD<K,V>> implements Serializable

Class org.apache.spark.api.java.JavaPairRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.api.java.JavaRDD extends org.apache.spark.api.java.AbstractJavaRDDLike<T,JavaRDD<T>> implements Serializable

Class org.apache.spark.api.java.JavaRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.api.java.JavaUtils.SerializableMapWrapper extends java.util.AbstractMap<A,B> implements Serializable

Class org.apache.spark.api.java.Optional extends java.lang.Object implements Serializable

Serialized Fields

value

java.lang.Object value

Package org.apache.spark.api.java.function

Package org.apache.spark.api.r

Class org.apache.spark.api.r.BaseRRDD extends RDD<U> implements Serializable

Class org.apache.spark.api.r.PairwiseRRDD extends BaseRRDD<T,scala.Tuple2<java.lang.Object,byte[]>> implements Serializable

Class org.apache.spark.api.r.RRDD extends BaseRRDD<T,byte[]> implements Serializable

Class org.apache.spark.api.r.RRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.api.r.StringRRDD extends BaseRRDD<T,java.lang.String> implements Serializable

Package org.apache.spark.broadcast

Class org.apache.spark.broadcast.Broadcast extends java.lang.Object implements Serializable

Class org.apache.spark.broadcast.TorrentBroadcast$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.graphx

Class org.apache.spark.graphx.Edge extends java.lang.Object implements Serializable

Class org.apache.spark.graphx.Edge$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.graphx.Edge$mcB$sp extends Edge<java.lang.Object> implements Serializable

Serialized Fields

attr$mcB$sp

byte attr$mcB$sp

Class org.apache.spark.graphx.Edge$mcC$sp extends Edge<java.lang.Object> implements Serializable

Serialized Fields

attr$mcC$sp

char attr$mcC$sp

Class org.apache.spark.graphx.Edge$mcD$sp extends Edge<java.lang.Object> implements Serializable

Serialized Fields

attr$mcD$sp

double attr$mcD$sp

Class org.apache.spark.graphx.Edge$mcF$sp extends Edge<java.lang.Object> implements Serializable

Serialized Fields

attr$mcF$sp

float attr$mcF$sp

Class org.apache.spark.graphx.Edge$mcI$sp extends Edge<java.lang.Object> implements Serializable

Serialized Fields

attr$mcI$sp

int attr$mcI$sp

Class org.apache.spark.graphx.Edge$mcJ$sp extends Edge<java.lang.Object> implements Serializable

Serialized Fields

attr$mcJ$sp

long attr$mcJ$sp

Class org.apache.spark.graphx.Edge$mcZ$sp extends Edge<java.lang.Object> implements Serializable

Serialized Fields

attr$mcZ$sp

boolean attr$mcZ$sp

Class org.apache.spark.graphx.EdgeDirection extends java.lang.Object implements Serializable

Class org.apache.spark.graphx.EdgeDirection$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

In

EdgeDirection In

Out

EdgeDirection Out

Either

EdgeDirection Either

Both

EdgeDirection Both

Class org.apache.spark.graphx.EdgeRDD extends RDD<Edge<ED>> implements Serializable

Class org.apache.spark.graphx.EdgeRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.graphx.EdgeTriplet extends Edge<ED> implements Serializable

Class org.apache.spark.graphx.Graph extends java.lang.Object implements Serializable

Class org.apache.spark.graphx.Graph$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.graphx.GraphOps extends java.lang.Object implements Serializable

Class org.apache.spark.graphx.PartitionStrategy.CanonicalRandomVertexCut$ extends java.lang.Object implements Serializable

Class org.apache.spark.graphx.PartitionStrategy.EdgePartition1D$ extends java.lang.Object implements Serializable

Class org.apache.spark.graphx.PartitionStrategy.EdgePartition2D$ extends java.lang.Object implements Serializable

Class org.apache.spark.graphx.PartitionStrategy.RandomVertexCut$ extends java.lang.Object implements Serializable

Class org.apache.spark.graphx.PartitionStrategy$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.graphx.TripletFields extends java.lang.Object implements Serializable

Serialized Fields

useSrc

boolean useSrc

Indicates whether the source vertex attribute is included.

useDst

boolean useDst

Indicates whether the destination vertex attribute is included.

useEdge

boolean useEdge

Indicates whether the edge attribute is included.

Class org.apache.spark.graphx.VertexRDD extends RDD<scala.Tuple2<java.lang.Object,VD>> implements Serializable

Class org.apache.spark.graphx.VertexRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.graphx.impl

Class org.apache.spark.graphx.impl.EdgePartition$mcB$sp extends org.apache.spark.graphx.impl.EdgePartition<java.lang.Object,VD> implements Serializable

Serialized Fields

org$apache$spark$graphx$impl$EdgePartition$$data$mcB$sp

byte[] org$apache$spark$graphx$impl$EdgePartition$$data$mcB$sp

localSrcIds

int[] localSrcIds

localDstIds

int[] localDstIds

data$mcB$sp

byte[] data$mcB$sp

index

org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> index

global2local

org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> global2local

local2global

long[] local2global

vertexAttrs

java.lang.Object vertexAttrs

activeSet

scala.Option<A> activeSet

evidence$1

scala.reflect.ClassTag<T> evidence$1

evidence$2

scala.reflect.ClassTag<T> evidence$2

Class org.apache.spark.graphx.impl.EdgePartition$mcC$sp extends org.apache.spark.graphx.impl.EdgePartition<java.lang.Object,VD> implements Serializable

Serialized Fields

org$apache$spark$graphx$impl$EdgePartition$$data$mcC$sp

char[] org$apache$spark$graphx$impl$EdgePartition$$data$mcC$sp

localSrcIds

int[] localSrcIds

localDstIds

int[] localDstIds

data$mcC$sp

char[] data$mcC$sp

index

org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> index

global2local

org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> global2local

local2global

long[] local2global

vertexAttrs

java.lang.Object vertexAttrs

activeSet

scala.Option<A> activeSet

evidence$1

scala.reflect.ClassTag<T> evidence$1

evidence$2

scala.reflect.ClassTag<T> evidence$2

Class org.apache.spark.graphx.impl.EdgePartition$mcD$sp extends org.apache.spark.graphx.impl.EdgePartition<java.lang.Object,VD> implements Serializable

Serialized Fields

org$apache$spark$graphx$impl$EdgePartition$$data$mcD$sp

double[] org$apache$spark$graphx$impl$EdgePartition$$data$mcD$sp

localSrcIds

int[] localSrcIds

localDstIds

int[] localDstIds

data$mcD$sp

double[] data$mcD$sp

index

org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> index

global2local

org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> global2local

local2global

long[] local2global

vertexAttrs

java.lang.Object vertexAttrs

activeSet

scala.Option<A> activeSet

evidence$1

scala.reflect.ClassTag<T> evidence$1

evidence$2

scala.reflect.ClassTag<T> evidence$2

Class org.apache.spark.graphx.impl.EdgePartition$mcF$sp extends org.apache.spark.graphx.impl.EdgePartition<java.lang.Object,VD> implements Serializable

Serialized Fields

org$apache$spark$graphx$impl$EdgePartition$$data$mcF$sp

float[] org$apache$spark$graphx$impl$EdgePartition$$data$mcF$sp

localSrcIds

int[] localSrcIds

localDstIds

int[] localDstIds

data$mcF$sp

float[] data$mcF$sp

index

org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> index

global2local

org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> global2local

local2global

long[] local2global

vertexAttrs

java.lang.Object vertexAttrs

activeSet

scala.Option<A> activeSet

evidence$1

scala.reflect.ClassTag<T> evidence$1

evidence$2

scala.reflect.ClassTag<T> evidence$2

Class org.apache.spark.graphx.impl.EdgePartition$mcI$sp extends org.apache.spark.graphx.impl.EdgePartition<java.lang.Object,VD> implements Serializable

Serialized Fields

org$apache$spark$graphx$impl$EdgePartition$$data$mcI$sp

int[] org$apache$spark$graphx$impl$EdgePartition$$data$mcI$sp

localSrcIds

int[] localSrcIds

localDstIds

int[] localDstIds

data$mcI$sp

int[] data$mcI$sp

index

org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> index

global2local

org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> global2local

local2global

long[] local2global

vertexAttrs

java.lang.Object vertexAttrs

activeSet

scala.Option<A> activeSet

evidence$1

scala.reflect.ClassTag<T> evidence$1

evidence$2

scala.reflect.ClassTag<T> evidence$2

Class org.apache.spark.graphx.impl.EdgePartition$mcJ$sp extends org.apache.spark.graphx.impl.EdgePartition<java.lang.Object,VD> implements Serializable

Serialized Fields

org$apache$spark$graphx$impl$EdgePartition$$data$mcJ$sp

long[] org$apache$spark$graphx$impl$EdgePartition$$data$mcJ$sp

localSrcIds

int[] localSrcIds

localDstIds

int[] localDstIds

data$mcJ$sp

long[] data$mcJ$sp

index

org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> index

global2local

org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> global2local

local2global

long[] local2global

vertexAttrs

java.lang.Object vertexAttrs

activeSet

scala.Option<A> activeSet

evidence$1

scala.reflect.ClassTag<T> evidence$1

evidence$2

scala.reflect.ClassTag<T> evidence$2

Class org.apache.spark.graphx.impl.EdgePartition$mcZ$sp extends org.apache.spark.graphx.impl.EdgePartition<java.lang.Object,VD> implements Serializable

Serialized Fields

org$apache$spark$graphx$impl$EdgePartition$$data$mcZ$sp

boolean[] org$apache$spark$graphx$impl$EdgePartition$$data$mcZ$sp

localSrcIds

int[] localSrcIds

localDstIds

int[] localDstIds

data$mcZ$sp

boolean[] data$mcZ$sp

index

org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> index

global2local

org.apache.spark.graphx.util.collection.GraphXPrimitiveKeyOpenHashMap<K,V> global2local

local2global

long[] local2global

vertexAttrs

java.lang.Object vertexAttrs

activeSet

scala.Option<A> activeSet

evidence$1

scala.reflect.ClassTag<T> evidence$1

evidence$2

scala.reflect.ClassTag<T> evidence$2

Class org.apache.spark.graphx.impl.EdgeRDDImpl extends EdgeRDD<ED> implements Serializable

Class org.apache.spark.graphx.impl.EdgeRDDImpl$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.graphx.impl.EdgeWithLocalIds$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.graphx.impl.EdgeWithLocalIds$mcB$sp extends org.apache.spark.graphx.impl.EdgeWithLocalIds<java.lang.Object> implements Serializable

Serialized Fields

attr$mcB$sp

byte attr$mcB$sp

Class org.apache.spark.graphx.impl.EdgeWithLocalIds$mcC$sp extends org.apache.spark.graphx.impl.EdgeWithLocalIds<java.lang.Object> implements Serializable

Serialized Fields

attr$mcC$sp

char attr$mcC$sp

Class org.apache.spark.graphx.impl.EdgeWithLocalIds$mcD$sp extends org.apache.spark.graphx.impl.EdgeWithLocalIds<java.lang.Object> implements Serializable

Serialized Fields

attr$mcD$sp

double attr$mcD$sp

Class org.apache.spark.graphx.impl.EdgeWithLocalIds$mcF$sp extends org.apache.spark.graphx.impl.EdgeWithLocalIds<java.lang.Object> implements Serializable

Serialized Fields

attr$mcF$sp

float attr$mcF$sp

Class org.apache.spark.graphx.impl.EdgeWithLocalIds$mcI$sp extends org.apache.spark.graphx.impl.EdgeWithLocalIds<java.lang.Object> implements Serializable

Serialized Fields

attr$mcI$sp

int attr$mcI$sp

Class org.apache.spark.graphx.impl.EdgeWithLocalIds$mcJ$sp extends org.apache.spark.graphx.impl.EdgeWithLocalIds<java.lang.Object> implements Serializable

Serialized Fields

attr$mcJ$sp

long attr$mcJ$sp

Class org.apache.spark.graphx.impl.EdgeWithLocalIds$mcS$sp extends org.apache.spark.graphx.impl.EdgeWithLocalIds<java.lang.Object> implements Serializable

Serialized Fields

attr$mcS$sp

short attr$mcS$sp

Class org.apache.spark.graphx.impl.EdgeWithLocalIds$mcV$sp extends org.apache.spark.graphx.impl.EdgeWithLocalIds<scala.runtime.BoxedUnit> implements Serializable

Serialized Fields

attr$mcV$sp

scala.runtime.BoxedUnit attr$mcV$sp

Class org.apache.spark.graphx.impl.EdgeWithLocalIds$mcZ$sp extends org.apache.spark.graphx.impl.EdgeWithLocalIds<java.lang.Object> implements Serializable

Serialized Fields

attr$mcZ$sp

boolean attr$mcZ$sp

Class org.apache.spark.graphx.impl.GraphImpl extends Graph<VD,ED> implements Serializable

Class org.apache.spark.graphx.impl.GraphImpl$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.graphx.impl.RoutingTablePartition$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

empty

org.apache.spark.graphx.impl.RoutingTablePartition empty

Class org.apache.spark.graphx.impl.ShippableVertexPartition$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.graphx.impl.VertexPartition$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.graphx.impl.VertexPartitionBase$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.graphx.impl.VertexPartitionBase$mcD$sp extends org.apache.spark.graphx.impl.VertexPartitionBase<java.lang.Object> implements Serializable

Serialized Fields

evidence$3

scala.reflect.ClassTag<T> evidence$3

Class org.apache.spark.graphx.impl.VertexPartitionBase$mcI$sp extends org.apache.spark.graphx.impl.VertexPartitionBase<java.lang.Object> implements Serializable

Serialized Fields

evidence$3

scala.reflect.ClassTag<T> evidence$3

Class org.apache.spark.graphx.impl.VertexPartitionBase$mcJ$sp extends org.apache.spark.graphx.impl.VertexPartitionBase<java.lang.Object> implements Serializable

Serialized Fields

evidence$3

scala.reflect.ClassTag<T> evidence$3

Class org.apache.spark.graphx.impl.VertexRDDImpl extends VertexRDD<VD> implements Serializable

Class org.apache.spark.graphx.impl.VertexRDDImpl$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.graphx.lib

Class org.apache.spark.graphx.lib.SVDPlusPlus.Conf extends java.lang.Object implements Serializable

Package org.apache.spark.input

Class org.apache.spark.input.PortableDataStream extends java.lang.Object implements Serializable

Package org.apache.spark.internal.config

Class org.apache.spark.internal.config.ConfigBuilder$ extends scala.runtime.AbstractFunction1<java.lang.String,org.apache.spark.internal.config.ConfigBuilder> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.ml

Class org.apache.spark.ml.Estimator extends PipelineStage implements Serializable

Class org.apache.spark.ml.Model extends Transformer implements Serializable

Class org.apache.spark.ml.Pipeline extends Estimator<PipelineModel> implements Serializable

Class org.apache.spark.ml.Pipeline$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.PipelineModel extends Model<PipelineModel> implements Serializable

Class org.apache.spark.ml.PipelineModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.PipelineStage extends java.lang.Object implements Serializable

Class org.apache.spark.ml.PredictionModel extends Model<M extends PredictionModel<FeaturesType,M>> implements Serializable

Class org.apache.spark.ml.Predictor extends Estimator<M extends PredictionModel<FeaturesType,M>> implements Serializable

Class org.apache.spark.ml.Transformer extends PipelineStage implements Serializable

Class org.apache.spark.ml.UnaryTransformer extends Transformer implements Serializable

Package org.apache.spark.ml.ann

Class org.apache.spark.ml.ann.AffineLayerModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.ann.FeedForwardModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.ann.FeedForwardTopology$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.ml.attribute

Class org.apache.spark.ml.attribute.Attribute extends java.lang.Object implements Serializable

Class org.apache.spark.ml.attribute.Attribute$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.attribute.AttributeGroup extends java.lang.Object implements Serializable

Class org.apache.spark.ml.attribute.AttributeGroup$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.attribute.BinaryAttribute extends Attribute implements Serializable

Class org.apache.spark.ml.attribute.BinaryAttribute$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

defaultAttr

BinaryAttribute defaultAttr

Class org.apache.spark.ml.attribute.NominalAttribute extends Attribute implements Serializable

Class org.apache.spark.ml.attribute.NominalAttribute$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

defaultAttr

NominalAttribute defaultAttr

Class org.apache.spark.ml.attribute.NumericAttribute extends Attribute implements Serializable

Class org.apache.spark.ml.attribute.NumericAttribute$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

defaultAttr

NumericAttribute defaultAttr

Class org.apache.spark.ml.attribute.UnresolvedAttribute$ extends Attribute implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.ml.classification

Class org.apache.spark.ml.classification.BinaryLogisticRegressionSummary extends java.lang.Object implements Serializable

Class org.apache.spark.ml.classification.BinaryLogisticRegressionTrainingSummary extends BinaryLogisticRegressionSummary implements Serializable

Class org.apache.spark.ml.classification.ClassificationModel extends PredictionModel<FeaturesType,M extends ClassificationModel<FeaturesType,M>> implements Serializable

Class org.apache.spark.ml.classification.Classifier extends Predictor<FeaturesType,E extends Classifier<FeaturesType,E,M>,M extends ClassificationModel<FeaturesType,M>> implements Serializable

Class org.apache.spark.ml.classification.DecisionTreeClassificationModel extends ProbabilisticClassificationModel<Vector,DecisionTreeClassificationModel> implements Serializable

Class org.apache.spark.ml.classification.DecisionTreeClassificationModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.classification.DecisionTreeClassifier extends ProbabilisticClassifier<Vector,DecisionTreeClassifier,DecisionTreeClassificationModel> implements Serializable

Class org.apache.spark.ml.classification.DecisionTreeClassifier$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

supportedImpurities

java.lang.String[] supportedImpurities

Class org.apache.spark.ml.classification.GBTClassificationModel extends PredictionModel<Vector,GBTClassificationModel> implements Serializable

Class org.apache.spark.ml.classification.GBTClassificationModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.classification.GBTClassifier extends Predictor<Vector,GBTClassifier,GBTClassificationModel> implements Serializable

Class org.apache.spark.ml.classification.GBTClassifier$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

supportedLossTypes

java.lang.String[] supportedLossTypes

Class org.apache.spark.ml.classification.LogisticAggregator extends java.lang.Object implements Serializable

Class org.apache.spark.ml.classification.LogisticRegression extends ProbabilisticClassifier<Vector,LogisticRegression,LogisticRegressionModel> implements Serializable

Class org.apache.spark.ml.classification.LogisticRegression$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.classification.LogisticRegressionModel extends ProbabilisticClassificationModel<Vector,LogisticRegressionModel> implements Serializable

Class org.apache.spark.ml.classification.LogisticRegressionModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.classification.MultilayerPerceptronClassificationModel extends PredictionModel<Vector,MultilayerPerceptronClassificationModel> implements Serializable

Class org.apache.spark.ml.classification.MultilayerPerceptronClassificationModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.classification.MultilayerPerceptronClassifier extends Predictor<Vector,MultilayerPerceptronClassifier,MultilayerPerceptronClassificationModel> implements Serializable

Class org.apache.spark.ml.classification.MultilayerPerceptronClassifier$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.classification.NaiveBayes extends ProbabilisticClassifier<Vector,NaiveBayes,NaiveBayesModel> implements Serializable

Class org.apache.spark.ml.classification.NaiveBayes$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.classification.NaiveBayesModel extends ProbabilisticClassificationModel<Vector,NaiveBayesModel> implements Serializable

Class org.apache.spark.ml.classification.NaiveBayesModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.classification.OneVsRest extends Estimator<OneVsRestModel> implements Serializable

Class org.apache.spark.ml.classification.OneVsRest$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.classification.OneVsRestModel extends Model<OneVsRestModel> implements Serializable

Class org.apache.spark.ml.classification.OneVsRestModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.classification.OneVsRestParams$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.classification.ProbabilisticClassificationModel extends ClassificationModel<FeaturesType,M extends ProbabilisticClassificationModel<FeaturesType,M>> implements Serializable

Class org.apache.spark.ml.classification.ProbabilisticClassificationModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.classification.ProbabilisticClassifier extends Classifier<FeaturesType,E extends ProbabilisticClassifier<FeaturesType,E,M>,M extends ProbabilisticClassificationModel<FeaturesType,M>> implements Serializable

Class org.apache.spark.ml.classification.RandomForestClassificationModel extends ProbabilisticClassificationModel<Vector,RandomForestClassificationModel> implements Serializable

Class org.apache.spark.ml.classification.RandomForestClassificationModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.classification.RandomForestClassifier extends ProbabilisticClassifier<Vector,RandomForestClassifier,RandomForestClassificationModel> implements Serializable

Class org.apache.spark.ml.classification.RandomForestClassifier$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

supportedImpurities

java.lang.String[] supportedImpurities

supportedFeatureSubsetStrategies

java.lang.String[] supportedFeatureSubsetStrategies

Package org.apache.spark.ml.clustering

Class org.apache.spark.ml.clustering.BisectingKMeans extends Estimator<BisectingKMeansModel> implements Serializable

Class org.apache.spark.ml.clustering.BisectingKMeans$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.clustering.BisectingKMeansModel extends Model<BisectingKMeansModel> implements Serializable

Class org.apache.spark.ml.clustering.BisectingKMeansModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.clustering.DistributedLDAModel extends LDAModel implements Serializable

Class org.apache.spark.ml.clustering.DistributedLDAModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.clustering.GaussianMixture extends Estimator<GaussianMixtureModel> implements Serializable

Class org.apache.spark.ml.clustering.GaussianMixture$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.clustering.GaussianMixtureModel extends Model<GaussianMixtureModel> implements Serializable

Class org.apache.spark.ml.clustering.GaussianMixtureModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.clustering.GaussianMixtureSummary extends java.lang.Object implements Serializable

Class org.apache.spark.ml.clustering.KMeans extends Estimator<KMeansModel> implements Serializable

Class org.apache.spark.ml.clustering.KMeans$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.clustering.KMeansModel extends Model<KMeansModel> implements Serializable

Class org.apache.spark.ml.clustering.KMeansModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.clustering.KMeansSummary extends java.lang.Object implements Serializable

Class org.apache.spark.ml.clustering.LDA extends Estimator<LDAModel> implements Serializable

Class org.apache.spark.ml.clustering.LDA$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.clustering.LDAModel extends Model<LDAModel> implements Serializable

Class org.apache.spark.ml.clustering.LocalLDAModel extends LDAModel implements Serializable

Class org.apache.spark.ml.clustering.LocalLDAModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.ml.evaluation

Class org.apache.spark.ml.evaluation.BinaryClassificationEvaluator extends Evaluator implements Serializable

Class org.apache.spark.ml.evaluation.BinaryClassificationEvaluator$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.evaluation.Evaluator extends java.lang.Object implements Serializable

Class org.apache.spark.ml.evaluation.MulticlassClassificationEvaluator extends Evaluator implements Serializable

Class org.apache.spark.ml.evaluation.MulticlassClassificationEvaluator$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.evaluation.RegressionEvaluator extends Evaluator implements Serializable

Class org.apache.spark.ml.evaluation.RegressionEvaluator$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.ml.feature

Class org.apache.spark.ml.feature.Binarizer extends Transformer implements Serializable

Class org.apache.spark.ml.feature.Binarizer$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.Bucketizer extends Model<Bucketizer> implements Serializable

Class org.apache.spark.ml.feature.Bucketizer$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.ChiSqSelector extends Estimator<ChiSqSelectorModel> implements Serializable

Class org.apache.spark.ml.feature.ChiSqSelector$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.ChiSqSelectorModel extends Model<ChiSqSelectorModel> implements Serializable

Class org.apache.spark.ml.feature.ChiSqSelectorModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.ColumnInteraction$ extends scala.runtime.AbstractFunction1<scala.collection.Seq<org.apache.spark.ml.feature.InteractableTerm>,org.apache.spark.ml.feature.ColumnInteraction> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.ColumnPruner extends Transformer implements Serializable

Class org.apache.spark.ml.feature.ColumnPruner$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.ColumnRef$ extends scala.runtime.AbstractFunction1<java.lang.String,org.apache.spark.ml.feature.ColumnRef> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.CountVectorizer extends Estimator<CountVectorizerModel> implements Serializable

Class org.apache.spark.ml.feature.CountVectorizer$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.CountVectorizerModel extends Model<CountVectorizerModel> implements Serializable

Class org.apache.spark.ml.feature.CountVectorizerModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.DCT extends UnaryTransformer<Vector,Vector,DCT> implements Serializable

Class org.apache.spark.ml.feature.DCT$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.Deletion$ extends scala.runtime.AbstractFunction1<org.apache.spark.ml.feature.Term,org.apache.spark.ml.feature.Deletion> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.Dot$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.ElementwiseProduct extends UnaryTransformer<Vector,Vector,ElementwiseProduct> implements Serializable

Class org.apache.spark.ml.feature.ElementwiseProduct$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.HashingTF extends Transformer implements Serializable

Class org.apache.spark.ml.feature.HashingTF$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.IDF extends Estimator<IDFModel> implements Serializable

Class org.apache.spark.ml.feature.IDF$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.IDFModel extends Model<IDFModel> implements Serializable

Class org.apache.spark.ml.feature.IDFModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.IndexToString extends Transformer implements Serializable

Class org.apache.spark.ml.feature.IndexToString$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.Instance$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.Object,Vector,org.apache.spark.ml.feature.Instance> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.Interaction extends Transformer implements Serializable

Class org.apache.spark.ml.feature.Interaction$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.Intercept$ extends scala.runtime.AbstractFunction1<java.lang.Object,org.apache.spark.ml.feature.Intercept> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.LabeledPoint extends java.lang.Object implements Serializable

Class org.apache.spark.ml.feature.LabeledPoint$ extends scala.runtime.AbstractFunction2<java.lang.Object,Vector,LabeledPoint> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.MaxAbsScaler extends Estimator<MaxAbsScalerModel> implements Serializable

Class org.apache.spark.ml.feature.MaxAbsScaler$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.MaxAbsScalerModel extends Model<MaxAbsScalerModel> implements Serializable

Class org.apache.spark.ml.feature.MaxAbsScalerModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.MinMaxScaler extends Estimator<MinMaxScalerModel> implements Serializable

Class org.apache.spark.ml.feature.MinMaxScaler$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.MinMaxScalerModel extends Model<MinMaxScalerModel> implements Serializable

Class org.apache.spark.ml.feature.MinMaxScalerModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.NGram extends UnaryTransformer<scala.collection.Seq<java.lang.String>,scala.collection.Seq<java.lang.String>,NGram> implements Serializable

Class org.apache.spark.ml.feature.NGram$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.Normalizer extends UnaryTransformer<Vector,Vector,Normalizer> implements Serializable

Class org.apache.spark.ml.feature.Normalizer$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.OneHotEncoder extends Transformer implements Serializable

Class org.apache.spark.ml.feature.OneHotEncoder$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.ParsedRFormula$ extends scala.runtime.AbstractFunction2<org.apache.spark.ml.feature.ColumnRef,scala.collection.Seq<org.apache.spark.ml.feature.Term>,org.apache.spark.ml.feature.ParsedRFormula> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.PCA extends Estimator<PCAModel> implements Serializable

Class org.apache.spark.ml.feature.PCA$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.PCAModel extends Model<PCAModel> implements Serializable

Class org.apache.spark.ml.feature.PCAModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.PolynomialExpansion extends UnaryTransformer<Vector,Vector,PolynomialExpansion> implements Serializable

Class org.apache.spark.ml.feature.PolynomialExpansion$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.QuantileDiscretizer extends Estimator<Bucketizer> implements Serializable

Class org.apache.spark.ml.feature.QuantileDiscretizer$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.RegexTokenizer extends UnaryTransformer<java.lang.String,scala.collection.Seq<java.lang.String>,RegexTokenizer> implements Serializable

Class org.apache.spark.ml.feature.RegexTokenizer$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.ResolvedRFormula$ extends scala.runtime.AbstractFunction3<java.lang.String,scala.collection.Seq<scala.collection.Seq<java.lang.String>>,java.lang.Object,org.apache.spark.ml.feature.ResolvedRFormula> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.RFormula extends Estimator<RFormulaModel> implements Serializable

Class org.apache.spark.ml.feature.RFormula$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.RFormulaModel extends Model<RFormulaModel> implements Serializable

Class org.apache.spark.ml.feature.RFormulaModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.SQLTransformer extends Transformer implements Serializable

Class org.apache.spark.ml.feature.SQLTransformer$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.StandardScaler extends Estimator<StandardScalerModel> implements Serializable

Class org.apache.spark.ml.feature.StandardScaler$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.StandardScalerModel extends Model<StandardScalerModel> implements Serializable

Class org.apache.spark.ml.feature.StandardScalerModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.StopWordsRemover extends Transformer implements Serializable

Class org.apache.spark.ml.feature.StopWordsRemover$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

supportedLanguages

scala.collection.immutable.Set<A> supportedLanguages

Class org.apache.spark.ml.feature.StringIndexer extends Estimator<StringIndexerModel> implements Serializable

Class org.apache.spark.ml.feature.StringIndexer$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.StringIndexerModel extends Model<StringIndexerModel> implements Serializable

Class org.apache.spark.ml.feature.StringIndexerModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.Tokenizer extends UnaryTransformer<java.lang.String,scala.collection.Seq<java.lang.String>,Tokenizer> implements Serializable

Class org.apache.spark.ml.feature.Tokenizer$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.VectorAssembler extends Transformer implements Serializable

Class org.apache.spark.ml.feature.VectorAssembler$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.VectorAttributeRewriter extends Transformer implements Serializable

Class org.apache.spark.ml.feature.VectorAttributeRewriter$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.VectorIndexer extends Estimator<VectorIndexerModel> implements Serializable

Class org.apache.spark.ml.feature.VectorIndexer$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.VectorIndexerModel extends Model<VectorIndexerModel> implements Serializable

Class org.apache.spark.ml.feature.VectorIndexerModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.VectorSlicer extends Transformer implements Serializable

Class org.apache.spark.ml.feature.VectorSlicer$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.Word2Vec extends Estimator<Word2VecModel> implements Serializable

Class org.apache.spark.ml.feature.Word2Vec$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.feature.Word2VecModel extends Model<Word2VecModel> implements Serializable

Class org.apache.spark.ml.feature.Word2VecModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.ml.linalg

Class org.apache.spark.ml.linalg.BLAS$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.linalg.DenseMatrix extends java.lang.Object implements Serializable

Class org.apache.spark.ml.linalg.DenseMatrix$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.linalg.DenseVector extends java.lang.Object implements Serializable

Class org.apache.spark.ml.linalg.DenseVector$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.linalg.SparseMatrix extends java.lang.Object implements Serializable

Class org.apache.spark.ml.linalg.SparseMatrix$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.linalg.SparseVector extends java.lang.Object implements Serializable

Class org.apache.spark.ml.linalg.SparseVector$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.ml.param

Class org.apache.spark.ml.param.BooleanParam extends Param<java.lang.Object> implements Serializable

Class org.apache.spark.ml.param.DoubleArrayParam extends Param<double[]> implements Serializable

Class org.apache.spark.ml.param.DoubleParam extends Param<java.lang.Object> implements Serializable

Class org.apache.spark.ml.param.DoubleParam$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.param.FloatParam extends Param<java.lang.Object> implements Serializable

Class org.apache.spark.ml.param.FloatParam$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.param.IntArrayParam extends Param<int[]> implements Serializable

Class org.apache.spark.ml.param.IntParam extends Param<java.lang.Object> implements Serializable

Class org.apache.spark.ml.param.JavaParams extends java.lang.Object implements Serializable

Class org.apache.spark.ml.param.LongParam extends Param<java.lang.Object> implements Serializable

Class org.apache.spark.ml.param.Param extends java.lang.Object implements Serializable

Class org.apache.spark.ml.param.Param$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.param.ParamMap extends java.lang.Object implements Serializable

Class org.apache.spark.ml.param.ParamMap$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.param.ParamPair extends java.lang.Object implements Serializable

Class org.apache.spark.ml.param.ParamPair$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.param.StringArrayParam extends Param<java.lang.String[]> implements Serializable

Package org.apache.spark.ml.recommendation

Class org.apache.spark.ml.recommendation.ALS extends Estimator<ALSModel> implements Serializable

Class org.apache.spark.ml.recommendation.ALS.InBlock$ extends java.lang.Object implements Serializable

Class org.apache.spark.ml.recommendation.ALS.Rating extends java.lang.Object implements Serializable

Class org.apache.spark.ml.recommendation.ALS.Rating$ extends java.lang.Object implements Serializable

Class org.apache.spark.ml.recommendation.ALS.RatingBlock$ extends java.lang.Object implements Serializable

Class org.apache.spark.ml.recommendation.ALS$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.recommendation.ALS$InBlock$mcI$sp extends org.apache.spark.ml.recommendation.ALS.InBlock<java.lang.Object> implements Serializable

Serialized Fields

srcIds$mcI$sp

int[] srcIds$mcI$sp

evidence$2

scala.reflect.ClassTag<T> evidence$2

Class org.apache.spark.ml.recommendation.ALS$InBlock$mcJ$sp extends org.apache.spark.ml.recommendation.ALS.InBlock<java.lang.Object> implements Serializable

Serialized Fields

srcIds$mcJ$sp

long[] srcIds$mcJ$sp

evidence$2

scala.reflect.ClassTag<T> evidence$2

Class org.apache.spark.ml.recommendation.ALS$Rating$mcI$sp extends ALS.Rating<java.lang.Object> implements Serializable

Serialized Fields

user$mcI$sp

int user$mcI$sp

item$mcI$sp

int item$mcI$sp

Class org.apache.spark.ml.recommendation.ALS$Rating$mcJ$sp extends ALS.Rating<java.lang.Object> implements Serializable

Serialized Fields

user$mcJ$sp

long user$mcJ$sp

item$mcJ$sp

long item$mcJ$sp

Class org.apache.spark.ml.recommendation.ALS$RatingBlock$mcI$sp extends org.apache.spark.ml.recommendation.ALS.RatingBlock<java.lang.Object> implements Serializable

Serialized Fields

srcIds$mcI$sp

int[] srcIds$mcI$sp

dstIds$mcI$sp

int[] dstIds$mcI$sp

evidence$3

scala.reflect.ClassTag<T> evidence$3

Class org.apache.spark.ml.recommendation.ALS$RatingBlock$mcJ$sp extends org.apache.spark.ml.recommendation.ALS.RatingBlock<java.lang.Object> implements Serializable

Serialized Fields

srcIds$mcJ$sp

long[] srcIds$mcJ$sp

dstIds$mcJ$sp

long[] dstIds$mcJ$sp

evidence$3

scala.reflect.ClassTag<T> evidence$3

Class org.apache.spark.ml.recommendation.ALS$RatingBlockBuilder$mcI$sp extends org.apache.spark.ml.recommendation.ALS.RatingBlockBuilder<java.lang.Object> implements Serializable

Serialized Fields

evidence$4

scala.reflect.ClassTag<T> evidence$4

Class org.apache.spark.ml.recommendation.ALS$RatingBlockBuilder$mcJ$sp extends org.apache.spark.ml.recommendation.ALS.RatingBlockBuilder<java.lang.Object> implements Serializable

Serialized Fields

evidence$4

scala.reflect.ClassTag<T> evidence$4

Class org.apache.spark.ml.recommendation.ALSModel extends Model<ALSModel> implements Serializable

Class org.apache.spark.ml.recommendation.ALSModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.ml.regression

Class org.apache.spark.ml.regression.AFTAggregator extends java.lang.Object implements Serializable

Class org.apache.spark.ml.regression.AFTPoint$ extends scala.runtime.AbstractFunction3<Vector,java.lang.Object,java.lang.Object,org.apache.spark.ml.regression.AFTPoint> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.regression.AFTSurvivalRegression extends Estimator<AFTSurvivalRegressionModel> implements Serializable

Class org.apache.spark.ml.regression.AFTSurvivalRegression$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.regression.AFTSurvivalRegressionModel extends Model<AFTSurvivalRegressionModel> implements Serializable

Class org.apache.spark.ml.regression.AFTSurvivalRegressionModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.regression.DecisionTreeRegressionModel extends PredictionModel<Vector,DecisionTreeRegressionModel> implements Serializable

Class org.apache.spark.ml.regression.DecisionTreeRegressionModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.regression.DecisionTreeRegressor extends Predictor<Vector,DecisionTreeRegressor,DecisionTreeRegressionModel> implements Serializable

Class org.apache.spark.ml.regression.DecisionTreeRegressor$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

supportedImpurities

java.lang.String[] supportedImpurities

Class org.apache.spark.ml.regression.GBTRegressionModel extends PredictionModel<Vector,GBTRegressionModel> implements Serializable

Class org.apache.spark.ml.regression.GBTRegressionModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.regression.GBTRegressor extends Predictor<Vector,GBTRegressor,GBTRegressionModel> implements Serializable

Class org.apache.spark.ml.regression.GBTRegressor$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

supportedLossTypes

java.lang.String[] supportedLossTypes

Class org.apache.spark.ml.regression.GeneralizedLinearRegression extends org.apache.spark.ml.regression.Regressor<Vector,GeneralizedLinearRegression,GeneralizedLinearRegressionModel> implements Serializable

Class org.apache.spark.ml.regression.GeneralizedLinearRegression.Binomial$ extends org.apache.spark.ml.regression.GeneralizedLinearRegression.Family implements Serializable

Class org.apache.spark.ml.regression.GeneralizedLinearRegression.CLogLog$ extends org.apache.spark.ml.regression.GeneralizedLinearRegression.Link implements Serializable

Class org.apache.spark.ml.regression.GeneralizedLinearRegression.Family$ extends java.lang.Object implements Serializable

Class org.apache.spark.ml.regression.GeneralizedLinearRegression.Gamma$ extends org.apache.spark.ml.regression.GeneralizedLinearRegression.Family implements Serializable

Class org.apache.spark.ml.regression.GeneralizedLinearRegression.Gaussian$ extends org.apache.spark.ml.regression.GeneralizedLinearRegression.Family implements Serializable

Class org.apache.spark.ml.regression.GeneralizedLinearRegression.Identity$ extends org.apache.spark.ml.regression.GeneralizedLinearRegression.Link implements Serializable

Class org.apache.spark.ml.regression.GeneralizedLinearRegression.Inverse$ extends org.apache.spark.ml.regression.GeneralizedLinearRegression.Link implements Serializable

Class org.apache.spark.ml.regression.GeneralizedLinearRegression.Link$ extends java.lang.Object implements Serializable

Class org.apache.spark.ml.regression.GeneralizedLinearRegression.Log$ extends org.apache.spark.ml.regression.GeneralizedLinearRegression.Link implements Serializable

Class org.apache.spark.ml.regression.GeneralizedLinearRegression.Logit$ extends org.apache.spark.ml.regression.GeneralizedLinearRegression.Link implements Serializable

Class org.apache.spark.ml.regression.GeneralizedLinearRegression.Poisson$ extends org.apache.spark.ml.regression.GeneralizedLinearRegression.Family implements Serializable

Class org.apache.spark.ml.regression.GeneralizedLinearRegression.Probit$ extends org.apache.spark.ml.regression.GeneralizedLinearRegression.Link implements Serializable

Class org.apache.spark.ml.regression.GeneralizedLinearRegression.Sqrt$ extends org.apache.spark.ml.regression.GeneralizedLinearRegression.Link implements Serializable

Class org.apache.spark.ml.regression.GeneralizedLinearRegression$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

supportedFamilyAndLinkPairs

scala.collection.immutable.Set<A> supportedFamilyAndLinkPairs

supportedFamilyNames

scala.collection.immutable.Set<A> supportedFamilyNames

supportedLinkNames

scala.collection.immutable.Set<A> supportedLinkNames

epsilon

double epsilon

bitmap$0

byte bitmap$0

Class org.apache.spark.ml.regression.GeneralizedLinearRegressionModel extends RegressionModel<Vector,GeneralizedLinearRegressionModel> implements Serializable

Class org.apache.spark.ml.regression.GeneralizedLinearRegressionModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.regression.GeneralizedLinearRegressionSummary extends java.lang.Object implements Serializable

Class org.apache.spark.ml.regression.GeneralizedLinearRegressionTrainingSummary extends GeneralizedLinearRegressionSummary implements Serializable

Class org.apache.spark.ml.regression.IsotonicRegression extends Estimator<IsotonicRegressionModel> implements Serializable

Class org.apache.spark.ml.regression.IsotonicRegression$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.regression.IsotonicRegressionModel extends Model<IsotonicRegressionModel> implements Serializable

Class org.apache.spark.ml.regression.IsotonicRegressionModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.regression.LeastSquaresAggregator extends java.lang.Object implements Serializable

Class org.apache.spark.ml.regression.LinearRegression extends org.apache.spark.ml.regression.Regressor<Vector,LinearRegression,LinearRegressionModel> implements Serializable

Class org.apache.spark.ml.regression.LinearRegression$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.regression.LinearRegressionModel extends RegressionModel<Vector,LinearRegressionModel> implements Serializable

Class org.apache.spark.ml.regression.LinearRegressionModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.regression.LinearRegressionSummary extends java.lang.Object implements Serializable

Class org.apache.spark.ml.regression.LinearRegressionTrainingSummary extends LinearRegressionSummary implements Serializable

Class org.apache.spark.ml.regression.RandomForestRegressionModel extends PredictionModel<Vector,RandomForestRegressionModel> implements Serializable

Class org.apache.spark.ml.regression.RandomForestRegressionModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.regression.RandomForestRegressor extends Predictor<Vector,RandomForestRegressor,RandomForestRegressionModel> implements Serializable

Class org.apache.spark.ml.regression.RandomForestRegressor$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

supportedImpurities

java.lang.String[] supportedImpurities

supportedFeatureSubsetStrategies

java.lang.String[] supportedFeatureSubsetStrategies

Class org.apache.spark.ml.regression.RegressionModel extends PredictionModel<FeaturesType,M extends RegressionModel<FeaturesType,M>> implements Serializable

Package org.apache.spark.ml.stat.distribution

Class org.apache.spark.ml.stat.distribution.MultivariateGaussian extends java.lang.Object implements Serializable

Package org.apache.spark.ml.tree

Class org.apache.spark.ml.tree.CategoricalSplit extends java.lang.Object implements Serializable

Class org.apache.spark.ml.tree.ContinuousSplit extends java.lang.Object implements Serializable

Class org.apache.spark.ml.tree.DecisionTreeModelReadWrite.NodeData extends java.lang.Object implements Serializable

Class org.apache.spark.ml.tree.DecisionTreeModelReadWrite.NodeData$ extends java.lang.Object implements Serializable

Class org.apache.spark.ml.tree.DecisionTreeModelReadWrite.SplitData extends java.lang.Object implements Serializable

Class org.apache.spark.ml.tree.DecisionTreeModelReadWrite.SplitData$ extends java.lang.Object implements Serializable

Class org.apache.spark.ml.tree.EnsembleModelReadWrite.EnsembleNodeData extends java.lang.Object implements Serializable

Class org.apache.spark.ml.tree.EnsembleModelReadWrite.EnsembleNodeData$ extends java.lang.Object implements Serializable

Class org.apache.spark.ml.tree.GBTClassifierParams$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

supportedLossTypes

java.lang.String[] supportedLossTypes

Class org.apache.spark.ml.tree.GBTRegressorParams$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

supportedLossTypes

java.lang.String[] supportedLossTypes

Class org.apache.spark.ml.tree.InternalNode extends Node implements Serializable

Class org.apache.spark.ml.tree.InternalNode$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.tree.LeafNode extends Node implements Serializable

Class org.apache.spark.ml.tree.LearningNode$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.tree.Node extends java.lang.Object implements Serializable

Class org.apache.spark.ml.tree.Node$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.tree.RandomForestParams$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

supportedFeatureSubsetStrategies

java.lang.String[] supportedFeatureSubsetStrategies

Class org.apache.spark.ml.tree.Split$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.tree.TreeClassifierParams$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

supportedImpurities

java.lang.String[] supportedImpurities

Class org.apache.spark.ml.tree.TreeRegressorParams$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

supportedImpurities

java.lang.String[] supportedImpurities

Package org.apache.spark.ml.tree.impl

Class org.apache.spark.ml.tree.impl.BaggedPoint$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.tree.impl.DecisionTreeMetadata$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.tree.impl.NodeIndexUpdater$ extends scala.runtime.AbstractFunction2<Split,java.lang.Object,org.apache.spark.ml.tree.impl.NodeIndexUpdater> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.tree.impl.TreePoint$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.ml.tuning

Class org.apache.spark.ml.tuning.CrossValidator extends Estimator<CrossValidatorModel> implements Serializable

Class org.apache.spark.ml.tuning.CrossValidator$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.tuning.CrossValidatorModel extends Model<CrossValidatorModel> implements Serializable

Class org.apache.spark.ml.tuning.CrossValidatorModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.tuning.TrainValidationSplit extends Estimator<TrainValidationSplitModel> implements Serializable

Class org.apache.spark.ml.tuning.TrainValidationSplit$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.tuning.TrainValidationSplitModel extends Model<TrainValidationSplitModel> implements Serializable

Class org.apache.spark.ml.tuning.TrainValidationSplitModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ml.tuning.ValidatorParams$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.ml.util

Class org.apache.spark.ml.util.DefaultParamsReader.Metadata extends java.lang.Object implements Serializable

Class org.apache.spark.ml.util.DefaultParamsReader.Metadata$ extends scala.runtime.AbstractFunction7<java.lang.String,java.lang.String,java.lang.Object,java.lang.String,org.json4s.JsonAST.JValue,org.json4s.JsonAST.JValue,java.lang.String,org.apache.spark.ml.util.DefaultParamsReader.Metadata> implements Serializable

Package org.apache.spark.mllib.classification

Class org.apache.spark.mllib.classification.ClassificationModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.classification.LogisticRegressionModel extends GeneralizedLinearModel implements Serializable

Class org.apache.spark.mllib.classification.LogisticRegressionModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.classification.LogisticRegressionWithSGD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.classification.NaiveBayes extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.classification.NaiveBayes$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

Multinomial

java.lang.String Multinomial

Bernoulli

java.lang.String Bernoulli

supportedModelTypes

scala.collection.immutable.Set<A> supportedModelTypes

Class org.apache.spark.mllib.classification.NaiveBayesModel extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.classification.NaiveBayesModel.SaveLoadV1_0$.Data extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.classification.NaiveBayesModel.SaveLoadV2_0$.Data extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.classification.NaiveBayesModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.classification.NaiveBayesModel$SaveLoadV1_0$Data extends java.lang.Object implements Serializable

Serialized Fields

labels

double[] labels

pi

double[] pi

theta

double[][] theta

Class org.apache.spark.mllib.classification.NaiveBayesModel$SaveLoadV1_0$Data$ extends scala.runtime.AbstractFunction3<double[],double[],double[][],org.apache.spark.mllib.classification.NaiveBayesModel$SaveLoadV1_0$Data> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.classification.NaiveBayesModel$SaveLoadV2_0$Data extends java.lang.Object implements Serializable

Serialized Fields

labels

double[] labels

pi

double[] pi

theta

double[][] theta

modelType

java.lang.String modelType

Class org.apache.spark.mllib.classification.NaiveBayesModel$SaveLoadV2_0$Data$ extends scala.runtime.AbstractFunction4<double[],double[],double[][],java.lang.String,org.apache.spark.mllib.classification.NaiveBayesModel$SaveLoadV2_0$Data> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.classification.SVMModel extends GeneralizedLinearModel implements Serializable

Class org.apache.spark.mllib.classification.SVMModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.classification.SVMWithSGD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.mllib.classification.impl

Class org.apache.spark.mllib.classification.impl.GLMClassificationModel.SaveLoadV1_0$.Data extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.classification.impl.GLMClassificationModel$SaveLoadV1_0$Data extends java.lang.Object implements Serializable

Serialized Fields

weights

Vector weights

intercept

double intercept

threshold

scala.Option<A> threshold

Class org.apache.spark.mllib.classification.impl.GLMClassificationModel$SaveLoadV1_0$Data$ extends scala.runtime.AbstractFunction3<Vector,java.lang.Object,scala.Option<java.lang.Object>,org.apache.spark.mllib.classification.impl.GLMClassificationModel$SaveLoadV1_0$Data> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.mllib.clustering

Class org.apache.spark.mllib.clustering.BisectingKMeans$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

org$apache$spark$mllib$clustering$BisectingKMeans$$ROOT_INDEX

long org$apache$spark$mllib$clustering$BisectingKMeans$$ROOT_INDEX

MAX_DIVISIBLE_CLUSTER_INDEX

long MAX_DIVISIBLE_CLUSTER_INDEX

org$apache$spark$mllib$clustering$BisectingKMeans$$LEVEL_LIMIT

double org$apache$spark$mllib$clustering$BisectingKMeans$$LEVEL_LIMIT

Class org.apache.spark.mllib.clustering.BisectingKMeansModel extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.clustering.BisectingKMeansModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.clustering.DistributedLDAModel.SaveLoadV1_0$.Data extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.clustering.DistributedLDAModel.SaveLoadV1_0$.EdgeData extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.clustering.DistributedLDAModel.SaveLoadV1_0$.VertexData extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.clustering.DistributedLDAModel$SaveLoadV1_0$Data extends java.lang.Object implements Serializable

Serialized Fields

globalTopicTotals

Vector globalTopicTotals

Class org.apache.spark.mllib.clustering.DistributedLDAModel$SaveLoadV1_0$Data$ extends scala.runtime.AbstractFunction1<Vector,org.apache.spark.mllib.clustering.DistributedLDAModel$SaveLoadV1_0$Data> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.clustering.DistributedLDAModel$SaveLoadV1_0$EdgeData extends java.lang.Object implements Serializable

Serialized Fields

srcId

long srcId

dstId

long dstId

tokenCounts

double tokenCounts

Class org.apache.spark.mllib.clustering.DistributedLDAModel$SaveLoadV1_0$EdgeData$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.Object,java.lang.Object,org.apache.spark.mllib.clustering.DistributedLDAModel$SaveLoadV1_0$EdgeData> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.clustering.DistributedLDAModel$SaveLoadV1_0$VertexData extends java.lang.Object implements Serializable

Serialized Fields

id

long id

topicWeights

Vector topicWeights

Class org.apache.spark.mllib.clustering.DistributedLDAModel$SaveLoadV1_0$VertexData$ extends scala.runtime.AbstractFunction2<java.lang.Object,Vector,org.apache.spark.mllib.clustering.DistributedLDAModel$SaveLoadV1_0$VertexData> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.clustering.ExpectationSum extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.clustering.ExpectationSum$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.clustering.GaussianMixture extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.clustering.GaussianMixture$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.clustering.GaussianMixtureModel extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.clustering.GaussianMixtureModel.SaveLoadV1_0$.Data extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.clustering.GaussianMixtureModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.clustering.GaussianMixtureModel$SaveLoadV1_0$Data extends java.lang.Object implements Serializable

Serialized Fields

weight

double weight

mu

Vector mu

sigma

Matrix sigma

Class org.apache.spark.mllib.clustering.GaussianMixtureModel$SaveLoadV1_0$Data$ extends scala.runtime.AbstractFunction3<java.lang.Object,Vector,Matrix,org.apache.spark.mllib.clustering.GaussianMixtureModel$SaveLoadV1_0$Data> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.clustering.KMeans extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.clustering.KMeans$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

RANDOM

java.lang.String RANDOM

K_MEANS_PARALLEL

java.lang.String K_MEANS_PARALLEL

Class org.apache.spark.mllib.clustering.KMeansModel extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.clustering.KMeansModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.clustering.LocalLDAModel extends LDAModel implements Serializable

Class org.apache.spark.mllib.clustering.LocalLDAModel.SaveLoadV1_0$.Data extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.clustering.LocalLDAModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.clustering.LocalLDAModel$SaveLoadV1_0$Data extends java.lang.Object implements Serializable

Serialized Fields

topic

Vector topic

index

int index

Class org.apache.spark.mllib.clustering.LocalLDAModel$SaveLoadV1_0$Data$ extends scala.runtime.AbstractFunction2<Vector,java.lang.Object,org.apache.spark.mllib.clustering.LocalLDAModel$SaveLoadV1_0$Data> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.clustering.PowerIterationClustering extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.clustering.PowerIterationClustering.Assignment extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.clustering.PowerIterationClustering.Assignment$ extends scala.runtime.AbstractFunction2<java.lang.Object,java.lang.Object,PowerIterationClustering.Assignment> implements Serializable

Class org.apache.spark.mllib.clustering.PowerIterationClustering$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.clustering.PowerIterationClusteringModel extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.clustering.PowerIterationClusteringModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.clustering.StreamingKMeans extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.clustering.StreamingKMeans$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

BATCHES

java.lang.String BATCHES

POINTS

java.lang.String POINTS

Class org.apache.spark.mllib.clustering.StreamingKMeansModel extends KMeansModel implements Serializable

Package org.apache.spark.mllib.evaluation

Class org.apache.spark.mllib.evaluation.RankingMetrics extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.evaluation.RankingMetrics$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.mllib.evaluation.binary

Class org.apache.spark.mllib.evaluation.binary.BinaryConfusionMatrixImpl$ extends scala.runtime.AbstractFunction2<org.apache.spark.mllib.evaluation.binary.BinaryLabelCounter,org.apache.spark.mllib.evaluation.binary.BinaryLabelCounter,org.apache.spark.mllib.evaluation.binary.BinaryConfusionMatrixImpl> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.evaluation.binary.BinaryLabelCounter$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.evaluation.binary.FalsePositiveRate$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.evaluation.binary.FMeasure$ extends scala.runtime.AbstractFunction1<java.lang.Object,org.apache.spark.mllib.evaluation.binary.FMeasure> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.evaluation.binary.Precision$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.evaluation.binary.Recall$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.mllib.feature

Class org.apache.spark.mllib.feature.ChiSqSelector extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.feature.ChiSqSelectorModel extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.feature.ChiSqSelectorModel.SaveLoadV1_0$.Data extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.feature.ChiSqSelectorModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.feature.ChiSqSelectorModel$SaveLoadV1_0$Data extends java.lang.Object implements Serializable

Serialized Fields

feature

int feature

Class org.apache.spark.mllib.feature.ChiSqSelectorModel$SaveLoadV1_0$Data$ extends scala.runtime.AbstractFunction1<java.lang.Object,org.apache.spark.mllib.feature.ChiSqSelectorModel$SaveLoadV1_0$Data> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.feature.ElementwiseProduct extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.feature.HashingTF extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.feature.HashingTF$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

Native

java.lang.String Native

Murmur3

java.lang.String Murmur3

seed

int seed

Class org.apache.spark.mllib.feature.IDF.DocumentFrequencyAggregator extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.feature.IDFModel extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.feature.IDFModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.feature.Normalizer extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.feature.PCAModel extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.feature.StandardScalerModel extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.feature.VocabWord extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.feature.VocabWord$ extends scala.runtime.AbstractFunction5<java.lang.String,java.lang.Object,int[],int[],java.lang.Object,VocabWord> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.feature.Word2Vec extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.feature.Word2VecModel extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.feature.Word2VecModel.SaveLoadV1_0$.Data extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.feature.Word2VecModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.feature.Word2VecModel$SaveLoadV1_0$Data extends java.lang.Object implements Serializable

Serialized Fields

word

java.lang.String word

vector

float[] vector

Class org.apache.spark.mllib.feature.Word2VecModel$SaveLoadV1_0$Data$ extends scala.runtime.AbstractFunction2<java.lang.String,float[],org.apache.spark.mllib.feature.Word2VecModel$SaveLoadV1_0$Data> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.mllib.fpm

Class org.apache.spark.mllib.fpm.AssociationRules extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.fpm.AssociationRules.Rule extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.fpm.AssociationRules$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.fpm.FPGrowth extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.fpm.FPGrowth.FreqItemset extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.fpm.FPGrowth$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.fpm.FPGrowthModel extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.fpm.FPGrowthModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.fpm.FPTree.Node extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.fpm.FPTree$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.fpm.LocalPrefixSpan.ReversedPrefix extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.fpm.LocalPrefixSpan.ReversedPrefix$ extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.fpm.LocalPrefixSpan$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.fpm.PrefixSpan extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.fpm.PrefixSpan.FreqSequence extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.fpm.PrefixSpan.Postfix$ extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.fpm.PrefixSpan.Prefix$ extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.fpm.PrefixSpan$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.fpm.PrefixSpanModel extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.fpm.PrefixSpanModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.mllib.linalg

Class org.apache.spark.mllib.linalg.BLAS$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.linalg.DenseMatrix extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.linalg.DenseMatrix$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.linalg.DenseVector extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.linalg.DenseVector$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.linalg.QRDecomposition extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.linalg.QRDecomposition$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.linalg.SingularValueDecomposition extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.linalg.SingularValueDecomposition$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.linalg.SparseMatrix extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.linalg.SparseMatrix$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.linalg.SparseVector extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.linalg.SparseVector$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.mllib.linalg.distributed

Class org.apache.spark.mllib.linalg.distributed.BlockMatrix extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.linalg.distributed.CoordinateMatrix extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.linalg.distributed.GridPartitioner$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.linalg.distributed.IndexedRow extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.linalg.distributed.IndexedRow$ extends scala.runtime.AbstractFunction2<java.lang.Object,Vector,IndexedRow> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.linalg.distributed.IndexedRowMatrix extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.linalg.distributed.MatrixEntry extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.linalg.distributed.MatrixEntry$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.Object,java.lang.Object,MatrixEntry> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.linalg.distributed.RowMatrix extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.linalg.distributed.RowMatrix$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.mllib.optimization

Class org.apache.spark.mllib.optimization.Gradient extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.optimization.GradientDescent extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.optimization.GradientDescent$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.optimization.HingeGradient extends Gradient implements Serializable

Class org.apache.spark.mllib.optimization.L1Updater extends Updater implements Serializable

Class org.apache.spark.mllib.optimization.LBFGS extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.optimization.LBFGS$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.optimization.LeastSquaresGradient extends Gradient implements Serializable

Class org.apache.spark.mllib.optimization.LogisticGradient extends Gradient implements Serializable

Class org.apache.spark.mllib.optimization.SimpleUpdater extends Updater implements Serializable

Class org.apache.spark.mllib.optimization.SquaredL2Updater extends Updater implements Serializable

Class org.apache.spark.mllib.optimization.Updater extends java.lang.Object implements Serializable

Package org.apache.spark.mllib.random

Class org.apache.spark.mllib.random.ExponentialGenerator extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.random.GammaGenerator extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.random.LogNormalGenerator extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.random.PoissonGenerator extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.random.StandardNormalGenerator extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.random.UniformGenerator extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.random.WeibullGenerator extends java.lang.Object implements Serializable

Package org.apache.spark.mllib.rdd

Class org.apache.spark.mllib.rdd.MLPairRDDFunctions extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.rdd.MLPairRDDFunctions$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.rdd.RandomRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.rdd.RandomVectorRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.rdd.RDDFunctions extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.rdd.RDDFunctions$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.mllib.recommendation

Class org.apache.spark.mllib.recommendation.ALS extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.recommendation.ALS$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.recommendation.MatrixFactorizationModel extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.recommendation.MatrixFactorizationModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.recommendation.Rating extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.recommendation.Rating$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.Object,java.lang.Object,Rating> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.mllib.regression

Class org.apache.spark.mllib.regression.GeneralizedLinearAlgorithm extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.regression.GeneralizedLinearModel extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.regression.IsotonicRegression extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.regression.IsotonicRegressionModel extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.regression.IsotonicRegressionModel.SaveLoadV1_0$.Data extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.regression.IsotonicRegressionModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.regression.IsotonicRegressionModel$SaveLoadV1_0$Data extends java.lang.Object implements Serializable

Serialized Fields

boundary

double boundary

prediction

double prediction

Class org.apache.spark.mllib.regression.IsotonicRegressionModel$SaveLoadV1_0$Data$ extends scala.runtime.AbstractFunction2<java.lang.Object,java.lang.Object,org.apache.spark.mllib.regression.IsotonicRegressionModel$SaveLoadV1_0$Data> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.regression.LabeledPoint extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.regression.LabeledPoint$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.regression.LassoModel extends GeneralizedLinearModel implements Serializable

Class org.apache.spark.mllib.regression.LassoModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.regression.LassoWithSGD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.regression.LinearRegressionModel extends GeneralizedLinearModel implements Serializable

Class org.apache.spark.mllib.regression.LinearRegressionModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.regression.LinearRegressionWithSGD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.regression.RegressionModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.regression.RidgeRegressionModel extends GeneralizedLinearModel implements Serializable

Class org.apache.spark.mllib.regression.RidgeRegressionModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.regression.RidgeRegressionWithSGD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.mllib.regression.impl

Class org.apache.spark.mllib.regression.impl.GLMRegressionModel.SaveLoadV1_0$.Data extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.regression.impl.GLMRegressionModel$SaveLoadV1_0$Data extends java.lang.Object implements Serializable

Serialized Fields

weights

Vector weights

intercept

double intercept

Class org.apache.spark.mllib.regression.impl.GLMRegressionModel$SaveLoadV1_0$Data$ extends scala.runtime.AbstractFunction2<Vector,java.lang.Object,org.apache.spark.mllib.regression.impl.GLMRegressionModel$SaveLoadV1_0$Data> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.mllib.stat

Class org.apache.spark.mllib.stat.KernelDensity extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.stat.KernelDensity$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.stat.MultivariateOnlineSummarizer extends java.lang.Object implements Serializable

Package org.apache.spark.mllib.stat.distribution

Class org.apache.spark.mllib.stat.distribution.MultivariateGaussian extends java.lang.Object implements Serializable

Package org.apache.spark.mllib.stat.test

Class org.apache.spark.mllib.stat.test.BinarySample extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.stat.test.BinarySample$ extends scala.runtime.AbstractFunction2<java.lang.Object,java.lang.Object,BinarySample> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.stat.test.ChiSqTest.Method extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.stat.test.ChiSqTest.Method$ extends scala.runtime.AbstractFunction2<java.lang.String,scala.Function2<java.lang.Object,java.lang.Object,java.lang.Object>,ChiSqTest.Method> implements Serializable

Class org.apache.spark.mllib.stat.test.ChiSqTest.NullHypothesis$ extends scala.Enumeration implements Serializable

Class org.apache.spark.mllib.stat.test.KolmogorovSmirnovTest.NullHypothesis$ extends scala.Enumeration implements Serializable

Class org.apache.spark.mllib.stat.test.StreamingTest extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.stat.test.StreamingTestMethod$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

TEST_NAME_TO_OBJECT

scala.collection.immutable.Map<A,B> TEST_NAME_TO_OBJECT

Class org.apache.spark.mllib.stat.test.StudentTTest$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

methodName

java.lang.String methodName

nullHypothesis

java.lang.String nullHypothesis

tTester

com.twitter.chill.MeatLocker<T> tTester

Class org.apache.spark.mllib.stat.test.WelchTTest$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

methodName

java.lang.String methodName

nullHypothesis

java.lang.String nullHypothesis

tTester

com.twitter.chill.MeatLocker<T> tTester

Package org.apache.spark.mllib.tree

Class org.apache.spark.mllib.tree.DecisionTree extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.tree.DecisionTree$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.GradientBoostedTrees extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.tree.GradientBoostedTrees$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.RandomForest extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.tree.RandomForest$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

supportedFeatureSubsetStrategies

java.lang.String[] supportedFeatureSubsetStrategies

Package org.apache.spark.mllib.tree.configuration

Class org.apache.spark.mllib.tree.configuration.Algo$ extends scala.Enumeration implements Serializable

Serialized Fields

Classification

scala.Enumeration.Value Classification

Regression

scala.Enumeration.Value Regression

Class org.apache.spark.mllib.tree.configuration.BoostingStrategy extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.tree.configuration.BoostingStrategy$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.configuration.EnsembleCombiningStrategy$ extends scala.Enumeration implements Serializable

Serialized Fields

Average

scala.Enumeration.Value Average

Sum

scala.Enumeration.Value Sum

Vote

scala.Enumeration.Value Vote

Class org.apache.spark.mllib.tree.configuration.FeatureType$ extends scala.Enumeration implements Serializable

Serialized Fields

Continuous

scala.Enumeration.Value Continuous

Categorical

scala.Enumeration.Value Categorical

Class org.apache.spark.mllib.tree.configuration.QuantileStrategy$ extends scala.Enumeration implements Serializable

Serialized Fields

Sort

scala.Enumeration.Value Sort

MinMax

scala.Enumeration.Value MinMax

ApproxHist

scala.Enumeration.Value ApproxHist

Class org.apache.spark.mllib.tree.configuration.Strategy extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.tree.configuration.Strategy$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.mllib.tree.impurity

Class org.apache.spark.mllib.tree.impurity.Entropy$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.impurity.Gini$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.impurity.ImpurityCalculator$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.impurity.Variance$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.mllib.tree.loss

Class org.apache.spark.mllib.tree.loss.AbsoluteError$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.loss.LogLoss$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.loss.SquaredError$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.mllib.tree.model

Class org.apache.spark.mllib.tree.model.DecisionTreeModel extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.tree.model.DecisionTreeModel.SaveLoadV1_0$.NodeData extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.tree.model.DecisionTreeModel.SaveLoadV1_0$.PredictData extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.tree.model.DecisionTreeModel.SaveLoadV1_0$.SplitData extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.tree.model.DecisionTreeModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.model.DecisionTreeModel$SaveLoadV1_0$NodeData extends java.lang.Object implements Serializable

Serialized Fields

treeId

int treeId

nodeId

int nodeId

predict

org.apache.spark.mllib.tree.model.DecisionTreeModel$SaveLoadV1_0$PredictData predict

impurity

double impurity

isLeaf

boolean isLeaf

split

scala.Option<A> split

leftNodeId

scala.Option<A> leftNodeId

rightNodeId

scala.Option<A> rightNodeId

infoGain

scala.Option<A> infoGain

Class org.apache.spark.mllib.tree.model.DecisionTreeModel$SaveLoadV1_0$NodeData$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.model.DecisionTreeModel$SaveLoadV1_0$PredictData extends java.lang.Object implements Serializable

Serialized Fields

predict

double predict

prob

double prob

Class org.apache.spark.mllib.tree.model.DecisionTreeModel$SaveLoadV1_0$PredictData$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.model.DecisionTreeModel$SaveLoadV1_0$SplitData extends java.lang.Object implements Serializable

Serialized Fields

feature

int feature

threshold

double threshold

featureType

int featureType

categories

scala.collection.Seq<A> categories

Class org.apache.spark.mllib.tree.model.DecisionTreeModel$SaveLoadV1_0$SplitData$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.model.GradientBoostedTreesModel extends org.apache.spark.mllib.tree.model.TreeEnsembleModel implements Serializable

Class org.apache.spark.mllib.tree.model.GradientBoostedTreesModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.model.ImpurityStats$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.model.InformationGainStats extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.tree.model.Node extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.tree.model.Node$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.model.Predict extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.tree.model.Predict$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.model.RandomForestModel extends org.apache.spark.mllib.tree.model.TreeEnsembleModel implements Serializable

Class org.apache.spark.mllib.tree.model.RandomForestModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.model.Split extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.tree.model.Split$ extends scala.runtime.AbstractFunction4<java.lang.Object,java.lang.Object,scala.Enumeration.Value,scala.collection.immutable.List<java.lang.Object>,Split> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.model.TreeEnsembleModel.SaveLoadV1_0$.EnsembleNodeData extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.tree.model.TreeEnsembleModel.SaveLoadV1_0$.Metadata extends java.lang.Object implements Serializable

Class org.apache.spark.mllib.tree.model.TreeEnsembleModel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.model.TreeEnsembleModel$SaveLoadV1_0$EnsembleNodeData extends java.lang.Object implements Serializable

Serialized Fields

treeId

int treeId

node

org.apache.spark.mllib.tree.model.DecisionTreeModel$SaveLoadV1_0$NodeData node

Class org.apache.spark.mllib.tree.model.TreeEnsembleModel$SaveLoadV1_0$EnsembleNodeData$ extends scala.runtime.AbstractFunction2<java.lang.Object,org.apache.spark.mllib.tree.model.DecisionTreeModel$SaveLoadV1_0$NodeData,org.apache.spark.mllib.tree.model.TreeEnsembleModel$SaveLoadV1_0$EnsembleNodeData> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.mllib.tree.model.TreeEnsembleModel$SaveLoadV1_0$Metadata extends java.lang.Object implements Serializable

Serialized Fields

algo

java.lang.String algo

treeAlgo

java.lang.String treeAlgo

combiningStrategy

java.lang.String combiningStrategy

treeWeights

double[] treeWeights

Class org.apache.spark.mllib.tree.model.TreeEnsembleModel$SaveLoadV1_0$Metadata$ extends scala.runtime.AbstractFunction4<java.lang.String,java.lang.String,java.lang.String,double[],org.apache.spark.mllib.tree.model.TreeEnsembleModel$SaveLoadV1_0$Metadata> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.rdd

Class org.apache.spark.rdd.AsyncRDDActions extends java.lang.Object implements Serializable

Class org.apache.spark.rdd.AsyncRDDActions$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

futureExecutionContext

scala.concurrent.ExecutionContextExecutorService futureExecutionContext

Class org.apache.spark.rdd.CheckpointState$ extends scala.Enumeration implements Serializable

Serialized Fields

Initialized

scala.Enumeration.Value Initialized

CheckpointingInProgress

scala.Enumeration.Value CheckpointingInProgress

Checkpointed

scala.Enumeration.Value Checkpointed

Class org.apache.spark.rdd.CoalescedRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rdd.CoalescedRDDPartition$ extends scala.runtime.AbstractFunction4<java.lang.Object,RDD<?>,int[],scala.Option<java.lang.String>,org.apache.spark.rdd.CoalescedRDDPartition> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rdd.CoGroupedRDD extends RDD<scala.Tuple2<K,scala.collection.Iterable<?>[]>> implements Serializable

Class org.apache.spark.rdd.DoubleRDDFunctions extends java.lang.Object implements Serializable

Class org.apache.spark.rdd.HadoopRDD extends RDD<scala.Tuple2<K,V>> implements Serializable

Class org.apache.spark.rdd.HadoopRDD.HadoopMapPartitionsWithSplitRDD$ extends java.lang.Object implements Serializable

Class org.apache.spark.rdd.HadoopRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

CONFIGURATION_INSTANTIATION_LOCK

java.lang.Object CONFIGURATION_INSTANTIATION_LOCK

RECORDS_BETWEEN_BYTES_READ_METRIC_UPDATES

int RECORDS_BETWEEN_BYTES_READ_METRIC_UPDATES

SPLIT_INFO_REFLECTIONS

scala.Option<A> SPLIT_INFO_REFLECTIONS

Class org.apache.spark.rdd.JdbcRDD extends RDD<T> implements Serializable

Class org.apache.spark.rdd.JdbcRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rdd.LocalRDDCheckpointData$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

DEFAULT_STORAGE_LEVEL

StorageLevel DEFAULT_STORAGE_LEVEL

Class org.apache.spark.rdd.MapPartitionsRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rdd.NarrowCoGroupSplitDep$ extends scala.runtime.AbstractFunction3<RDD<?>,java.lang.Object,Partition,org.apache.spark.rdd.NarrowCoGroupSplitDep> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rdd.NewHadoopRDD extends RDD<scala.Tuple2<K,V>> implements Serializable

Class org.apache.spark.rdd.NewHadoopRDD.NewHadoopMapPartitionsWithSplitRDD$ extends java.lang.Object implements Serializable

Class org.apache.spark.rdd.NewHadoopRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

CONFIGURATION_INSTANTIATION_LOCK

java.lang.Object CONFIGURATION_INSTANTIATION_LOCK

Class org.apache.spark.rdd.OrderedRDDFunctions extends java.lang.Object implements Serializable

Class org.apache.spark.rdd.PairRDDFunctions extends java.lang.Object implements Serializable

Class org.apache.spark.rdd.PairRDDFunctions$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

RECORDS_BETWEEN_BYTES_WRITTEN_METRIC_UPDATES

int RECORDS_BETWEEN_BYTES_WRITTEN_METRIC_UPDATES

disableOutputSpecValidation

scala.util.DynamicVariable<T> disableOutputSpecValidation

Class org.apache.spark.rdd.ParallelCollectionRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rdd.PartitionPruningRDD extends RDD<T> implements Serializable

Class org.apache.spark.rdd.PartitionPruningRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rdd.PartitionwiseSampledRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rdd.PipedRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rdd.RDD extends java.lang.Object implements Serializable

Class org.apache.spark.rdd.RDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

CHECKPOINT_ALL_MARKED_ANCESTORS

java.lang.String CHECKPOINT_ALL_MARKED_ANCESTORS

Class org.apache.spark.rdd.RDDCheckpointData$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rdd.ReliableCheckpointRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rdd.ReliableRDDCheckpointData$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rdd.SequenceFileRDDFunctions extends java.lang.Object implements Serializable

Class org.apache.spark.rdd.ShuffledRDD extends RDD<scala.Tuple2<K,C>> implements Serializable

Class org.apache.spark.rdd.UnionRDD extends RDD<T> implements Serializable

Class org.apache.spark.rdd.ZippedPartitionsBaseRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rdd.ZippedPartitionsRDD2$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rdd.ZippedPartitionsRDD3$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rdd.ZippedPartitionsRDD4$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.rpc.netty

Class org.apache.spark.rpc.netty.OneWayMessage$ extends scala.runtime.AbstractFunction2<org.apache.spark.rpc.RpcAddress,java.lang.Object,org.apache.spark.rpc.netty.OneWayMessage> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rpc.netty.OneWayOutboxMessage$ extends scala.runtime.AbstractFunction1<java.nio.ByteBuffer,org.apache.spark.rpc.netty.OneWayOutboxMessage> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rpc.netty.OnStart$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rpc.netty.OnStop$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rpc.netty.RemoteProcessConnected$ extends scala.runtime.AbstractFunction1<org.apache.spark.rpc.RpcAddress,org.apache.spark.rpc.netty.RemoteProcessConnected> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rpc.netty.RemoteProcessConnectionError$ extends scala.runtime.AbstractFunction2<java.lang.Throwable,org.apache.spark.rpc.RpcAddress,org.apache.spark.rpc.netty.RemoteProcessConnectionError> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rpc.netty.RemoteProcessDisconnected$ extends scala.runtime.AbstractFunction1<org.apache.spark.rpc.RpcAddress,org.apache.spark.rpc.netty.RemoteProcessDisconnected> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rpc.netty.RequestMessage$ extends scala.runtime.AbstractFunction3<org.apache.spark.rpc.RpcAddress,org.apache.spark.rpc.netty.NettyRpcEndpointRef,java.lang.Object,org.apache.spark.rpc.netty.RequestMessage> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rpc.netty.RpcEndpointVerifier.CheckExistence extends java.lang.Object implements Serializable

Class org.apache.spark.rpc.netty.RpcEndpointVerifier.CheckExistence$ extends scala.runtime.AbstractFunction1<java.lang.String,org.apache.spark.rpc.netty.RpcEndpointVerifier.CheckExistence> implements Serializable

Class org.apache.spark.rpc.netty.RpcFailure$ extends scala.runtime.AbstractFunction1<java.lang.Throwable,org.apache.spark.rpc.netty.RpcFailure> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rpc.netty.RpcMessage$ extends scala.runtime.AbstractFunction3<org.apache.spark.rpc.RpcAddress,java.lang.Object,org.apache.spark.rpc.netty.NettyRpcCallContext,org.apache.spark.rpc.netty.RpcMessage> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.rpc.netty.RpcOutboxMessage$ extends scala.runtime.AbstractFunction3<java.nio.ByteBuffer,scala.Function1<java.lang.Throwable,scala.runtime.BoxedUnit>,scala.Function2<org.apache.spark.network.client.TransportClient,java.nio.ByteBuffer,scala.runtime.BoxedUnit>,org.apache.spark.rpc.netty.RpcOutboxMessage> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.scheduler

Class org.apache.spark.scheduler.AccumulableInfo extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.AccumulableInfo$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.AllJobsCancelled$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.AskPermissionToCommitOutput extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.AskPermissionToCommitOutput$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.Object,java.lang.Object,AskPermissionToCommitOutput> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.BeginEvent$ extends scala.runtime.AbstractFunction2<org.apache.spark.scheduler.Task<?>,TaskInfo,org.apache.spark.scheduler.BeginEvent> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.CompletionEvent$ extends scala.runtime.AbstractFunction5<org.apache.spark.scheduler.Task<?>,TaskEndReason,java.lang.Object,scala.collection.Seq<AccumulatorV2<?,?>>,TaskInfo,org.apache.spark.scheduler.CompletionEvent> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.ExecutorAdded$ extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.String,org.apache.spark.scheduler.ExecutorAdded> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.ExecutorCacheTaskLocation$ extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.String,org.apache.spark.scheduler.ExecutorCacheTaskLocation> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.ExecutorExited$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.ExecutorKilled$ extends org.apache.spark.scheduler.ExecutorLossReason implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.ExecutorLost$ extends scala.runtime.AbstractFunction1<java.lang.String,org.apache.spark.scheduler.ExecutorLost> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.GettingResultEvent$ extends scala.runtime.AbstractFunction1<TaskInfo,org.apache.spark.scheduler.GettingResultEvent> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.HDFSCacheTaskLocation$ extends scala.runtime.AbstractFunction1<java.lang.String,org.apache.spark.scheduler.HDFSCacheTaskLocation> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.HighlyCompressedMapStatus$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.HostTaskLocation$ extends scala.runtime.AbstractFunction1<java.lang.String,org.apache.spark.scheduler.HostTaskLocation> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.IndirectTaskResult$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.JobCancelled$ extends scala.runtime.AbstractFunction1<java.lang.Object,org.apache.spark.scheduler.JobCancelled> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.JobFailed$ extends scala.runtime.AbstractFunction1<java.lang.Exception,org.apache.spark.scheduler.JobFailed> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.JobGroupCancelled$ extends scala.runtime.AbstractFunction1<java.lang.String,org.apache.spark.scheduler.JobGroupCancelled> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.JobSubmitted$ extends scala.runtime.AbstractFunction7<java.lang.Object,RDD<?>,scala.Function2<TaskContext,scala.collection.Iterator<?>,?>,int[],org.apache.spark.util.CallSite,org.apache.spark.scheduler.JobListener,java.util.Properties,org.apache.spark.scheduler.JobSubmitted> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.JobSucceeded$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.LossReasonPending$ extends org.apache.spark.scheduler.ExecutorLossReason implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.MapStageSubmitted$ extends scala.runtime.AbstractFunction5<java.lang.Object,ShuffleDependency<?,?,?>,org.apache.spark.util.CallSite,org.apache.spark.scheduler.JobListener,java.util.Properties,org.apache.spark.scheduler.MapStageSubmitted> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.ResubmitFailedStages$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.RuntimePercentage extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.RuntimePercentage$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SchedulingMode$ extends scala.Enumeration implements Serializable

Serialized Fields

FAIR

scala.Enumeration.Value FAIR

FIFO

scala.Enumeration.Value FIFO

NONE

scala.Enumeration.Value NONE

Class org.apache.spark.scheduler.SlaveLost$ extends scala.runtime.AbstractFunction1<java.lang.String,org.apache.spark.scheduler.SlaveLost> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SparkListenerApplicationEnd extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.SparkListenerApplicationEnd$ extends scala.runtime.AbstractFunction1<java.lang.Object,SparkListenerApplicationEnd> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SparkListenerApplicationStart extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.SparkListenerApplicationStart$ extends scala.runtime.AbstractFunction6<java.lang.String,scala.Option<java.lang.String>,java.lang.Object,java.lang.String,scala.Option<java.lang.String>,scala.Option<scala.collection.Map<java.lang.String,java.lang.String>>,SparkListenerApplicationStart> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SparkListenerBlockManagerAdded extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.SparkListenerBlockManagerAdded$ extends scala.runtime.AbstractFunction3<java.lang.Object,BlockManagerId,java.lang.Object,SparkListenerBlockManagerAdded> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SparkListenerBlockManagerRemoved extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.SparkListenerBlockManagerRemoved$ extends scala.runtime.AbstractFunction2<java.lang.Object,BlockManagerId,SparkListenerBlockManagerRemoved> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SparkListenerBlockUpdated extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.SparkListenerBlockUpdated$ extends scala.runtime.AbstractFunction1<BlockUpdatedInfo,SparkListenerBlockUpdated> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SparkListenerEnvironmentUpdate extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.SparkListenerEnvironmentUpdate$ extends scala.runtime.AbstractFunction1<scala.collection.Map<java.lang.String,scala.collection.Seq<scala.Tuple2<java.lang.String,java.lang.String>>>,SparkListenerEnvironmentUpdate> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SparkListenerExecutorAdded extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.SparkListenerExecutorAdded$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.String,ExecutorInfo,SparkListenerExecutorAdded> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SparkListenerExecutorMetricsUpdate extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.SparkListenerExecutorMetricsUpdate$ extends scala.runtime.AbstractFunction2<java.lang.String,scala.collection.Seq<scala.Tuple4<java.lang.Object,java.lang.Object,java.lang.Object,scala.collection.Seq<AccumulableInfo>>>,SparkListenerExecutorMetricsUpdate> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SparkListenerExecutorRemoved extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.SparkListenerExecutorRemoved$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.String,java.lang.String,SparkListenerExecutorRemoved> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SparkListenerJobEnd extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.SparkListenerJobEnd$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.Object,JobResult,SparkListenerJobEnd> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SparkListenerJobStart extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.SparkListenerJobStart$ extends scala.runtime.AbstractFunction4<java.lang.Object,java.lang.Object,scala.collection.Seq<StageInfo>,java.util.Properties,SparkListenerJobStart> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SparkListenerLogStart$ extends scala.runtime.AbstractFunction1<java.lang.String,org.apache.spark.scheduler.SparkListenerLogStart> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SparkListenerStageCompleted extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.SparkListenerStageCompleted$ extends scala.runtime.AbstractFunction1<StageInfo,SparkListenerStageCompleted> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SparkListenerStageSubmitted extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.SparkListenerStageSubmitted$ extends scala.runtime.AbstractFunction2<StageInfo,java.util.Properties,SparkListenerStageSubmitted> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SparkListenerTaskEnd extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.SparkListenerTaskEnd$ extends scala.runtime.AbstractFunction6<java.lang.Object,java.lang.Object,java.lang.String,TaskEndReason,TaskInfo,org.apache.spark.executor.TaskMetrics,SparkListenerTaskEnd> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SparkListenerTaskGettingResult extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.SparkListenerTaskGettingResult$ extends scala.runtime.AbstractFunction1<TaskInfo,SparkListenerTaskGettingResult> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SparkListenerTaskStart extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.SparkListenerTaskStart$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.Object,TaskInfo,SparkListenerTaskStart> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.SparkListenerUnpersistRDD extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.SparkListenerUnpersistRDD$ extends scala.runtime.AbstractFunction1<java.lang.Object,SparkListenerUnpersistRDD> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.StageCancelled$ extends scala.runtime.AbstractFunction1<java.lang.Object,org.apache.spark.scheduler.StageCancelled> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.StopCoordinator$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.Task$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.TaskLocality$ extends scala.Enumeration implements Serializable

Serialized Fields

PROCESS_LOCAL

scala.Enumeration.Value PROCESS_LOCAL

NODE_LOCAL

scala.Enumeration.Value NODE_LOCAL

NO_PREF

scala.Enumeration.Value NO_PREF

RACK_LOCAL

scala.Enumeration.Value RACK_LOCAL

ANY

scala.Enumeration.Value ANY

Class org.apache.spark.scheduler.TaskSetFailed$ extends scala.runtime.AbstractFunction3<org.apache.spark.scheduler.TaskSet,java.lang.String,scala.Option<java.lang.Throwable>,org.apache.spark.scheduler.TaskSetFailed> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.WorkerOffer$ extends scala.runtime.AbstractFunction3<java.lang.String,java.lang.String,java.lang.Object,org.apache.spark.scheduler.WorkerOffer> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.scheduler.cluster

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.AddWebUIFilter extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.AddWebUIFilter$ extends scala.runtime.AbstractFunction3<java.lang.String,scala.collection.immutable.Map<java.lang.String,java.lang.String>,java.lang.String,CoarseGrainedClusterMessages.AddWebUIFilter> implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.GetExecutorLossReason extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.GetExecutorLossReason$ extends scala.runtime.AbstractFunction1<java.lang.String,CoarseGrainedClusterMessages.GetExecutorLossReason> implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.KillExecutors extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.KillExecutors$ extends scala.runtime.AbstractFunction1<scala.collection.Seq<java.lang.String>,CoarseGrainedClusterMessages.KillExecutors> implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.KillTask extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.KillTask$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.String,java.lang.Object,CoarseGrainedClusterMessages.KillTask> implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.LaunchTask extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.LaunchTask$ extends scala.runtime.AbstractFunction1<org.apache.spark.util.SerializableBuffer,CoarseGrainedClusterMessages.LaunchTask> implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RegisterClusterManager extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RegisterClusterManager$ extends scala.runtime.AbstractFunction1<org.apache.spark.rpc.RpcEndpointRef,CoarseGrainedClusterMessages.RegisterClusterManager> implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RegisteredExecutor extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RegisteredExecutor$ extends scala.runtime.AbstractFunction1<java.lang.String,CoarseGrainedClusterMessages.RegisteredExecutor> implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RegisterExecutor extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RegisterExecutor$ extends scala.runtime.AbstractFunction4<java.lang.String,org.apache.spark.rpc.RpcEndpointRef,java.lang.Object,scala.collection.immutable.Map<java.lang.String,java.lang.String>,CoarseGrainedClusterMessages.RegisterExecutor> implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RegisterExecutorFailed extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RegisterExecutorFailed$ extends scala.runtime.AbstractFunction1<java.lang.String,CoarseGrainedClusterMessages.RegisterExecutorFailed> implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RemoveExecutor extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RemoveExecutor$ extends scala.runtime.AbstractFunction2<java.lang.String,org.apache.spark.scheduler.ExecutorLossReason,CoarseGrainedClusterMessages.RemoveExecutor> implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RequestExecutors extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RequestExecutors$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.Object,scala.collection.immutable.Map<java.lang.String,java.lang.Object>,CoarseGrainedClusterMessages.RequestExecutors> implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RetrieveLastAllocatedExecutorId$ extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RetrieveSparkProps$ extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.ReviveOffers$ extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.SetupDriver extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.SetupDriver$ extends scala.runtime.AbstractFunction1<org.apache.spark.rpc.RpcEndpointRef,CoarseGrainedClusterMessages.SetupDriver> implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.Shutdown$ extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.StatusUpdate extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.StatusUpdate$ extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.StopDriver$ extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.StopExecutor$ extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.StopExecutors$ extends java.lang.Object implements Serializable

Package org.apache.spark.scheduler.cluster.mesos

Class org.apache.spark.scheduler.cluster.mesos.MesosTaskLaunchData$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.scheduler.local

Class org.apache.spark.scheduler.local.KillTask extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.local.KillTask$ extends scala.runtime.AbstractFunction2<java.lang.Object,java.lang.Object,KillTask> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.local.ReviveOffers extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.local.ReviveOffers$ extends scala.runtime.AbstractFunction0<ReviveOffers> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.local.StatusUpdate extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.local.StatusUpdate$ extends scala.runtime.AbstractFunction3<java.lang.Object,scala.Enumeration.Value,java.nio.ByteBuffer,StatusUpdate> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.scheduler.local.StopExecutor extends java.lang.Object implements Serializable

Class org.apache.spark.scheduler.local.StopExecutor$ extends scala.runtime.AbstractFunction0<StopExecutor> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.serializer

Class org.apache.spark.serializer.JavaSerializer extends Serializer implements Serializable

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)

writeExternal

public void writeExternal(java.io.ObjectOutput out)

Class org.apache.spark.serializer.KryoSerializer extends Serializer implements Serializable

Class org.apache.spark.serializer.KryoSerializer$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

org$apache$spark$serializer$KryoSerializer$$toRegister

scala.collection.Seq<A> org$apache$spark$serializer$KryoSerializer$$toRegister

org$apache$spark$serializer$KryoSerializer$$toRegisterSerializer

scala.collection.immutable.Map<A,B> org$apache$spark$serializer$KryoSerializer$$toRegisterSerializer

Package org.apache.spark.sql

Class org.apache.spark.sql.AnalysisException extends java.lang.Exception implements Serializable

Class org.apache.spark.sql.AnalysisException$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.ContinuousQueryException extends java.lang.Exception implements Serializable

Class org.apache.spark.sql.ContinuousQueryException$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.Dataset extends java.lang.Object implements Serializable

Class org.apache.spark.sql.Dataset$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.DatasetHolder extends java.lang.Object implements Serializable

Class org.apache.spark.sql.DatasetHolder$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.KeyValueGroupedDataset extends java.lang.Object implements Serializable

Class org.apache.spark.sql.ProcessingTime extends java.lang.Object implements Serializable

Class org.apache.spark.sql.ProcessingTime$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.RelationalGroupedDataset.PivotType$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Expression,scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Literal>,org.apache.spark.sql.RelationalGroupedDataset.PivotType> implements Serializable

Class org.apache.spark.sql.Row$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

empty

Row empty

Class org.apache.spark.sql.SparkSession extends java.lang.Object implements Serializable

Class org.apache.spark.sql.SparkSession.implicits$ extends SQLImplicits implements Serializable

Class org.apache.spark.sql.SparkSession$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

HIVE_SHARED_STATE_CLASS_NAME

java.lang.String HIVE_SHARED_STATE_CLASS_NAME

HIVE_SESSION_STATE_CLASS_NAME

java.lang.String HIVE_SESSION_STATE_CLASS_NAME

Class org.apache.spark.sql.SQLContext extends java.lang.Object implements Serializable

Class org.apache.spark.sql.SQLContext.implicits$ extends SQLImplicits implements Serializable

Class org.apache.spark.sql.SQLContext$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

activeContext

java.lang.InheritableThreadLocal<T> activeContext

Package org.apache.spark.sql.api.java

Package org.apache.spark.sql.expressions

Class org.apache.spark.sql.expressions.Aggregator extends java.lang.Object implements Serializable

Class org.apache.spark.sql.expressions.MutableAggregationBuffer extends java.lang.Object implements Serializable

Class org.apache.spark.sql.expressions.UserDefinedAggregateFunction extends java.lang.Object implements Serializable

Class org.apache.spark.sql.expressions.UserDefinedFunction extends java.lang.Object implements Serializable

Class org.apache.spark.sql.expressions.UserDefinedFunction$ extends scala.runtime.AbstractFunction3<java.lang.Object,DataType,scala.Option<scala.collection.Seq<DataType>>,UserDefinedFunction> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.sql.hive

Class org.apache.spark.sql.hive.HiveContext extends SQLContext implements Serializable

Class org.apache.spark.sql.hive.HiveGenericUDF$ extends scala.runtime.AbstractFunction3<java.lang.String,org.apache.spark.sql.hive.HiveShim.HiveFunctionWrapper,scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>,org.apache.spark.sql.hive.HiveGenericUDF> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.hive.HiveGenericUDTF$ extends scala.runtime.AbstractFunction3<java.lang.String,org.apache.spark.sql.hive.HiveShim.HiveFunctionWrapper,scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>,org.apache.spark.sql.hive.HiveGenericUDTF> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.hive.HiveMetastoreCatalog.QualifiedTableName extends java.lang.Object implements Serializable

Class org.apache.spark.sql.hive.HiveShim.HiveFunctionWrapper$ extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.Object,org.apache.spark.sql.hive.HiveShim.HiveFunctionWrapper> implements Serializable

Class org.apache.spark.sql.hive.HiveSimpleUDF$ extends scala.runtime.AbstractFunction3<java.lang.String,org.apache.spark.sql.hive.HiveShim.HiveFunctionWrapper,scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>,org.apache.spark.sql.hive.HiveSimpleUDF> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.hive.HiveUDAFFunction$ extends scala.runtime.AbstractFunction6<java.lang.String,org.apache.spark.sql.hive.HiveShim.HiveFunctionWrapper,scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>,java.lang.Object,java.lang.Object,java.lang.Object,org.apache.spark.sql.hive.HiveUDAFFunction> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.hive.InsertIntoHiveTable$ extends scala.runtime.AbstractFunction5<org.apache.spark.sql.hive.MetastoreRelation,scala.collection.immutable.Map<java.lang.String,scala.Option<java.lang.String>>,org.apache.spark.sql.catalyst.plans.logical.LogicalPlan,java.lang.Object,java.lang.Object,org.apache.spark.sql.hive.InsertIntoHiveTable> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.hive.MetastoreRelation$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.hive.SparkHiveDynamicPartitionWriterContainer$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

SUCCESSFUL_JOB_OUTPUT_DIR_MARKER

java.lang.String SUCCESSFUL_JOB_OUTPUT_DIR_MARKER

Class org.apache.spark.sql.hive.SparkHiveWriterContainer$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.sql.hive.execution

Class org.apache.spark.sql.hive.execution.CreateTableAsSelect$ extends scala.runtime.AbstractFunction3<org.apache.spark.sql.catalyst.catalog.CatalogTable,org.apache.spark.sql.catalyst.plans.logical.LogicalPlan,java.lang.Object,org.apache.spark.sql.hive.execution.CreateTableAsSelect> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.hive.execution.HiveScriptIOSchema$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.hive.execution.HiveTableScanExec$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.hive.execution.InsertIntoHiveTable extends org.apache.spark.sql.execution.SparkPlan implements Serializable

Class org.apache.spark.sql.hive.execution.InsertIntoHiveTable$ extends scala.runtime.AbstractFunction5<org.apache.spark.sql.hive.MetastoreRelation,scala.collection.immutable.Map<java.lang.String,scala.Option<java.lang.String>>,org.apache.spark.sql.execution.SparkPlan,java.lang.Object,java.lang.Object,InsertIntoHiveTable> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.hive.execution.ScriptTransformation$ extends scala.runtime.AbstractFunction5<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>,java.lang.String,scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>,org.apache.spark.sql.execution.SparkPlan,org.apache.spark.sql.hive.execution.HiveScriptIOSchema,org.apache.spark.sql.hive.execution.ScriptTransformation> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.sql.hive.orc

Class org.apache.spark.sql.hive.orc.OrcOptions$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

org$apache$spark$sql$hive$orc$OrcOptions$$shortOrcCompressionCodecNames

scala.collection.immutable.Map<A,B> org$apache$spark$sql$hive$orc$OrcOptions$$shortOrcCompressionCodecNames

Class org.apache.spark.sql.hive.orc.OrcTableScan$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

SARG_PUSHDOWN

java.lang.String SARG_PUSHDOWN

Package org.apache.spark.sql.internal

Class org.apache.spark.sql.internal.HiveSerDe extends java.lang.Object implements Serializable

Class org.apache.spark.sql.internal.HiveSerDe$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.internal.SQLConf$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

org$apache$spark$sql$internal$SQLConf$$sqlConfEntries

java.util.Map<K,V> org$apache$spark$sql$internal$SQLConf$$sqlConfEntries

WAREHOUSE_PATH

org.apache.spark.internal.config.ConfigEntry<T> WAREHOUSE_PATH

OPTIMIZER_MAX_ITERATIONS

org.apache.spark.internal.config.ConfigEntry<T> OPTIMIZER_MAX_ITERATIONS

OPTIMIZER_INSET_CONVERSION_THRESHOLD

org.apache.spark.internal.config.ConfigEntry<T> OPTIMIZER_INSET_CONVERSION_THRESHOLD

ALLOW_MULTIPLE_CONTEXTS

org.apache.spark.internal.config.ConfigEntry<T> ALLOW_MULTIPLE_CONTEXTS

COMPRESS_CACHED

org.apache.spark.internal.config.ConfigEntry<T> COMPRESS_CACHED

COLUMN_BATCH_SIZE

org.apache.spark.internal.config.ConfigEntry<T> COLUMN_BATCH_SIZE

IN_MEMORY_PARTITION_PRUNING

org.apache.spark.internal.config.ConfigEntry<T> IN_MEMORY_PARTITION_PRUNING

PREFER_SORTMERGEJOIN

org.apache.spark.internal.config.ConfigEntry<T> PREFER_SORTMERGEJOIN

RADIX_SORT_ENABLED

org.apache.spark.internal.config.ConfigEntry<T> RADIX_SORT_ENABLED

AUTO_BROADCASTJOIN_THRESHOLD

org.apache.spark.internal.config.ConfigEntry<T> AUTO_BROADCASTJOIN_THRESHOLD

DEFAULT_SIZE_IN_BYTES

org.apache.spark.internal.config.ConfigEntry<T> DEFAULT_SIZE_IN_BYTES

SHUFFLE_PARTITIONS

org.apache.spark.internal.config.ConfigEntry<T> SHUFFLE_PARTITIONS

SHUFFLE_TARGET_POSTSHUFFLE_INPUT_SIZE

org.apache.spark.internal.config.ConfigEntry<T> SHUFFLE_TARGET_POSTSHUFFLE_INPUT_SIZE

ADAPTIVE_EXECUTION_ENABLED

org.apache.spark.internal.config.ConfigEntry<T> ADAPTIVE_EXECUTION_ENABLED

SHUFFLE_MIN_NUM_POSTSHUFFLE_PARTITIONS

org.apache.spark.internal.config.ConfigEntry<T> SHUFFLE_MIN_NUM_POSTSHUFFLE_PARTITIONS

SUBEXPRESSION_ELIMINATION_ENABLED

org.apache.spark.internal.config.ConfigEntry<T> SUBEXPRESSION_ELIMINATION_ENABLED

CASE_SENSITIVE

org.apache.spark.internal.config.ConfigEntry<T> CASE_SENSITIVE

PARQUET_SCHEMA_MERGING_ENABLED

org.apache.spark.internal.config.ConfigEntry<T> PARQUET_SCHEMA_MERGING_ENABLED

PARQUET_SCHEMA_RESPECT_SUMMARIES

org.apache.spark.internal.config.ConfigEntry<T> PARQUET_SCHEMA_RESPECT_SUMMARIES

PARQUET_BINARY_AS_STRING

org.apache.spark.internal.config.ConfigEntry<T> PARQUET_BINARY_AS_STRING

PARQUET_INT96_AS_TIMESTAMP

org.apache.spark.internal.config.ConfigEntry<T> PARQUET_INT96_AS_TIMESTAMP

PARQUET_CACHE_METADATA

org.apache.spark.internal.config.ConfigEntry<T> PARQUET_CACHE_METADATA

PARQUET_COMPRESSION

org.apache.spark.internal.config.ConfigEntry<T> PARQUET_COMPRESSION

PARQUET_FILTER_PUSHDOWN_ENABLED

org.apache.spark.internal.config.ConfigEntry<T> PARQUET_FILTER_PUSHDOWN_ENABLED

PARQUET_WRITE_LEGACY_FORMAT

org.apache.spark.internal.config.ConfigEntry<T> PARQUET_WRITE_LEGACY_FORMAT

PARQUET_OUTPUT_COMMITTER_CLASS

org.apache.spark.internal.config.ConfigEntry<T> PARQUET_OUTPUT_COMMITTER_CLASS

PARQUET_VECTORIZED_READER_ENABLED

org.apache.spark.internal.config.ConfigEntry<T> PARQUET_VECTORIZED_READER_ENABLED

ORC_FILTER_PUSHDOWN_ENABLED

org.apache.spark.internal.config.ConfigEntry<T> ORC_FILTER_PUSHDOWN_ENABLED

HIVE_VERIFY_PARTITION_PATH

org.apache.spark.internal.config.ConfigEntry<T> HIVE_VERIFY_PARTITION_PATH

HIVE_METASTORE_PARTITION_PRUNING

org.apache.spark.internal.config.ConfigEntry<T> HIVE_METASTORE_PARTITION_PRUNING

NATIVE_VIEW

org.apache.spark.internal.config.ConfigEntry<T> NATIVE_VIEW

CANONICAL_NATIVE_VIEW

org.apache.spark.internal.config.ConfigEntry<T> CANONICAL_NATIVE_VIEW

COLUMN_NAME_OF_CORRUPT_RECORD

org.apache.spark.internal.config.ConfigEntry<T> COLUMN_NAME_OF_CORRUPT_RECORD

BROADCAST_TIMEOUT

org.apache.spark.internal.config.ConfigEntry<T> BROADCAST_TIMEOUT

THRIFTSERVER_POOL

org.apache.spark.internal.config.OptionalConfigEntry<T> THRIFTSERVER_POOL

THRIFTSERVER_UI_STATEMENT_LIMIT

org.apache.spark.internal.config.ConfigEntry<T> THRIFTSERVER_UI_STATEMENT_LIMIT

THRIFTSERVER_UI_SESSION_LIMIT

org.apache.spark.internal.config.ConfigEntry<T> THRIFTSERVER_UI_SESSION_LIMIT

DEFAULT_DATA_SOURCE_NAME

org.apache.spark.internal.config.ConfigEntry<T> DEFAULT_DATA_SOURCE_NAME

SCHEMA_STRING_LENGTH_THRESHOLD

org.apache.spark.internal.config.ConfigEntry<T> SCHEMA_STRING_LENGTH_THRESHOLD

PARTITION_DISCOVERY_ENABLED

org.apache.spark.internal.config.ConfigEntry<T> PARTITION_DISCOVERY_ENABLED

PARTITION_COLUMN_TYPE_INFERENCE

org.apache.spark.internal.config.ConfigEntry<T> PARTITION_COLUMN_TYPE_INFERENCE

PARTITION_MAX_FILES

org.apache.spark.internal.config.ConfigEntry<T> PARTITION_MAX_FILES

BUCKETING_ENABLED

org.apache.spark.internal.config.ConfigEntry<T> BUCKETING_ENABLED

ORDER_BY_ORDINAL

org.apache.spark.internal.config.ConfigEntry<T> ORDER_BY_ORDINAL

GROUP_BY_ORDINAL

org.apache.spark.internal.config.ConfigEntry<T> GROUP_BY_ORDINAL

OUTPUT_COMMITTER_CLASS

org.apache.spark.internal.config.OptionalConfigEntry<T> OUTPUT_COMMITTER_CLASS

PARALLEL_PARTITION_DISCOVERY_THRESHOLD

org.apache.spark.internal.config.ConfigEntry<T> PARALLEL_PARTITION_DISCOVERY_THRESHOLD

DATAFRAME_EAGER_ANALYSIS

org.apache.spark.internal.config.ConfigEntry<T> DATAFRAME_EAGER_ANALYSIS

DATAFRAME_SELF_JOIN_AUTO_RESOLVE_AMBIGUITY

org.apache.spark.internal.config.ConfigEntry<T> DATAFRAME_SELF_JOIN_AUTO_RESOLVE_AMBIGUITY

DATAFRAME_RETAIN_GROUP_COLUMNS

org.apache.spark.internal.config.ConfigEntry<T> DATAFRAME_RETAIN_GROUP_COLUMNS

DATAFRAME_PIVOT_MAX_VALUES

org.apache.spark.internal.config.ConfigEntry<T> DATAFRAME_PIVOT_MAX_VALUES

RUN_SQL_ON_FILES

org.apache.spark.internal.config.ConfigEntry<T> RUN_SQL_ON_FILES

WHOLESTAGE_CODEGEN_ENABLED

org.apache.spark.internal.config.ConfigEntry<T> WHOLESTAGE_CODEGEN_ENABLED

WHOLESTAGE_MAX_NUM_FIELDS

org.apache.spark.internal.config.ConfigEntry<T> WHOLESTAGE_MAX_NUM_FIELDS

MAX_CASES_BRANCHES

org.apache.spark.internal.config.ConfigEntry<T> MAX_CASES_BRANCHES

FILES_MAX_PARTITION_BYTES

org.apache.spark.internal.config.ConfigEntry<T> FILES_MAX_PARTITION_BYTES

FILES_OPEN_COST_IN_BYTES

org.apache.spark.internal.config.ConfigEntry<T> FILES_OPEN_COST_IN_BYTES

EXCHANGE_REUSE_ENABLED

org.apache.spark.internal.config.ConfigEntry<T> EXCHANGE_REUSE_ENABLED

STATE_STORE_MIN_DELTAS_FOR_SNAPSHOT

org.apache.spark.internal.config.ConfigEntry<T> STATE_STORE_MIN_DELTAS_FOR_SNAPSHOT

STATE_STORE_MIN_VERSIONS_TO_RETAIN

org.apache.spark.internal.config.ConfigEntry<T> STATE_STORE_MIN_VERSIONS_TO_RETAIN

CHECKPOINT_LOCATION

org.apache.spark.internal.config.OptionalConfigEntry<T> CHECKPOINT_LOCATION

UNSUPPORTED_OPERATION_CHECK_ENABLED

org.apache.spark.internal.config.ConfigEntry<T> UNSUPPORTED_OPERATION_CHECK_ENABLED

VARIABLE_SUBSTITUTE_ENABLED

org.apache.spark.internal.config.ConfigEntry<T> VARIABLE_SUBSTITUTE_ENABLED

VARIABLE_SUBSTITUTE_DEPTH

org.apache.spark.internal.config.ConfigEntry<T> VARIABLE_SUBSTITUTE_DEPTH

VECTORIZED_AGG_MAP_MAX_COLUMNS

org.apache.spark.internal.config.ConfigEntry<T> VECTORIZED_AGG_MAP_MAX_COLUMNS

FILE_SINK_LOG_DELETION

org.apache.spark.internal.config.ConfigEntry<T> FILE_SINK_LOG_DELETION

FILE_SINK_LOG_COMPACT_INTERVAL

org.apache.spark.internal.config.ConfigEntry<T> FILE_SINK_LOG_COMPACT_INTERVAL

FILE_SINK_LOG_CLEANUP_DELAY

org.apache.spark.internal.config.ConfigEntry<T> FILE_SINK_LOG_CLEANUP_DELAY

Package org.apache.spark.sql.jdbc

Class org.apache.spark.sql.jdbc.AggregatedDialect extends JdbcDialect implements Serializable

Class org.apache.spark.sql.jdbc.DB2Dialect$ extends JdbcDialect implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.jdbc.DerbyDialect$ extends JdbcDialect implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.jdbc.JdbcDialect extends java.lang.Object implements Serializable

Class org.apache.spark.sql.jdbc.JdbcType extends java.lang.Object implements Serializable

Class org.apache.spark.sql.jdbc.JdbcType$ extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.Object,JdbcType> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.jdbc.MsSqlServerDialect$ extends JdbcDialect implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.jdbc.MySQLDialect$ extends JdbcDialect implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.jdbc.NoopDialect$ extends JdbcDialect implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.jdbc.OracleDialect$ extends JdbcDialect implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.jdbc.PostgresDialect$ extends JdbcDialect implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.sql.sources

Class org.apache.spark.sql.sources.And extends Filter implements Serializable

Class org.apache.spark.sql.sources.And$ extends scala.runtime.AbstractFunction2<Filter,Filter,And> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.sources.EqualNullSafe extends Filter implements Serializable

Class org.apache.spark.sql.sources.EqualNullSafe$ extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.Object,EqualNullSafe> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.sources.EqualTo extends Filter implements Serializable

Class org.apache.spark.sql.sources.EqualTo$ extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.Object,EqualTo> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.sources.GreaterThan extends Filter implements Serializable

Class org.apache.spark.sql.sources.GreaterThan$ extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.Object,GreaterThan> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.sources.GreaterThanOrEqual extends Filter implements Serializable

Class org.apache.spark.sql.sources.GreaterThanOrEqual$ extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.Object,GreaterThanOrEqual> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.sources.In extends Filter implements Serializable

Class org.apache.spark.sql.sources.In$ extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.Object[],In> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.sources.IsNotNull extends Filter implements Serializable

Class org.apache.spark.sql.sources.IsNotNull$ extends scala.runtime.AbstractFunction1<java.lang.String,IsNotNull> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.sources.IsNull extends Filter implements Serializable

Class org.apache.spark.sql.sources.IsNull$ extends scala.runtime.AbstractFunction1<java.lang.String,IsNull> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.sources.LessThan extends Filter implements Serializable

Class org.apache.spark.sql.sources.LessThan$ extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.Object,LessThan> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.sources.LessThanOrEqual extends Filter implements Serializable

Class org.apache.spark.sql.sources.LessThanOrEqual$ extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.Object,LessThanOrEqual> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.sources.Not extends Filter implements Serializable

Class org.apache.spark.sql.sources.Not$ extends scala.runtime.AbstractFunction1<Filter,Not> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.sources.Or extends Filter implements Serializable

Class org.apache.spark.sql.sources.Or$ extends scala.runtime.AbstractFunction2<Filter,Filter,Or> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.sources.StringContains extends Filter implements Serializable

Class org.apache.spark.sql.sources.StringContains$ extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.String,StringContains> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.sources.StringEndsWith extends Filter implements Serializable

Class org.apache.spark.sql.sources.StringEndsWith$ extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.String,StringEndsWith> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.sources.StringStartsWith extends Filter implements Serializable

Class org.apache.spark.sql.sources.StringStartsWith$ extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.String,StringStartsWith> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.sql.types

Class org.apache.spark.sql.types.ArrayType extends DataType implements Serializable

Class org.apache.spark.sql.types.ArrayType$ extends org.apache.spark.sql.types.AbstractDataType implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.types.BinaryType$ extends BinaryType implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.types.BooleanType$ extends BooleanType implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.types.ByteType$ extends ByteType implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.types.CalendarIntervalType$ extends CalendarIntervalType implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.types.DateType$ extends DateType implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.types.Decimal extends java.lang.Object implements Serializable

Class org.apache.spark.sql.types.Decimal.DecimalAsIfIntegral$ extends java.lang.Object implements Serializable

Class org.apache.spark.sql.types.Decimal.DecimalIsFractional$ extends java.lang.Object implements Serializable

Class org.apache.spark.sql.types.Decimal$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

ROUND_HALF_UP

scala.Enumeration.Value ROUND_HALF_UP

ROUND_HALF_EVEN

scala.Enumeration.Value ROUND_HALF_EVEN

ROUND_CEILING

scala.Enumeration.Value ROUND_CEILING

ROUND_FLOOR

scala.Enumeration.Value ROUND_FLOOR

MAX_INT_DIGITS

int MAX_INT_DIGITS

MAX_LONG_DIGITS

int MAX_LONG_DIGITS

org$apache$spark$sql$types$Decimal$$POW_10

long[] org$apache$spark$sql$types$Decimal$$POW_10

org$apache$spark$sql$types$Decimal$$BIG_DEC_ZERO

scala.math.BigDecimal org$apache$spark$sql$types$Decimal$$BIG_DEC_ZERO

org$apache$spark$sql$types$Decimal$$MATH_CONTEXT

java.math.MathContext org$apache$spark$sql$types$Decimal$$MATH_CONTEXT

ZERO

Decimal ZERO

ONE

Decimal ONE

Class org.apache.spark.sql.types.DecimalType extends org.apache.spark.sql.types.FractionalType implements Serializable

Class org.apache.spark.sql.types.DecimalType$ extends org.apache.spark.sql.types.AbstractDataType implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

MAX_PRECISION

int MAX_PRECISION

MAX_SCALE

int MAX_SCALE

SYSTEM_DEFAULT

DecimalType SYSTEM_DEFAULT

USER_DEFAULT

DecimalType USER_DEFAULT

ByteDecimal

DecimalType ByteDecimal

ShortDecimal

DecimalType ShortDecimal

IntDecimal

DecimalType IntDecimal

LongDecimal

DecimalType LongDecimal

FloatDecimal

DecimalType FloatDecimal

DoubleDecimal

DecimalType DoubleDecimal

Class org.apache.spark.sql.types.DoubleType$ extends DoubleType implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.types.FloatType$ extends FloatType implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.types.IntegerType$ extends IntegerType implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.types.LongType$ extends LongType implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.types.MapType extends DataType implements Serializable

Class org.apache.spark.sql.types.MapType$ extends org.apache.spark.sql.types.AbstractDataType implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.types.Metadata extends java.lang.Object implements Serializable

Class org.apache.spark.sql.types.Metadata$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.types.NullType$ extends NullType implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.types.ObjectType$ extends org.apache.spark.sql.types.AbstractDataType implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.types.ShortType$ extends ShortType implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.types.StringType$ extends StringType implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.types.StructField extends java.lang.Object implements Serializable

Class org.apache.spark.sql.types.StructField$ extends scala.runtime.AbstractFunction4<java.lang.String,DataType,java.lang.Object,Metadata,StructField> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.types.StructType extends DataType implements Serializable

Class org.apache.spark.sql.types.StructType$ extends org.apache.spark.sql.types.AbstractDataType implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

metadataKeyForOptionalField

java.lang.String metadataKeyForOptionalField

Class org.apache.spark.sql.types.TimestampType$ extends TimestampType implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.sql.types.UDTRegistration$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

udtMap

scala.collection.mutable.Map<A,B> udtMap

bitmap$0

boolean bitmap$0

Package org.apache.spark.status.api.v1

Class org.apache.spark.status.api.v1.ErrorWrapper$ extends scala.runtime.AbstractFunction1<java.lang.String,org.apache.spark.status.api.v1.ErrorWrapper> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.storage

Class org.apache.spark.storage.BlockException$ extends scala.runtime.AbstractFunction2<BlockId,java.lang.String,org.apache.spark.storage.BlockException> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.storage.BlockFetchException$ extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.Throwable,org.apache.spark.storage.BlockFetchException> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.storage.BlockManagerId extends java.lang.Object implements Serializable

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)

writeExternal

public void writeExternal(java.io.ObjectOutput out)

Class org.apache.spark.storage.BlockManagerId$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

blockManagerIdCache

java.util.concurrent.ConcurrentHashMap<K,V> blockManagerIdCache

Class org.apache.spark.storage.BlockManagerMessages.BlockManagerHeartbeat extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.BlockManagerHeartbeat$ extends scala.runtime.AbstractFunction1<BlockManagerId,BlockManagerMessages.BlockManagerHeartbeat> implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.GetBlockStatus extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.GetBlockStatus$ extends scala.runtime.AbstractFunction2<BlockId,java.lang.Object,BlockManagerMessages.GetBlockStatus> implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.GetExecutorEndpointRef extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.GetExecutorEndpointRef$ extends scala.runtime.AbstractFunction1<java.lang.String,BlockManagerMessages.GetExecutorEndpointRef> implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.GetLocations extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.GetLocations$ extends scala.runtime.AbstractFunction1<BlockId,BlockManagerMessages.GetLocations> implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.GetLocationsMultipleBlockIds extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.GetLocationsMultipleBlockIds$ extends scala.runtime.AbstractFunction1<BlockId[],BlockManagerMessages.GetLocationsMultipleBlockIds> implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.GetMatchingBlockIds extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.GetMatchingBlockIds$ extends scala.runtime.AbstractFunction2<scala.Function1<BlockId,java.lang.Object>,java.lang.Object,BlockManagerMessages.GetMatchingBlockIds> implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.GetMemoryStatus$ extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.GetPeers extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.GetPeers$ extends scala.runtime.AbstractFunction1<BlockManagerId,BlockManagerMessages.GetPeers> implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.GetStorageStatus$ extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.HasCachedBlocks extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.HasCachedBlocks$ extends scala.runtime.AbstractFunction1<java.lang.String,BlockManagerMessages.HasCachedBlocks> implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.RegisterBlockManager extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.RegisterBlockManager$ extends scala.runtime.AbstractFunction3<BlockManagerId,java.lang.Object,org.apache.spark.rpc.RpcEndpointRef,BlockManagerMessages.RegisterBlockManager> implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.RemoveBlock extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.RemoveBlock$ extends scala.runtime.AbstractFunction1<BlockId,BlockManagerMessages.RemoveBlock> implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.RemoveBroadcast extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.RemoveBroadcast$ extends scala.runtime.AbstractFunction2<java.lang.Object,java.lang.Object,BlockManagerMessages.RemoveBroadcast> implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.RemoveExecutor extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.RemoveExecutor$ extends scala.runtime.AbstractFunction1<java.lang.String,BlockManagerMessages.RemoveExecutor> implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.RemoveRdd extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.RemoveRdd$ extends scala.runtime.AbstractFunction1<java.lang.Object,BlockManagerMessages.RemoveRdd> implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.RemoveShuffle extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.RemoveShuffle$ extends scala.runtime.AbstractFunction1<java.lang.Object,BlockManagerMessages.RemoveShuffle> implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.StopBlockManagerMaster$ extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.TriggerThreadDump$ extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockManagerMessages.UpdateBlockInfo extends java.lang.Object implements Serializable

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)

writeExternal

public void writeExternal(java.io.ObjectOutput out)

Class org.apache.spark.storage.BlockManagerMessages.UpdateBlockInfo$ extends scala.runtime.AbstractFunction5<BlockManagerId,BlockId,StorageLevel,java.lang.Object,java.lang.Object,BlockManagerMessages.UpdateBlockInfo> implements Serializable

Class org.apache.spark.storage.BlockNotFoundException extends java.lang.Exception implements Serializable

Class org.apache.spark.storage.BlockStatus extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockStatus$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.storage.BlockUIData$ extends scala.runtime.AbstractFunction5<BlockId,java.lang.String,StorageLevel,java.lang.Object,java.lang.Object,org.apache.spark.storage.BlockUIData> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.storage.BlockUpdatedInfo extends java.lang.Object implements Serializable

Class org.apache.spark.storage.BlockUpdatedInfo$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.storage.BroadcastBlockId extends BlockId implements Serializable

Class org.apache.spark.storage.BroadcastBlockId$ extends scala.runtime.AbstractFunction2<java.lang.Object,java.lang.String,BroadcastBlockId> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.storage.ExecutorStreamBlockStatus$ extends scala.runtime.AbstractFunction3<java.lang.String,java.lang.String,scala.collection.Seq<org.apache.spark.storage.BlockUIData>,org.apache.spark.storage.ExecutorStreamBlockStatus> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.storage.RDDBlockId extends BlockId implements Serializable

Class org.apache.spark.storage.RDDBlockId$ extends scala.runtime.AbstractFunction2<java.lang.Object,java.lang.Object,RDDBlockId> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.storage.ShuffleBlockFetcherIterator.FailureFetchResult$ extends scala.runtime.AbstractFunction3<BlockId,BlockManagerId,java.lang.Throwable,org.apache.spark.storage.ShuffleBlockFetcherIterator.FailureFetchResult> implements Serializable

Class org.apache.spark.storage.ShuffleBlockFetcherIterator.FetchRequest extends java.lang.Object implements Serializable

Class org.apache.spark.storage.ShuffleBlockFetcherIterator.FetchRequest$ extends scala.runtime.AbstractFunction2<BlockManagerId,scala.collection.Seq<scala.Tuple2<BlockId,java.lang.Object>>,org.apache.spark.storage.ShuffleBlockFetcherIterator.FetchRequest> implements Serializable

Class org.apache.spark.storage.ShuffleBlockFetcherIterator.SuccessFetchResult$ extends scala.runtime.AbstractFunction5<BlockId,BlockManagerId,java.lang.Object,org.apache.spark.network.buffer.ManagedBuffer,java.lang.Object,org.apache.spark.storage.ShuffleBlockFetcherIterator.SuccessFetchResult> implements Serializable

Class org.apache.spark.storage.ShuffleBlockId extends BlockId implements Serializable

Class org.apache.spark.storage.ShuffleBlockId$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.Object,java.lang.Object,ShuffleBlockId> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.storage.ShuffleDataBlockId extends BlockId implements Serializable

Class org.apache.spark.storage.ShuffleDataBlockId$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.Object,java.lang.Object,ShuffleDataBlockId> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.storage.ShuffleIndexBlockId extends BlockId implements Serializable

Class org.apache.spark.storage.ShuffleIndexBlockId$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.Object,java.lang.Object,ShuffleIndexBlockId> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.storage.StorageLevel extends java.lang.Object implements Serializable

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)

writeExternal

public void writeExternal(java.io.ObjectOutput out)

Class org.apache.spark.storage.StorageLevel$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

NONE

StorageLevel NONE

DISK_ONLY

StorageLevel DISK_ONLY

DISK_ONLY_2

StorageLevel DISK_ONLY_2

MEMORY_ONLY

StorageLevel MEMORY_ONLY

MEMORY_ONLY_2

StorageLevel MEMORY_ONLY_2

MEMORY_ONLY_SER

StorageLevel MEMORY_ONLY_SER

MEMORY_ONLY_SER_2

StorageLevel MEMORY_ONLY_SER_2

MEMORY_AND_DISK

StorageLevel MEMORY_AND_DISK

MEMORY_AND_DISK_2

StorageLevel MEMORY_AND_DISK_2

MEMORY_AND_DISK_SER

StorageLevel MEMORY_AND_DISK_SER

MEMORY_AND_DISK_SER_2

StorageLevel MEMORY_AND_DISK_SER_2

OFF_HEAP

StorageLevel OFF_HEAP

storageLevelCache

java.util.concurrent.ConcurrentHashMap<K,V> storageLevelCache

Class org.apache.spark.storage.StreamBlockId extends BlockId implements Serializable

Class org.apache.spark.storage.StreamBlockId$ extends scala.runtime.AbstractFunction2<java.lang.Object,java.lang.Object,StreamBlockId> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.storage.TaskResultBlockId extends BlockId implements Serializable

Class org.apache.spark.storage.TaskResultBlockId$ extends scala.runtime.AbstractFunction1<java.lang.Object,TaskResultBlockId> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.storage.TempLocalBlockId$ extends scala.runtime.AbstractFunction1<java.util.UUID,org.apache.spark.storage.TempLocalBlockId> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.storage.TempShuffleBlockId$ extends scala.runtime.AbstractFunction1<java.util.UUID,org.apache.spark.storage.TempShuffleBlockId> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.storage.TestBlockId$ extends scala.runtime.AbstractFunction1<java.lang.String,org.apache.spark.storage.TestBlockId> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.storage.memory

Class org.apache.spark.storage.memory.DeserializedMemoryEntry extends java.lang.Object implements Serializable

Class org.apache.spark.storage.memory.DeserializedMemoryEntry$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.storage.memory.SerializedMemoryEntry extends java.lang.Object implements Serializable

Class org.apache.spark.storage.memory.SerializedMemoryEntry$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.streaming

Class org.apache.spark.streaming.Checkpoint$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

PREFIX

java.lang.String PREFIX

REGEX

scala.util.matching.Regex REGEX

Class org.apache.spark.streaming.Duration extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.Duration$ extends scala.runtime.AbstractFunction1<java.lang.Object,Duration> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.StateSpec extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.StateSpec$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.StateSpecImpl$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.Time extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.Time$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

ordering

scala.math.Ordering<T> ordering

Package org.apache.spark.streaming.api.java

Class org.apache.spark.streaming.api.java.JavaBatchInfo$ extends scala.runtime.AbstractFunction10<Time,java.util.Map<java.lang.Object,org.apache.spark.streaming.api.java.JavaStreamInputInfo>,java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object,java.util.Map<java.lang.Object,org.apache.spark.streaming.api.java.JavaOutputOperationInfo>,org.apache.spark.streaming.api.java.JavaBatchInfo> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.api.java.JavaDStream extends org.apache.spark.streaming.api.java.AbstractJavaDStreamLike<T,JavaDStream<T>,JavaRDD<T>> implements Serializable

Class org.apache.spark.streaming.api.java.JavaDStream$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.api.java.JavaInputDStream extends JavaDStream<T> implements Serializable

Class org.apache.spark.streaming.api.java.JavaInputDStream$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.api.java.JavaMapWithStateDStream extends JavaDStream<MappedType> implements Serializable

Class org.apache.spark.streaming.api.java.JavaOutputOperationInfo$ extends scala.runtime.AbstractFunction7<Time,java.lang.Object,java.lang.String,java.lang.String,java.lang.Object,java.lang.Object,java.lang.String,org.apache.spark.streaming.api.java.JavaOutputOperationInfo> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.api.java.JavaPairDStream extends org.apache.spark.streaming.api.java.AbstractJavaDStreamLike<scala.Tuple2<K,V>,JavaPairDStream<K,V>,JavaPairRDD<K,V>> implements Serializable

Class org.apache.spark.streaming.api.java.JavaPairDStream$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.api.java.JavaPairInputDStream extends JavaPairDStream<K,V> implements Serializable

Class org.apache.spark.streaming.api.java.JavaPairInputDStream$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.api.java.JavaPairReceiverInputDStream extends JavaPairInputDStream<K,V> implements Serializable

Class org.apache.spark.streaming.api.java.JavaPairReceiverInputDStream$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.api.java.JavaReceiverInfo$ extends scala.runtime.AbstractFunction8<java.lang.Object,java.lang.String,java.lang.Object,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.Object,org.apache.spark.streaming.api.java.JavaReceiverInfo> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.api.java.JavaReceiverInputDStream extends JavaInputDStream<T> implements Serializable

Class org.apache.spark.streaming.api.java.JavaReceiverInputDStream$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.api.java.JavaStreamInputInfo$ extends scala.runtime.AbstractFunction4<java.lang.Object,java.lang.Object,java.util.Map<java.lang.String,java.lang.Object>,java.lang.String,org.apache.spark.streaming.api.java.JavaStreamInputInfo> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.streaming.dstream

Class org.apache.spark.streaming.dstream.ConstantInputDStream extends InputDStream<T> implements Serializable

Class org.apache.spark.streaming.dstream.DStream extends java.lang.Object implements Serializable

Serialization Methods

readObject

private void readObject(java.io.ObjectInputStream ois)
                 throws java.io.IOException

Throws:

java.io.IOException

writeObject

private void writeObject(java.io.ObjectOutputStream oos)
                  throws java.io.IOException

Throws:

java.io.IOException

Class org.apache.spark.streaming.dstream.DStream$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.dstream.FileInputDStream$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.dstream.InputDStream extends DStream<T> implements Serializable

Class org.apache.spark.streaming.dstream.InternalMapWithStateDStream$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

org$apache$spark$streaming$dstream$InternalMapWithStateDStream$$DEFAULT_CHECKPOINT_DURATION_MULTIPLIER

int org$apache$spark$streaming$dstream$InternalMapWithStateDStream$$DEFAULT_CHECKPOINT_DURATION_MULTIPLIER

Class org.apache.spark.streaming.dstream.MapWithStateDStream extends DStream<MappedType> implements Serializable

Class org.apache.spark.streaming.dstream.PairDStreamFunctions extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.dstream.ReceiverInputDStream extends InputDStream<T> implements Serializable

Class org.apache.spark.streaming.dstream.ShuffledDStream$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.dstream.SocketReceiver$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.streaming.flume

Class org.apache.spark.streaming.flume.SparkFlumeEvent extends java.lang.Object implements Serializable

Serialization Methods

readExternal

public void readExternal(java.io.ObjectInput in)

writeExternal

public void writeExternal(java.io.ObjectOutput out)

Class org.apache.spark.streaming.flume.SparkFlumeEvent$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.streaming.kafka

Class org.apache.spark.streaming.kafka.Broker extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.kafka.Broker$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.kafka.KafkaCluster extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.kafka.KafkaCluster.LeaderOffset extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.kafka.KafkaCluster.LeaderOffset$ extends scala.runtime.AbstractFunction3<java.lang.String,java.lang.Object,java.lang.Object,KafkaCluster.LeaderOffset> implements Serializable

Class org.apache.spark.streaming.kafka.KafkaCluster$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.kafka.KafkaRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.kafka.KafkaUtilsPythonHelper.PythonMessageAndMetadata extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.kafka.KafkaUtilsPythonHelper.PythonMessageAndMetadata$ extends scala.runtime.AbstractFunction5<java.lang.String,java.lang.Integer,java.lang.Long,byte[],byte[],org.apache.spark.streaming.kafka.KafkaUtilsPythonHelper.PythonMessageAndMetadata> implements Serializable

Class org.apache.spark.streaming.kafka.OffsetRange extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.kafka.OffsetRange$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.streaming.kinesis

Class org.apache.spark.streaming.kinesis.KinesisBackedBlockRDD$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.kinesis.SequenceNumberRange$ extends scala.runtime.AbstractFunction4<java.lang.String,java.lang.String,java.lang.String,java.lang.String,org.apache.spark.streaming.kinesis.SequenceNumberRange> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.kinesis.SequenceNumberRanges$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.kinesis.SerializableAWSCredentials$ extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.String,org.apache.spark.streaming.kinesis.SerializableAWSCredentials> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.streaming.receiver

Class org.apache.spark.streaming.receiver.ArrayBufferBlock$ extends scala.runtime.AbstractFunction1<scala.collection.mutable.ArrayBuffer<?>,org.apache.spark.streaming.receiver.ArrayBufferBlock> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.receiver.BlockManagerBasedStoreResult$ extends scala.runtime.AbstractFunction2<StreamBlockId,scala.Option<java.lang.Object>,org.apache.spark.streaming.receiver.BlockManagerBasedStoreResult> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.receiver.ByteBufferBlock$ extends scala.runtime.AbstractFunction1<java.nio.ByteBuffer,org.apache.spark.streaming.receiver.ByteBufferBlock> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.receiver.CleanupOldBlocks$ extends scala.runtime.AbstractFunction1<Time,org.apache.spark.streaming.receiver.CleanupOldBlocks> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.receiver.IteratorBlock$ extends scala.runtime.AbstractFunction1<scala.collection.Iterator<?>,org.apache.spark.streaming.receiver.IteratorBlock> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.receiver.Receiver extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.receiver.ReceiverSupervisor.ReceiverState extends scala.Enumeration implements Serializable

Class org.apache.spark.streaming.receiver.StopReceiver$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.receiver.UpdateRateLimit$ extends scala.runtime.AbstractFunction1<java.lang.Object,org.apache.spark.streaming.receiver.UpdateRateLimit> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.receiver.WriteAheadLogBasedStoreResult$ extends scala.runtime.AbstractFunction3<StreamBlockId,scala.Option<java.lang.Object>,WriteAheadLogRecordHandle,org.apache.spark.streaming.receiver.WriteAheadLogBasedStoreResult> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.streaming.scheduler

Class org.apache.spark.streaming.scheduler.AddBlock$ extends scala.runtime.AbstractFunction1<org.apache.spark.streaming.scheduler.ReceivedBlockInfo,org.apache.spark.streaming.scheduler.AddBlock> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.AllocatedBlocks$ extends scala.runtime.AbstractFunction1<scala.collection.immutable.Map<java.lang.Object,scala.collection.Seq<org.apache.spark.streaming.scheduler.ReceivedBlockInfo>>,org.apache.spark.streaming.scheduler.AllocatedBlocks> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.AllReceiverIds$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.BatchAllocationEvent$ extends scala.runtime.AbstractFunction2<Time,org.apache.spark.streaming.scheduler.AllocatedBlocks,org.apache.spark.streaming.scheduler.BatchAllocationEvent> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.BatchCleanupEvent$ extends scala.runtime.AbstractFunction1<scala.collection.Seq<Time>,org.apache.spark.streaming.scheduler.BatchCleanupEvent> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.BatchInfo extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.scheduler.BatchInfo$ extends scala.runtime.AbstractFunction6<Time,scala.collection.immutable.Map<java.lang.Object,StreamInputInfo>,java.lang.Object,scala.Option<java.lang.Object>,scala.Option<java.lang.Object>,scala.collection.immutable.Map<java.lang.Object,OutputOperationInfo>,BatchInfo> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.BlockAdditionEvent$ extends scala.runtime.AbstractFunction1<org.apache.spark.streaming.scheduler.ReceivedBlockInfo,org.apache.spark.streaming.scheduler.BlockAdditionEvent> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.ClearCheckpointData$ extends scala.runtime.AbstractFunction1<Time,org.apache.spark.streaming.scheduler.ClearCheckpointData> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.ClearMetadata$ extends scala.runtime.AbstractFunction1<Time,org.apache.spark.streaming.scheduler.ClearMetadata> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.DeregisterReceiver$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.String,java.lang.String,org.apache.spark.streaming.scheduler.DeregisterReceiver> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.DoCheckpoint$ extends scala.runtime.AbstractFunction2<Time,java.lang.Object,org.apache.spark.streaming.scheduler.DoCheckpoint> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.ErrorReported$ extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.Throwable,org.apache.spark.streaming.scheduler.ErrorReported> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.GenerateJobs$ extends scala.runtime.AbstractFunction1<Time,org.apache.spark.streaming.scheduler.GenerateJobs> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.GetAllReceiverInfo$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.JobCompleted$ extends scala.runtime.AbstractFunction2<org.apache.spark.streaming.scheduler.Job,java.lang.Object,org.apache.spark.streaming.scheduler.JobCompleted> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.JobSet$ extends scala.runtime.AbstractFunction3<Time,scala.collection.Seq<org.apache.spark.streaming.scheduler.Job>,scala.collection.immutable.Map<java.lang.Object,StreamInputInfo>,org.apache.spark.streaming.scheduler.JobSet> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.JobStarted$ extends scala.runtime.AbstractFunction2<org.apache.spark.streaming.scheduler.Job,java.lang.Object,org.apache.spark.streaming.scheduler.JobStarted> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.OutputOperationInfo extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.scheduler.OutputOperationInfo$ extends scala.runtime.AbstractFunction7<Time,java.lang.Object,java.lang.String,java.lang.String,scala.Option<java.lang.Object>,scala.Option<java.lang.Object>,scala.Option<java.lang.String>,OutputOperationInfo> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.RateController$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.ReceivedBlockInfo$ extends scala.runtime.AbstractFunction4<java.lang.Object,scala.Option<java.lang.Object>,scala.Option<java.lang.Object>,org.apache.spark.streaming.receiver.ReceivedBlockStoreResult,org.apache.spark.streaming.scheduler.ReceivedBlockInfo> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.ReceiverErrorInfo$ extends scala.runtime.AbstractFunction3<java.lang.String,java.lang.String,java.lang.Object,org.apache.spark.streaming.scheduler.ReceiverErrorInfo> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.ReceiverInfo extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.scheduler.ReceiverInfo$ extends scala.runtime.AbstractFunction8<java.lang.Object,java.lang.String,java.lang.Object,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.Object,ReceiverInfo> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.ReceiverState$ extends scala.Enumeration implements Serializable

Serialized Fields

INACTIVE

scala.Enumeration.Value INACTIVE

SCHEDULED

scala.Enumeration.Value SCHEDULED

ACTIVE

scala.Enumeration.Value ACTIVE

Class org.apache.spark.streaming.scheduler.ReceiverTracker.TrackerState$ extends scala.Enumeration implements Serializable

Class org.apache.spark.streaming.scheduler.ReceiverTrackingInfo$ extends scala.runtime.AbstractFunction7<java.lang.Object,scala.Enumeration.Value,scala.Option<scala.collection.Seq<org.apache.spark.scheduler.TaskLocation>>,scala.Option<org.apache.spark.scheduler.ExecutorCacheTaskLocation>,scala.Option<java.lang.String>,scala.Option<org.apache.spark.rpc.RpcEndpointRef>,scala.Option<org.apache.spark.streaming.scheduler.ReceiverErrorInfo>,org.apache.spark.streaming.scheduler.ReceiverTrackingInfo> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.RegisterReceiver$ extends scala.runtime.AbstractFunction5<java.lang.Object,java.lang.String,java.lang.String,java.lang.String,org.apache.spark.rpc.RpcEndpointRef,org.apache.spark.streaming.scheduler.RegisterReceiver> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.ReportError$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.String,java.lang.String,org.apache.spark.streaming.scheduler.ReportError> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.RestartReceiver$ extends scala.runtime.AbstractFunction1<Receiver<?>,org.apache.spark.streaming.scheduler.RestartReceiver> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.StartAllReceivers$ extends scala.runtime.AbstractFunction1<scala.collection.Seq<Receiver<?>>,org.apache.spark.streaming.scheduler.StartAllReceivers> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.StopAllReceivers$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.StreamingListenerBatchCompleted extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.scheduler.StreamingListenerBatchCompleted$ extends scala.runtime.AbstractFunction1<BatchInfo,StreamingListenerBatchCompleted> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.StreamingListenerBatchStarted extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.scheduler.StreamingListenerBatchStarted$ extends scala.runtime.AbstractFunction1<BatchInfo,StreamingListenerBatchStarted> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.StreamingListenerBatchSubmitted extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.scheduler.StreamingListenerBatchSubmitted$ extends scala.runtime.AbstractFunction1<BatchInfo,StreamingListenerBatchSubmitted> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.StreamingListenerOutputOperationCompleted extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.scheduler.StreamingListenerOutputOperationCompleted$ extends scala.runtime.AbstractFunction1<OutputOperationInfo,StreamingListenerOutputOperationCompleted> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.StreamingListenerOutputOperationStarted extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.scheduler.StreamingListenerOutputOperationStarted$ extends scala.runtime.AbstractFunction1<OutputOperationInfo,StreamingListenerOutputOperationStarted> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.StreamingListenerReceiverError extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.scheduler.StreamingListenerReceiverError$ extends scala.runtime.AbstractFunction1<ReceiverInfo,StreamingListenerReceiverError> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.StreamingListenerReceiverStarted extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.scheduler.StreamingListenerReceiverStarted$ extends scala.runtime.AbstractFunction1<ReceiverInfo,StreamingListenerReceiverStarted> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.StreamingListenerReceiverStopped extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.scheduler.StreamingListenerReceiverStopped$ extends scala.runtime.AbstractFunction1<ReceiverInfo,StreamingListenerReceiverStopped> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.scheduler.StreamInputInfo extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.scheduler.StreamInputInfo$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

METADATA_KEY_DESCRIPTION

java.lang.String METADATA_KEY_DESCRIPTION

Class org.apache.spark.streaming.scheduler.UpdateReceiverRateLimit$ extends scala.runtime.AbstractFunction2<java.lang.Object,java.lang.Object,org.apache.spark.streaming.scheduler.UpdateReceiverRateLimit> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.streaming.ui

Class org.apache.spark.streaming.ui.BatchUIData$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.ui.OutputOperationUIData$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.ui.OutputOpIdAndSparkJobId$ extends scala.runtime.AbstractFunction2<java.lang.Object,java.lang.Object,org.apache.spark.streaming.ui.OutputOpIdAndSparkJobId> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.ui.SparkJobIdWithUIData$ extends scala.runtime.AbstractFunction2<java.lang.Object,scala.Option<UIData.JobUIData>,org.apache.spark.streaming.ui.SparkJobIdWithUIData> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.streaming.util

Class org.apache.spark.streaming.util.BatchedWriteAheadLog.Record extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.util.BatchedWriteAheadLog.Record$ extends scala.runtime.AbstractFunction3<java.nio.ByteBuffer,java.lang.Object,scala.concurrent.Promise<WriteAheadLogRecordHandle>,org.apache.spark.streaming.util.BatchedWriteAheadLog.Record> implements Serializable

Class org.apache.spark.streaming.util.FileBasedWriteAheadLog.LogInfo extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.util.FileBasedWriteAheadLog.LogInfo$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.Object,java.lang.String,org.apache.spark.streaming.util.FileBasedWriteAheadLog.LogInfo> implements Serializable

Class org.apache.spark.streaming.util.FileBasedWriteAheadLogSegment$ extends scala.runtime.AbstractFunction3<java.lang.String,java.lang.Object,java.lang.Object,org.apache.spark.streaming.util.FileBasedWriteAheadLogSegment> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.util.OpenHashMapBasedStateMap.LimitMarker extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.util.OpenHashMapBasedStateMap.StateInfo extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.util.OpenHashMapBasedStateMap.StateInfo$ extends java.lang.Object implements Serializable

Class org.apache.spark.streaming.util.OpenHashMapBasedStateMap$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

DELTA_CHAIN_LENGTH_THRESHOLD

int DELTA_CHAIN_LENGTH_THRESHOLD

DEFAULT_INITIAL_CAPACITY

int DEFAULT_INITIAL_CAPACITY

Class org.apache.spark.streaming.util.StateMap$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.streaming.util.WriteAheadLogRecordHandle extends java.lang.Object implements Serializable

Package org.apache.spark.ui

Class org.apache.spark.ui.PageData$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ui.ServerInfo$ extends scala.runtime.AbstractFunction3<org.eclipse.jetty.server.Server,java.lang.Object,org.eclipse.jetty.server.handler.ContextHandlerCollection,org.apache.spark.ui.ServerInfo> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.ui.exec

Class org.apache.spark.ui.exec.ExecutorSummaryInfo$ extends scala.runtime.AbstractFunction15<java.lang.String,java.lang.String,java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object,scala.collection.immutable.Map<java.lang.String,java.lang.String>,org.apache.spark.ui.exec.ExecutorSummaryInfo> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.ui.jobs

Class org.apache.spark.ui.jobs.TaskTableRowBytesSpilledData$ extends scala.runtime.AbstractFunction4<java.lang.Object,java.lang.String,java.lang.Object,java.lang.String,org.apache.spark.ui.jobs.TaskTableRowBytesSpilledData> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ui.jobs.TaskTableRowInputData$ extends scala.runtime.AbstractFunction2<java.lang.Object,java.lang.String,org.apache.spark.ui.jobs.TaskTableRowInputData> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ui.jobs.TaskTableRowOutputData$ extends scala.runtime.AbstractFunction2<java.lang.Object,java.lang.String,org.apache.spark.ui.jobs.TaskTableRowOutputData> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ui.jobs.TaskTableRowShuffleReadData$ extends scala.runtime.AbstractFunction6<java.lang.Object,java.lang.String,java.lang.Object,java.lang.String,java.lang.Object,java.lang.String,org.apache.spark.ui.jobs.TaskTableRowShuffleReadData> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.ui.jobs.TaskTableRowShuffleWriteData$ extends scala.runtime.AbstractFunction4<java.lang.Object,java.lang.String,java.lang.Object,java.lang.String,org.apache.spark.ui.jobs.TaskTableRowShuffleWriteData> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.ui.storage

Class org.apache.spark.ui.storage.BlockTableRowData$ extends scala.runtime.AbstractFunction5<java.lang.String,java.lang.String,java.lang.Object,java.lang.Object,java.lang.String,org.apache.spark.ui.storage.BlockTableRowData> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.util

Class org.apache.spark.util.AccumulatorMetadata$ extends scala.runtime.AbstractFunction3<java.lang.Object,scala.Option<java.lang.String>,java.lang.Object,org.apache.spark.util.AccumulatorMetadata> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.util.AccumulatorV2 extends java.lang.Object implements Serializable

Serialization Methods

readObject

private void readObject(java.io.ObjectInputStream in)

writeReplace

protected final java.lang.Object writeReplace()

Class org.apache.spark.util.Benchmark.Case extends java.lang.Object implements Serializable

Class org.apache.spark.util.Benchmark.Case$ extends scala.runtime.AbstractFunction3<java.lang.String,scala.Function1<org.apache.spark.util.Benchmark.Timer,scala.runtime.BoxedUnit>,java.lang.Object,org.apache.spark.util.Benchmark.Case> implements Serializable

Class org.apache.spark.util.Benchmark.Result extends java.lang.Object implements Serializable

Class org.apache.spark.util.Benchmark.Result$ extends scala.runtime.AbstractFunction3<java.lang.Object,java.lang.Object,java.lang.Object,org.apache.spark.util.Benchmark.Result> implements Serializable

Class org.apache.spark.util.CallSite$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

SHORT_FORM

java.lang.String SHORT_FORM

LONG_FORM

java.lang.String LONG_FORM

empty

org.apache.spark.util.CallSite empty

Class org.apache.spark.util.DoubleAccumulator extends AccumulatorV2<java.lang.Double,java.lang.Double> implements Serializable

Class org.apache.spark.util.LegacyAccumulatorWrapper extends AccumulatorV2<T,R> implements Serializable

Class org.apache.spark.util.ListAccumulator extends AccumulatorV2<T,java.util.List<T>> implements Serializable

Class org.apache.spark.util.LongAccumulator extends AccumulatorV2<java.lang.Long,java.lang.Long> implements Serializable

Class org.apache.spark.util.MethodIdentifier extends java.lang.Object implements Serializable

Class org.apache.spark.util.MethodIdentifier$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.util.MutablePair extends java.lang.Object implements Serializable

Class org.apache.spark.util.MutablePair$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.util.MutablePair$mcCC$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcC$sp

char _1$mcC$sp

_2$mcC$sp

char _2$mcC$sp

Class org.apache.spark.util.MutablePair$mcCD$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcC$sp

char _1$mcC$sp

_2$mcD$sp

double _2$mcD$sp

Class org.apache.spark.util.MutablePair$mcCI$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcC$sp

char _1$mcC$sp

_2$mcI$sp

int _2$mcI$sp

Class org.apache.spark.util.MutablePair$mcCJ$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcC$sp

char _1$mcC$sp

_2$mcJ$sp

long _2$mcJ$sp

Class org.apache.spark.util.MutablePair$mcCZ$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcC$sp

char _1$mcC$sp

_2$mcZ$sp

boolean _2$mcZ$sp

Class org.apache.spark.util.MutablePair$mcDC$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcD$sp

double _1$mcD$sp

_2$mcC$sp

char _2$mcC$sp

Class org.apache.spark.util.MutablePair$mcDD$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcD$sp

double _1$mcD$sp

_2$mcD$sp

double _2$mcD$sp

Class org.apache.spark.util.MutablePair$mcDI$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcD$sp

double _1$mcD$sp

_2$mcI$sp

int _2$mcI$sp

Class org.apache.spark.util.MutablePair$mcDJ$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcD$sp

double _1$mcD$sp

_2$mcJ$sp

long _2$mcJ$sp

Class org.apache.spark.util.MutablePair$mcDZ$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcD$sp

double _1$mcD$sp

_2$mcZ$sp

boolean _2$mcZ$sp

Class org.apache.spark.util.MutablePair$mcIC$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcI$sp

int _1$mcI$sp

_2$mcC$sp

char _2$mcC$sp

Class org.apache.spark.util.MutablePair$mcID$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcI$sp

int _1$mcI$sp

_2$mcD$sp

double _2$mcD$sp

Class org.apache.spark.util.MutablePair$mcII$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcI$sp

int _1$mcI$sp

_2$mcI$sp

int _2$mcI$sp

Class org.apache.spark.util.MutablePair$mcIJ$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcI$sp

int _1$mcI$sp

_2$mcJ$sp

long _2$mcJ$sp

Class org.apache.spark.util.MutablePair$mcIZ$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcI$sp

int _1$mcI$sp

_2$mcZ$sp

boolean _2$mcZ$sp

Class org.apache.spark.util.MutablePair$mcJC$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcJ$sp

long _1$mcJ$sp

_2$mcC$sp

char _2$mcC$sp

Class org.apache.spark.util.MutablePair$mcJD$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcJ$sp

long _1$mcJ$sp

_2$mcD$sp

double _2$mcD$sp

Class org.apache.spark.util.MutablePair$mcJI$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcJ$sp

long _1$mcJ$sp

_2$mcI$sp

int _2$mcI$sp

Class org.apache.spark.util.MutablePair$mcJJ$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcJ$sp

long _1$mcJ$sp

_2$mcJ$sp

long _2$mcJ$sp

Class org.apache.spark.util.MutablePair$mcJZ$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcJ$sp

long _1$mcJ$sp

_2$mcZ$sp

boolean _2$mcZ$sp

Class org.apache.spark.util.MutablePair$mcZC$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcZ$sp

boolean _1$mcZ$sp

_2$mcC$sp

char _2$mcC$sp

Class org.apache.spark.util.MutablePair$mcZD$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcZ$sp

boolean _1$mcZ$sp

_2$mcD$sp

double _2$mcD$sp

Class org.apache.spark.util.MutablePair$mcZI$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcZ$sp

boolean _1$mcZ$sp

_2$mcI$sp

int _2$mcI$sp

Class org.apache.spark.util.MutablePair$mcZJ$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcZ$sp

boolean _1$mcZ$sp

_2$mcJ$sp

long _2$mcJ$sp

Class org.apache.spark.util.MutablePair$mcZZ$sp extends MutablePair<java.lang.Object,java.lang.Object> implements Serializable

Serialized Fields

_1$mcZ$sp

boolean _1$mcZ$sp

_2$mcZ$sp

boolean _2$mcZ$sp

Class org.apache.spark.util.StatCounter extends java.lang.Object implements Serializable

Class org.apache.spark.util.StatCounter$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.util.TaskCompletionListenerException$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.util.ThreadStackTrace$ extends scala.runtime.AbstractFunction4<java.lang.Object,java.lang.String,java.lang.Thread.State,java.lang.String,org.apache.spark.util.ThreadStackTrace> implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.util.TimeStampedValue$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.util.random

Class org.apache.spark.util.random.AcceptanceResult$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.util.random.BernoulliCellSampler extends java.lang.Object implements Serializable

Class org.apache.spark.util.random.BernoulliCellSampler$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.util.random.BernoulliSampler extends java.lang.Object implements Serializable

Class org.apache.spark.util.random.GapSampling$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.util.random.GapSamplingReplacement$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Class org.apache.spark.util.random.PoissonSampler extends java.lang.Object implements Serializable

Class org.apache.spark.util.random.RandomSampler$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Serialized Fields

defaultMaxGapSamplingFraction

double defaultMaxGapSamplingFraction

rngEpsilon

double rngEpsilon

roundingEpsilon

double roundingEpsilon

Class org.apache.spark.util.random.XORShiftRandom$ extends java.lang.Object implements Serializable

Serialization Methods

readResolve

private java.lang.Object readResolve()

Package org.apache.spark.util.sketch

Class org.apache.spark.util.sketch.IncompatibleMergeException extends java.lang.Exception implements Serializable