public class ScalaEsRowRDDIterator
extends org.elasticsearch.spark.rdd.AbstractEsRDDIterator<org.apache.spark.sql.Row>
| 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(Object[] value) |
org.apache.commons.logging.Log |
getLogger() |
void |
initReader(Settings settings,
org.apache.commons.logging.Log log) |
$colon$bslash, $div$colon, $plus$plus, addString, addString, addString, aggregate, buffered, close, closeIfNeeded, collect, collectFirst, concat, contains, context, copyToArray, copyToArray, copyToArray, copyToBuffer, corresponds, count, distinct, distinctBy, drop, dropWhile, duplicate, exists, filter, filterImpl, filterNot, find, finished_$eq, finished, flatMap, flatten, fold, foldLeft, foldRight, forall, foreach, grouped, hasDefiniteSize, hasNext, indexOf, indexOf, indexWhere, indexWhere$default$2, isEmpty, isTraversableAgain, iterator, knownSize, length, map, max, maxBy, maxByOption, maxOption, min, minBy, minByOption, minOption, mkString, mkString, mkString, next, nextOption, nonEmpty, padTo, partition, patch, product, reader, reduce, reduceLeft, reduceLeftOption, reduceOption, reduceRight, reduceRightOption, reversed, sameElements, scanLeft, scanRight, seq, size, slice, sliceIterator, sliding, sliding$default$2, span, splitAt, stepper, sum, take, takeWhile, tapEach, to, toArray, toBuffer, toIndexedSeq, toIterator, toList, toMap, toSeq, toSet, toStream, toString, toVector, withFilter, zip, zipAll, zipWithIndexclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitpublic ScalaEsRowRDDIterator(org.apache.spark.TaskContext context,
org.elasticsearch.hadoop.rest.PartitionDefinition partition,
SchemaUtils.Schema schema)
public org.apache.spark.sql.Row createValue(Object[] value)
createValue in class org.elasticsearch.spark.rdd.AbstractEsRDDIterator<org.apache.spark.sql.Row>public org.apache.commons.logging.Log getLogger()
getLogger in class org.elasticsearch.spark.rdd.AbstractEsRDDIterator<org.apache.spark.sql.Row>public void initReader(Settings settings, org.apache.commons.logging.Log log)
initReader in class org.elasticsearch.spark.rdd.AbstractEsRDDIterator<org.apache.spark.sql.Row>