74b09ce0db4d24a0ac25de2ecac391fdf8bd5a90
Files Diff
- Added: 1
- Removed: 1
- Renamed: 0
- Modified: 2
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 1 | ||
| Rename Variable callback : AtomicReference<Runnable> to runnableFuture : AtomicReference<Runnable> in method public testAckLoopExitOnException() : void in class org.apache.flink.streaming.connectors.cassandra.CassandraTupleWriteAheadSinkTest | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorUnitTest renamed to org.apache.flink.streaming.connectors.cassandra.CassandraTupleWriteAheadSinkTest | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type updatesCount : IntValue to updatesCount : AtomicInteger in method protected sendValues(values Iterable<IN>, timestamp long) : boolean in class org.apache.flink.streaming.connectors.cassandra.CassandraTupleWriteAheadSink | From | To |