public class KafkaUtilsPythonHelper
extends Object
The zero-arg constructor helps instantiate this class from the Class object classOf[KafkaUtilsPythonHelper].newInstance(), and the createStream() takes care of known parameters instead of passing them from Python
Constructor and Description |
---|
KafkaUtilsPythonHelper() |
Modifier and Type | Method and Description |
---|---|
JavaPairReceiverInputDStream<byte[],byte[]> |
createStream(JavaStreamingContext jssc,
java.util.Map<String,String> kafkaParams,
java.util.Map<String,Integer> topics,
StorageLevel storageLevel) |
public JavaPairReceiverInputDStream<byte[],byte[]> createStream(JavaStreamingContext jssc, java.util.Map<String,String> kafkaParams, java.util.Map<String,Integer> topics, StorageLevel storageLevel)