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

Packages that use KafkaTopicSource

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

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

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

Modifier and Type	Method	Description
void	KafkaTopicSource.initConsumer(KafkaTopicSource kts)

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

Constructor	Description
KafkaTopicSource(KafkaTopicSource that)	Copies an instance (exclusive of broadcasts).

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

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

Modifier and Type	Class	Description
class	JavaKafkaTopicSource

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

Constructor	Description
JavaKafkaTopicSource(KafkaTopicSource that)

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

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

Modifier and Type	Class	Description
class	SparkKafkaTopicSource	Provides a Collection to a Spark job.

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

Constructor	Description
SparkKafkaTopicSource(KafkaTopicSource that)	Copies an instance (exclusive of broadcasts).