8dfc9f9d0f06e4ea2376b0a58efd623e58735ae5
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Pull Up Method | 2 | ||
Pull Up Method public send(value IN) : ListenableFuture<ResultSet> from class org.apache.flink.streaming.connectors.cassandra.CassandraTupleSink to public send(value IN) : ListenableFuture<ResultSet> from class org.apache.flink.streaming.connectors.cassandra.AbstractCassandraTupleSink | From | To | |
Pull Up Method public open(configuration Configuration) : void from class org.apache.flink.streaming.connectors.cassandra.CassandraTupleSink to public open(configuration Configuration) : void from class org.apache.flink.streaming.connectors.cassandra.AbstractCassandraTupleSink | From | To | |
Pull Up Attribute | 2 | ||
Pull Up Attribute private insertQuery : String from class org.apache.flink.streaming.connectors.cassandra.CassandraTupleSink to private insertQuery : String from class org.apache.flink.streaming.connectors.cassandra.AbstractCassandraTupleSink | From | To | |
Pull Up Attribute private ps : PreparedStatement from class org.apache.flink.streaming.connectors.cassandra.CassandraTupleSink to private ps : PreparedStatement from class org.apache.flink.streaming.connectors.cassandra.AbstractCassandraTupleSink | From | To | |
Extract Superclass | 1 | ||
Extract Superclass org.apache.flink.streaming.connectors.cassandra.AbstractCassandraTupleSink from classes [org.apache.flink.streaming.connectors.cassandra.CassandraTupleSink] | From | To | |
Rename Attribute | 1 | ||
Rename Attribute LOG : Logger to log : Logger in class org.apache.flink.streaming.connectors.cassandra.CassandraSinkBase | From | To | |
Extract Variable | 1 | ||
Extract Variable typeInfo : TypeInformation<IN> in method public addSink(input DataStream<IN>) : CassandraSinkBuilder<IN> from class org.apache.flink.streaming.connectors.cassandra.CassandraSink | From | To |