Serialized Form

Package org.elasticsearch.hadoop

Class org.elasticsearch.hadoop.EsHadoopException extends java.lang.RuntimeException implements Serializable

Class org.elasticsearch.hadoop.EsHadoopIllegalArgumentException extends EsHadoopException implements Serializable

Class org.elasticsearch.hadoop.EsHadoopIllegalStateException extends EsHadoopException implements Serializable

Class org.elasticsearch.hadoop.EsHadoopUnsupportedOperationException extends EsHadoopException implements Serializable

Package org.elasticsearch.hadoop.handler

Class org.elasticsearch.hadoop.handler.EsHadoopAbortHandlerException extends EsHadoopException implements Serializable

Package org.elasticsearch.hadoop.hive

Class org.elasticsearch.hadoop.hive.HiveBytesArrayWritable extends BinaryComparable implements Serializable

Class org.elasticsearch.hadoop.hive.HiveBytesArrayWritable.Comparator extends WritableComparator implements Serializable

Package org.elasticsearch.hadoop.security

Class org.elasticsearch.hadoop.security.EsHadoopSecurityException extends java.security.GeneralSecurityException implements Serializable

Package org.elasticsearch.spark.sql

Class org.elasticsearch.spark.sql.ElasticsearchRelation extends org.apache.spark.sql.sources.BaseRelation implements Serializable

Class org.elasticsearch.spark.sql.ElasticsearchRelation$ extends scala.runtime.AbstractFunction3<scala.collection.immutable.Map<java.lang.String,java.lang.String>,org.apache.spark.sql.SQLContext,scala.Option<org.apache.spark.sql.types.StructType>,ElasticsearchRelation> implements Serializable

Class org.elasticsearch.spark.sql.package.SparkDataFrameFunctions extends java.lang.Object implements Serializable

Serialized Fields

df

org.apache.spark.sql.Dataset<T> df

Class org.elasticsearch.spark.sql.package.SparkDatasetFunctions extends java.lang.Object implements Serializable

Serialized Fields

ds

org.apache.spark.sql.Dataset<T> ds

Class org.elasticsearch.spark.sql.package.SparkSessionFunctions extends java.lang.Object implements Serializable

Serialized Fields

ss

org.apache.spark.sql.SparkSession ss

Class org.elasticsearch.spark.sql.package.SQLContextFunctions extends java.lang.Object implements Serializable

Serialized Fields

sc

org.apache.spark.sql.SQLContext sc

Class org.elasticsearch.spark.sql.ScalaEsRow extends java.lang.Object implements Serializable

Class org.elasticsearch.spark.sql.ScalaEsRowRDD$ extends java.lang.Object implements Serializable

Class org.elasticsearch.spark.sql.SchemaUtils.Schema extends java.lang.Object implements Serializable

Class org.elasticsearch.spark.sql.SchemaUtils.Schema$ extends scala.runtime.AbstractFunction2<org.elasticsearch.hadoop.serialization.dto.mapping.Mapping,org.apache.spark.sql.types.StructType,SchemaUtils.Schema> implements Serializable

Package org.elasticsearch.spark.sql.streaming

Class org.elasticsearch.spark.sql.streaming.EsCommitProtocol extends java.lang.Object implements Serializable

Class org.elasticsearch.spark.sql.streaming.EsSinkStatus extends java.lang.Object implements Serializable

Class org.elasticsearch.spark.sql.streaming.EsSinkStatus$ extends scala.runtime.AbstractFunction4<java.lang.Object,java.lang.Object,java.lang.String,java.lang.Object,EsSinkStatus> implements Serializable

Class org.elasticsearch.spark.sql.streaming.JobState extends java.lang.Object implements Serializable

Class org.elasticsearch.spark.sql.streaming.JobState$ extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.Object,JobState> implements Serializable

Class org.elasticsearch.spark.sql.streaming.NullMetadataLog extends java.lang.Object implements Serializable

Class org.elasticsearch.spark.sql.streaming.TaskCommit extends java.lang.Object implements Serializable

Class org.elasticsearch.spark.sql.streaming.TaskCommit$ extends scala.runtime.AbstractFunction1<scala.Option<EsSinkStatus>,TaskCommit> implements Serializable

Class org.elasticsearch.spark.sql.streaming.TaskState extends java.lang.Object implements Serializable

Class org.elasticsearch.spark.sql.streaming.TaskState$ extends scala.runtime.AbstractFunction2<java.lang.Object,java.lang.String,TaskState> implements Serializable

Package org.elasticsearch.spark.streaming

Class org.elasticsearch.spark.streaming.package.SparkDStreamFunctions extends java.lang.Object implements Serializable

Serialized Fields

ds

org.apache.spark.streaming.dstream.DStream<T> ds

Class org.elasticsearch.spark.streaming.package.SparkJsonDStreamFunctions extends java.lang.Object implements Serializable

Serialized Fields

ds

org.apache.spark.streaming.dstream.DStream<T> ds

Class org.elasticsearch.spark.streaming.package.SparkPairDStreamFunctions extends java.lang.Object implements Serializable

Serialized Fields

ds

org.apache.spark.streaming.dstream.DStream<T> ds