cb9c4fcde2555e7970afdc5f641f4bde8e6b5d08
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 1
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 3 | ||
| Rename Variable casSinkFunc : TestCassandraSink to testCassandraSink : TestCassandraSink in method private createOpenedTestCassandraSink() : TestCassandraSink in class org.apache.flink.streaming.connectors.cassandra.CassandraSinkBaseTest | From | To | |
| Rename Variable casSinkFunc : TestCassandraSink to testCassandraSink : TestCassandraSink in method private createOpenedTestCassandraSink(failureHandler CassandraFailureHandler) : TestCassandraSink in class org.apache.flink.streaming.connectors.cassandra.CassandraSinkBaseTest | From | To | |
| Parameterize Variable | 1 | ||
| Parameterize Variable casSinkFunc : TestCassandraSink to testCassandraSink : TestCassandraSink in method private createOpenedTestHarness(testCassandraSink TestCassandraSink) : OneInputStreamOperatorTestHarness<String,Object> in class org.apache.flink.streaming.connectors.cassandra.CassandraSinkBaseTest | From | To | |
| Extract Variable | 1 | ||
| Extract Variable testStreamSink : StreamSink<String> in method private createOpenedTestHarness(testCassandraSink TestCassandraSink) : OneInputStreamOperatorTestHarness<String,Object> from class org.apache.flink.streaming.connectors.cassandra.CassandraSinkBaseTest | From | To | |
| Extract Method | 6 | ||
| Extract Method private createOpenedTestHarness(testCassandraSink TestCassandraSink) : OneInputStreamOperatorTestHarness<String,Object> extracted from public testThrowErrorOnSnapshot() : void in class org.apache.flink.streaming.connectors.cassandra.CassandraSinkBaseTest | From | To | |
| Extract Method private createOpenedTestCassandraSink(failureHandler CassandraFailureHandler) : TestCassandraSink extracted from public testIgnoreError() : void in class org.apache.flink.streaming.connectors.cassandra.CassandraSinkBaseTest | From | To | |
| Extract Method private createOpenedTestHarness(testCassandraSink TestCassandraSink) : OneInputStreamOperatorTestHarness<String,Object> extracted from public testWaitForPendingUpdatesOnClose() : void in class org.apache.flink.streaming.connectors.cassandra.CassandraSinkBaseTest | From | To | |
| Extract Method private createOpenedTestCassandraSink() : TestCassandraSink extracted from public testSuccessfulPath() : void in class org.apache.flink.streaming.connectors.cassandra.CassandraSinkBaseTest | From | To | |
| Extract Method private createOpenedTestHarness(testCassandraSink TestCassandraSink) : OneInputStreamOperatorTestHarness<String,Object> extracted from public testWaitForPendingUpdatesOnSnapshot() : void in class org.apache.flink.streaming.connectors.cassandra.CassandraSinkBaseTest | From | To | |
| Extract Method private createOpenedTestCassandraSink() : TestCassandraSink extracted from public testThrowErrorOnInvoke() : void in class org.apache.flink.streaming.connectors.cassandra.CassandraSinkBaseTest | From | To |