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

Modifier	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

Modifier	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

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