public class KinesisUtilsPythonHelper
extends Object
Constructor and Description |
---|
KinesisUtilsPythonHelper() |
Modifier and Type | Method and 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) |
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)