|
Change Parameter Type subscribedShardsState : LinkedList<KinesisStreamShardState> to subscribedShardsState : List<KinesisStreamShardState> in method protected KinesisDataFetcher(streams List<String>, sourceContext SourceFunction.SourceContext<T>, checkpointLock Object, runtimeContext RuntimeContext, configProps Properties, deserializationSchema KinesisDeserializationSchema<T>, error AtomicReference<Throwable>, subscribedShardsState List<KinesisStreamShardState>, subscribedStreamsToLastDiscoveredShardIds HashMap<String,String>, kinesis KinesisProxyInterface) in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher |
From |
To |