|
Move Method public compareShardIds(firstShardId String, secondShardId String) : int from class org.apache.flink.streaming.connectors.kinesis.model.KinesisStreamShard to private compareShardIds(firstShardId String, secondShardId String) : int from class org.apache.flink.streaming.connectors.kinesis.testutils.FakeKinesisBehavioursFactory.NonReshardedStreamsKinesis |
From |
To |
|
Move Method public isValidShardId(shardId String) : boolean from class org.apache.flink.streaming.connectors.kinesis.model.StreamShardHandle to private isValidShardId(shardId String) : boolean from class org.apache.flink.streaming.connectors.kinesis.testutils.FakeKinesisBehavioursFactory.NonReshardedStreamsKinesis |
From |
To |
|
Move Method public isValidShardId(shardId String) : boolean from class org.apache.flink.streaming.connectors.kinesis.model.KinesisStreamShard to private isValidShardId(shardId String) : boolean from class org.apache.flink.streaming.connectors.kinesis.testutils.FakeKinesisBehavioursFactory.NonReshardedStreamsKinesis |
From |
To |