073b82c856c0897679d46576ec902c4e5e3a5e32
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 5 | ||
| Rename Variable testConfig : Properties to standardProps : Properties in method private getStandardProperties() : Properties in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisProducerTest | From | To | |
| Replace Variable With Attribute | 1 | ||
| Replace Variable With Attribute kp : KinesisProducer to producer : KinesisProducer in method private flushSync() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisProducer | From | To | |
| Extract Method | 8 | ||
| Extract Method private getStandardProperties() : Properties extracted from public testConsumerIsSerializable() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisProducerTest | From | To | |
| Extract Method private checkAndPropagateAsyncError() : void extracted from public invoke(value OUT) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisProducer | From | To | |
| Extract Method private getStandardProperties() : Properties extracted from public testCreateWithNonSerializableDeserializerFails() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisProducerTest | From | To | |
| Extract Method private getStandardProperties() : Properties extracted from public testConfigureWithNonSerializableCustomPartitionerFails() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisProducerTest | From | To | |
| Extract Method private getStandardProperties() : Properties extracted from public testCreateWithSerializableDeserializer() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisProducerTest | From | To | |
| Extract Method protected getKinesisProducer(producerConfig KinesisProducerConfiguration) : KinesisProducer extracted from public open(parameters Configuration) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisProducer | From | To | |
| Extract Method private flushSync() : void extracted from public close() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisProducer | From | To | |
| Extract Method private getStandardProperties() : Properties extracted from public testConfigureWithSerializableCustomPartitioner() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisProducerTest | From | To |