org.elasticsearch.spark.sql

Class ScalaEsRowRDD

java.lang.Object

<any>

org.elasticsearch.spark.sql.ScalaEsRowRDD

public class ScalaEsRowRDD
extends <any>

Constructor Summary

Constructors

Constructor and Description
ScalaEsRowRDD(org.apache.spark.SparkContext sc, scala.collection.Map<java.lang.String,java.lang.String> params, SchemaUtils.Schema schema)

Method Summary

Modifier and Type	Method and Description
ScalaEsRowRDDIterator	compute(org.apache.spark.Partition split, org.apache.spark.TaskContext context)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ScalaEsRowRDD

public ScalaEsRowRDD(org.apache.spark.SparkContext sc,
                     scala.collection.Map<java.lang.String,java.lang.String> params,
                     SchemaUtils.Schema schema)

Method Detail

compute

public ScalaEsRowRDDIterator compute(org.apache.spark.Partition split,
                                     org.apache.spark.TaskContext context)