Package | Description |
---|---|
org.apache.storm.kinesis.spout |
Modifier and Type | Method and Description |
---|---|
RecordToTupleMapper |
KinesisConfig.getRecordToTupleMapper() |
Constructor and Description |
---|
KinesisConfig(String streamName,
com.amazonaws.services.kinesis.model.ShardIteratorType shardIteratorType,
RecordToTupleMapper recordToTupleMapper,
Date timestamp,
FailedMessageRetryHandler failedMessageRetryHandler,
ZkInfo zkInfo,
KinesisConnectionInfo kinesisConnectionInfo,
Long maxUncommittedRecords) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.