Uses of Class
org.apache.wayang.basic.operators.CollectionSource
Packages that use CollectionSource
Package
Description
-
Uses of CollectionSource in org.apache.wayang.basic.operators
Methods in org.apache.wayang.basic.operators that return CollectionSourceModifier and TypeMethodDescriptionstatic <T> CollectionSource<T>
Creates a new instance without any data quanta.static <T> CollectionSource<T>
Creates a new instance without any data quanta.Constructors in org.apache.wayang.basic.operators with parameters of type CollectionSourceModifierConstructorDescriptionCopies an instance (exclusive of broadcasts). -
Uses of CollectionSource in org.apache.wayang.flink.operators
Subclasses of CollectionSource in org.apache.wayang.flink.operatorsModifier and TypeClassDescriptionclass
FlinkCollectionSource<Type>
This is execution operator implements theCollectionSource
.Constructors in org.apache.wayang.flink.operators with parameters of type CollectionSourceModifierConstructorDescriptionCopies an instance (exclusive of broadcasts). -
Uses of CollectionSource in org.apache.wayang.java.operators
Subclasses of CollectionSource in org.apache.wayang.java.operatorsConstructors in org.apache.wayang.java.operators with parameters of type CollectionSourceModifierConstructorDescriptionCopies an instance (exclusive of broadcasts). -
Uses of CollectionSource in org.apache.wayang.spark.operators
Subclasses of CollectionSource in org.apache.wayang.spark.operatorsModifier and TypeClassDescriptionclass
SparkCollectionSource<Type>
Provides aCollection
to a Spark job.Constructors in org.apache.wayang.spark.operators with parameters of type CollectionSourceModifierConstructorDescriptionCopies an instance (exclusive of broadcasts). -
Uses of CollectionSource in org.apache.wayang.tensorflow.operators
Subclasses of CollectionSource in org.apache.wayang.tensorflow.operatorsConstructors in org.apache.wayang.tensorflow.operators with parameters of type CollectionSource