|
Rename Parameter fakeTndexOfThisSubtask : int to fakeIndexOfThisSubtask : int in method public TestableKinesisDataFetcher(fakeStreams List<String>, fakeConfiguration Properties, fakeTotalCountOfSubtasks int, fakeIndexOfThisSubtask int, thrownErrorUnderTest AtomicReference<Throwable>, subscribedShardsStateUnderTest LinkedList<KinesisStreamShardState>, subscribedStreamsToLastDiscoveredShardIdsStateUnderTest HashMap<String,String>, fakeKinesis KinesisProxyInterface) in class org.apache.flink.streaming.connectors.kinesis.testutils.TestableKinesisDataFetcher |
From |
To |