|
Rename Method public testUnparsableLongForDescribeStreamBackoffBaseMillisInConfig() : void renamed to public testUnparsableLongForListShardsBackoffBaseMillisInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest |
From |
To |
|
Rename Method public testUnparsableLongForDescribeStreamBackoffMaxMillisInConfig() : void renamed to public testUnparsableLongForListShardsBackoffMaxMillisInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest |
From |
To |
|
Rename Method public testUnparsableDoubleForDescribeStreamBackoffExponentialConstantInConfig() : void renamed to public testUnparsableDoubleForListShardsBackoffExponentialConstantInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest |
From |
To |
|
Rename Method private describeStream(streamName String, startShardId String) : DescribeStreamResult renamed to private listShards(streamName String, startShardId String, startNextToken String) : ListShardsResult in class org.apache.flink.streaming.connectors.kinesis.proxy.KinesisProxy |
From |
To |
|
Rename Variable re : ResourceNotFoundException to reNotFound : ResourceNotFoundException in method private listShards(streamName String, startShardId String, startNextToken String) : ListShardsResult in class org.apache.flink.streaming.connectors.kinesis.proxy.KinesisProxy |
From |
To |
|
Rename Variable describeStreamRequest : DescribeStreamRequest to listShardsRequest : ListShardsRequest in method private listShards(streamName String, startShardId String, startNextToken String) : ListShardsResult in class org.apache.flink.streaming.connectors.kinesis.proxy.KinesisProxy |
From |
To |
|
Rename Variable describeStreamResult : DescribeStreamResult to listShardsResult : ListShardsResult in method private getShardsOfStream(streamName String, lastSeenShardId String) : List<StreamShardHandle> in class org.apache.flink.streaming.connectors.kinesis.proxy.KinesisProxy |
From |
To |
|
Rename Variable describeStreamResult : DescribeStreamResult to listShardsResults : ListShardsResult in method private listShards(streamName String, startShardId String, startNextToken String) : ListShardsResult in class org.apache.flink.streaming.connectors.kinesis.proxy.KinesisProxy |
From |
To |