Uses of Class
org.apache.wayang.basic.operators.CollectionSource
-
-
Uses of CollectionSource in org.apache.wayang.basic.operators
Methods in org.apache.wayang.basic.operators that return CollectionSource Modifier and Type Method Description static <T> CollectionSource<T>
CollectionSource. empty(java.lang.Class<T> typeClass)
Creates a new instance without any data quanta.static <T> CollectionSource<T>
CollectionSource. singleton(T value, java.lang.Class<T> typeClass)
Creates a new instance without any data quanta.Constructors in org.apache.wayang.basic.operators with parameters of type CollectionSource Constructor Description CollectionSource(CollectionSource that)
Copies an instance (exclusive of broadcasts). -
Uses of CollectionSource in org.apache.wayang.flink.operators
Subclasses of CollectionSource in org.apache.wayang.flink.operators Modifier and Type Class Description class
FlinkCollectionSource<Type>
This is execution operator implements theCollectionSource
.Constructors in org.apache.wayang.flink.operators with parameters of type CollectionSource Constructor Description FlinkCollectionSource(CollectionSource<Type> that)
Copies an instance (exclusive of broadcasts). -
Uses of CollectionSource in org.apache.wayang.java.operators
Subclasses of CollectionSource in org.apache.wayang.java.operators Modifier and Type Class Description class
JavaCollectionSource<T>
This is execution operator implements theTextFileSource
.Constructors in org.apache.wayang.java.operators with parameters of type CollectionSource Constructor Description JavaCollectionSource(CollectionSource<T> that)
Copies an instance (exclusive of broadcasts). -
Uses of CollectionSource in org.apache.wayang.spark.operators
Subclasses of CollectionSource in org.apache.wayang.spark.operators Modifier and Type Class Description class
SparkCollectionSource<Type>
Provides aCollection
to a Spark job.Constructors in org.apache.wayang.spark.operators with parameters of type CollectionSource Constructor Description SparkCollectionSource(CollectionSource that)
Copies an instance (exclusive of broadcasts). -
Uses of CollectionSource in org.apache.wayang.tensorflow.operators
Subclasses of CollectionSource in org.apache.wayang.tensorflow.operators Modifier and Type Class Description class
TensorflowCollectionSource<Type>
Provides aCollection
to a Tensorflow job.Constructors in org.apache.wayang.tensorflow.operators with parameters of type CollectionSource Constructor Description TensorflowCollectionSource(CollectionSource that)
-