KafkaSourceRDD

KafkaSourceRDD is an RDD of Kafka’s ConsumerRecords (with keys and values being collections of bytes, i.e. Array[Byte]).

KafkaSourceRDD is created when:

Placement Preferences of Partition (Preferred Locations) — getPreferredLocations Method

Caution
FIXME

compute Method

Caution
FIXME

getPartitions Method

Caution
FIXME

persist Method

Caution
FIXME

Creating KafkaSourceRDD Instance

KafkaSourceRDD takes the following when created:

KafkaSourceRDD initializes the internal registries and counters.

results matching ""

    No results matching ""