Package | Description |
---|---|
org.apache.flink.streaming.connectors.kinesis | |
org.apache.flink.streaming.connectors.kinesis.internals |
Modifier and Type | Method and Description |
---|---|
protected KinesisDataFetcher<T> |
FlinkKinesisConsumer.createFetcher(List<String> streams,
SourceFunction.SourceContext<T> sourceContext,
RuntimeContext runtimeContext,
Properties configProps,
KinesisDeserializationSchema<T> deserializationSchema)
This method is exposed for tests that need to mock the KinesisDataFetcher in the consumer.
|
protected KinesisDataFetcher<T> |
FlinkDynamoDBStreamsConsumer.createFetcher(List<String> streams,
SourceFunction.SourceContext<T> sourceContext,
RuntimeContext runtimeContext,
Properties configProps,
KinesisDeserializationSchema<T> deserializationSchema) |
Modifier and Type | Class and Description |
---|---|
class |
DynamoDBStreamsDataFetcher<T>
Dynamodb streams data fetcher.
|
Constructor and Description |
---|
ShardConsumer(KinesisDataFetcher<T> fetcherRef,
RecordPublisher recordPublisher,
Integer subscribedShardStateIndex,
StreamShardHandle subscribedShard,
SequenceNumber lastSequenceNum,
ShardConsumerMetricsReporter shardConsumerMetricsReporter,
KinesisDeserializationSchema<T> shardDeserializer)
Creates a shard consumer.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.