Modifier and Type | Method and Description |
---|---|
<X> DataSource<X> |
ExecutionEnvironment.fromParallelCollection(SplittableIterator<X> iterator,
Class<X> type)
Creates a new data set that contains elements in the iterator.
|
<X> DataSource<X> |
ExecutionEnvironment.fromParallelCollection(SplittableIterator<X> iterator,
TypeInformation<X> type)
Creates a new data set that contains elements in the iterator.
|
Constructor and Description |
---|
ParallelIteratorInputFormat(SplittableIterator<T> iterator) |
Modifier and Type | Method and Description |
---|---|
<T> DataSet<T> |
ExecutionEnvironment.fromParallelCollection(SplittableIterator<T> iterator,
scala.reflect.ClassTag<T> evidence$16,
TypeInformation<T> evidence$17)
Creates a new data set that contains elements in the iterator.
|
Modifier and Type | Method and Description |
---|---|
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.fromParallelCollection(SplittableIterator<OUT> iterator,
Class<OUT> type)
Creates a new data stream that contains elements in the iterator.
|
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.fromParallelCollection(SplittableIterator<OUT> iterator,
TypeInformation<OUT> typeInfo)
Creates a new data stream that contains elements in the iterator.
|
Constructor and Description |
---|
FromSplittableIteratorFunction(SplittableIterator<T> iterator) |
Modifier and Type | Method and Description |
---|---|
<T> DataStream<T> |
StreamExecutionEnvironment.fromParallelCollection(SplittableIterator<T> data,
TypeInformation<T> evidence$4)
Creates a DataStream from the given
SplittableIterator . |
Modifier and Type | Class and Description |
---|---|
class |
LongValueSequenceIterator
The
LongValueSequenceIterator is an iterator that returns a sequence of numbers (as LongValue )s. |
class |
NumberSequenceIterator
The
NumberSequenceIterator is an iterator that returns a sequence of numbers (as Long )s. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.