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

Packages that use KafkaTopicSink

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

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

Methods in org.apache.wayang.basic.operators with parameters of type KafkaTopicSink

Modifier and Type	Method	Description
void	KafkaTopicSink.initProducer(KafkaTopicSink<T> kts)

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

Constructor	Description
KafkaTopicSink(KafkaTopicSink<T> that)	Creates a copied instance.

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

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

Modifier and Type	Class	Description
class	JavaKafkaTopicSink<T>	Implementation fo the KafkaTopicSink for the JavaPlatform.

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

Constructor	Description
JavaKafkaTopicSink(KafkaTopicSink<T> that)

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

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

Modifier and Type	Class	Description
class	SparkKafkaTopicSink<T>	Implementation of the KafkaTopicSink operator for the Spark platform.

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

Constructor	Description
SparkKafkaTopicSink(KafkaTopicSink<T> that)