private Object readResolve()
int rddId
int idx
org.elasticsearch.hadoop.rest.PartitionDefinition esPartition
int index
private Object readResolve()
private Object readResolve()
private Object readResolve()
org.apache.spark.sql.Dataset<T> df
org.apache.spark.sql.Dataset<T> ds
org.apache.spark.sql.SparkSession ss
org.apache.spark.sql.SQLContext sc
org.apache.spark.streaming.dstream.DStream<T> ds
org.apache.spark.streaming.dstream.DStream<T> ds
org.apache.spark.streaming.dstream.DStream<T> ds