public class ScalaEsRowRDDIterator
extends <any>
| Constructor and Description |
|---|
ScalaEsRowRDDIterator(org.apache.spark.TaskContext context,
org.elasticsearch.hadoop.rest.PartitionDefinition partition,
SchemaUtils.Schema schema) |
| 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) |
public ScalaEsRowRDDIterator(org.apache.spark.TaskContext context,
org.elasticsearch.hadoop.rest.PartitionDefinition partition,
SchemaUtils.Schema schema)
public org.apache.spark.sql.Row createValue(java.lang.Object[] value)
public org.apache.commons.logging.Log getLogger()
public void initReader(Settings settings, org.apache.commons.logging.Log log)