Package org.apache.spark.streaming.kinesis

Class KinesisUtilsPythonHelper

Object

org.apache.spark.streaming.kinesis.KinesisUtilsPythonHelper

public class KinesisUtilsPythonHelper
extends Object

This is a helper class that wraps the methods in KinesisUtils into more Python-friendly class and function so that it can be easily instantiated and called from Python's KinesisUtils.

Constructor Summary

Constructors

Constructor	Description
KinesisUtilsPythonHelper()

Method Summary

Modifier and Type	Method	Description
JavaReceiverInputDStream<byte[]>	createStream(JavaStreamingContext jssc, String kinesisAppName, String streamName, String endpointUrl, String regionName, int initialPositionInStream, Duration checkpointInterval, int metricsLevel, StorageLevel storageLevel, String awsAccessKeyId, String awsSecretKey, String stsAssumeRoleArn, String stsSessionName, String stsExternalId)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KinesisUtilsPythonHelper

public KinesisUtilsPythonHelper()

Method Details

createStream

public JavaReceiverInputDStream<byte[]> createStream(JavaStreamingContext jssc,
 String kinesisAppName,
 String streamName,
 String endpointUrl,
 String regionName,
 int initialPositionInStream,
 Duration checkpointInterval,
 int metricsLevel,
 StorageLevel storageLevel,
 String awsAccessKeyId,
 String awsSecretKey,
 String stsAssumeRoleArn,
 String stsSessionName,
 String stsExternalId)