Uses of Class
org.apache.wayang.basic.operators.LocalCallbackSink

Packages that use LocalCallbackSink

Package	Description
org.apache.wayang.basic.operators
org.apache.wayang.flink.operators
org.apache.wayang.java.operators
org.apache.wayang.spark.operators

Uses of LocalCallbackSink in org.apache.wayang.basic.operators

Methods in org.apache.wayang.basic.operators that return LocalCallbackSink

Modifier and Type	Method	Description
static <T> LocalCallbackSink<T>	LocalCallbackSink.createCollectingSink(java.util.Collection<T> collector, java.lang.Class<T> typeClass)
static <T> LocalCallbackSink<T>	LocalCallbackSink.createCollectingSink(java.util.Collection<T> collector, DataSetType<T> type)
static <T> LocalCallbackSink<T>	LocalCallbackSink.createStdoutSink(java.lang.Class<T> typeClass)
static <T> LocalCallbackSink<T>	LocalCallbackSink.createStdoutSink(DataSetType<T> type)
LocalCallbackSink<T>	LocalCallbackSink.setCollector(java.util.Collection<T> collector)

Constructors in org.apache.wayang.basic.operators with parameters of type LocalCallbackSink

Constructor	Description
LocalCallbackSink(LocalCallbackSink<T> that)	Copies an instance (exclusive of broadcasts).

Uses of LocalCallbackSink in org.apache.wayang.flink.operators

Subclasses of LocalCallbackSink in org.apache.wayang.flink.operators

Modifier and Type	Class	Description
class	FlinkLocalCallbackSink<Type extends java.io.Serializable>	Implementation of the LocalCallbackSink operator for the Flink platform.

Constructors in org.apache.wayang.flink.operators with parameters of type LocalCallbackSink

Constructor	Description
FlinkLocalCallbackSink(LocalCallbackSink<Type> that)	Copies an instance (exclusive of broadcasts).

Uses of LocalCallbackSink in org.apache.wayang.java.operators

Subclasses of LocalCallbackSink in org.apache.wayang.java.operators

Modifier and Type	Class	Description
class	JavaLocalCallbackSink<T extends java.io.Serializable>	Implementation of the LocalCallbackSink operator for the Java platform.

Constructors in org.apache.wayang.java.operators with parameters of type LocalCallbackSink

Constructor	Description
JavaLocalCallbackSink(LocalCallbackSink<T> that)	Copies an instance (exclusive of broadcasts).

Uses of LocalCallbackSink in org.apache.wayang.spark.operators

Subclasses of LocalCallbackSink in org.apache.wayang.spark.operators

Modifier and Type	Class	Description
class	SparkLocalCallbackSink<T extends java.io.Serializable>	Implementation of the LocalCallbackSink operator for the Spark platform.

Constructors in org.apache.wayang.spark.operators with parameters of type LocalCallbackSink

Constructor	Description
SparkLocalCallbackSink(LocalCallbackSink<T> that)	Copies an instance (exclusive of broadcasts).