be913100d8657c7a0acdaa92557af51ab69af0ab
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 3
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 3 | ||
| Rename Method public testCustomizedRateLimitInProducerConfiguration() : void renamed to public testRateLimitInProducerConfiguration() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Rename Method public testCustomizedThreadingModelInProducerConfiguration() : void renamed to public testThreadingModelInProducerConfiguration() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Rename Method public testDefaultThreadPoolSizeInProducerConfiguration() : void renamed to public testThreadPoolSizeInProducerConfiguration() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Rename Variable | 24 | ||
| Rename Variable testConfig : Properties to config : Properties in method private getPropertiesWithRequiredFields() : Properties in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Attribute | 1 | ||
| Extract Attribute protected DEFAULT_THREADING_MODEL : KinesisProducerConfiguration.ThreadingModel in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtil | From | To | |
| Extract Method | 24 | ||
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnparsableLongForShardDiscoveryIntervalMillisInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testInvalidPatternForInitialTimestampInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnparsableDoubleForGetShardIteratorBackoffExponentialConstantInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnparsableLongForGetShardIteratorBackoffBaseMillisInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnparsableDoubleForGetRecordsBackoffExponentialConstantInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnixTimestampForValidateOptionDateProperty() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnparsableDateForUserDefinedDateFormatForInitialTimestampInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnparsableDateForInitialTimestampInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testDateStringForUserDefinedDateFormatForValidateOptionDateProperty() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnparsableLongForGetRecordsIntervalMillisInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testDateStringForValidateOptionDateProperty() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testStreamInitPositionTypeSetToAtTimestampButNoInitTimestampSetInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnparsableIntForGetRecordsRetriesInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnparsableIntForGetShardIteratorRetriesInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnparsableLongForGetRecordsBackoffMaxMillisInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnparsableLongForGetRecordsBackoffBaseMillisInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnrecognizableStreamInitPositionTypeInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnparsableDoubleForDescribeStreamBackoffExponentialConstantInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnparsableIntForGetRecordsMaxCountInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testIllegalValueForInitialTimestampInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnparsableLongForDescribeStreamBackoffBaseMillisInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnrecognizableCredentialProviderTypeInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnparsableLongForDescribeStreamBackoffMaxMillisInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Extract Method private getPropertiesWithRequiredFields() : Properties extracted from public testUnparsableLongForGetShardIteratorBackoffMaxMillisInConfig() : void in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtilTest | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type DEFAULT_RATE_LIMIT : String to DEFAULT_RATE_LIMIT : long in class org.apache.flink.streaming.connectors.kinesis.util.KinesisConfigUtil | From | To |