public class ScalaEsRowRDDIterator
extends org.elasticsearch.spark.rdd.AbstractEsRDDIterator<org.apache.spark.sql.Row>
scala.collection.Iterator.GroupedIterator<B>, scala.collection.Iterator.SliceIterator<A>scala.collection.TraversableOnce.BufferedCanBuildFrom<A,CC extends scala.collection.TraversableOnce<Object>>, scala.collection.TraversableOnce.FlattenOps<A>, scala.collection.TraversableOnce.ForceImplicitAmbiguity, scala.collection.TraversableOnce.MonadOps<A>, scala.collection.TraversableOnce.OnceCanBuildFrom<A>| 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, contains, context, copyToArray, copyToArray, copyToArray, copyToBuffer, corresponds, count, drop, dropWhile, duplicate, exists, filter, filterNot, find, finished_$eq, finished, flatMap, fold, foldLeft, foldRight, forall, foreach, grouped, hasDefiniteSize, hasNext, indexOf, indexOf, indexWhere, indexWhere, isEmpty, isTraversableAgain, length, map, max, maxBy, min, minBy, mkString, mkString, mkString, next, nonEmpty, padTo, partition, patch, product, reader, reduce, reduceLeft, reduceLeftOption, reduceOption, reduceRight, reduceRightOption, reversed, sameElements, scanLeft, scanRight, seq, size, sizeHintIfCheap, slice, sliceIterator, sliding, sliding$default$2, span, sum, take, takeWhile, to, toArray, toBuffer, toIndexedSeq, toIterable, toIterator, toList, toMap, toSeq, toSet, toStream, toString, toTraversable, toVector, withFilter, zip, zipAll, zipWithIndexclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait$init$, apply, continually, empty, fill, from, from, iterate, IteratorCanBuildFrom, range, range, single, tabulatepublic 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>