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(Collection<T> collector, Class<T> typeClass)
static <T> LocalCallbackSink<T>	LocalCallbackSink.createCollectingSink(Collection<T> collector, DataSetType<T> type)
static <T> LocalCallbackSink<T>	LocalCallbackSink.createStdoutSink(Class<T> typeClass)
static <T> LocalCallbackSink<T>	LocalCallbackSink.createStdoutSink(DataSetType<T> type)
LocalCallbackSink<T>	LocalCallbackSink.setCollector(Collection<T> collector)

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

Modifier	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 Serializable>	Implementation of the LocalCallbackSink operator for the Flink platform.

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

Modifier	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 Serializable>	Implementation of the LocalCallbackSink operator for the Java platform.

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

Modifier	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 Serializable>	Implementation of the LocalCallbackSink operator for the Spark platform.

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

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