org.elasticsearch.spark.sql

Class ScalaEsRowRDDIterator

java.lang.Object

<any>

org.elasticsearch.spark.sql.ScalaEsRowRDDIterator

public class ScalaEsRowRDDIterator
extends <any>

Constructor Summary

Constructors

Constructor and Description
ScalaEsRowRDDIterator(org.apache.spark.TaskContext context, org.elasticsearch.hadoop.rest.PartitionDefinition partition, SchemaUtils.Schema schema)

Method Summary

Modifier and Type	Method and Description
org.apache.spark.sql.Row	createValue(java.lang.Object[] value)
org.apache.commons.logging.Log	getLogger()
void	initReader(Settings settings, org.apache.commons.logging.Log log)

Methods inherited from class java.lang.Object

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

Constructor Detail

ScalaEsRowRDDIterator

public ScalaEsRowRDDIterator(org.apache.spark.TaskContext context,
                             org.elasticsearch.hadoop.rest.PartitionDefinition partition,
                             SchemaUtils.Schema schema)

Method Detail

createValue

public org.apache.spark.sql.Row createValue(java.lang.Object[] value)

getLogger

public org.apache.commons.logging.Log getLogger()

initReader

public void initReader(Settings settings,
                       org.apache.commons.logging.Log log)