flink 62523acbe175cf159fe1b4ab6cf5c0412fc4d232

62523acbe175cf159fe1b4ab6cf5c0412fc4d232

Files Diff

Added: 1
Removed: 0
Renamed: 0
Modified: 4

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Change Parameter Type	3
	Change Parameter Type sink : CassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>> to sink : TestCassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>> in method protected verifyResultsDataDiscardingUponRestore(harness OneInputStreamOperatorTestHarness<Tuple3<String,Integer,Integer>,Tuple3<String,Integer,Integer>>, sink TestCassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>>) : void in class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase	From	To
	Change Parameter Type sink : CassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>> to sink : TestCassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>> in method protected verifyResultsDataPersistenceUponMissedNotify(harness OneInputStreamOperatorTestHarness<Tuple3<String,Integer,Integer>,Tuple3<String,Integer,Integer>>, sink TestCassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>>) : void in class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase	From	To
	Change Parameter Type sink : CassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>> to sink : TestCassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>> in method protected verifyResultsIdealCircumstances(harness OneInputStreamOperatorTestHarness<Tuple3<String,Integer,Integer>,Tuple3<String,Integer,Integer>>, sink TestCassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>>) : void in class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase	From	To
	Change Return Type	1
	Change Return Type CassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>> to TestCassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>> in method protected createSink() : TestCassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>> in class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase	From	To
	Move Attribute	1
	Move Attribute private tmpDir : File from class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase to private tmpDir : File from class org.apache.flink.streaming.connectors.cassandra.CassandraService	From	To
	Change Attribute Type	3
	Change Attribute Type exception : Throwable to exception : AtomicReference<Throwable> in class org.apache.flink.streaming.connectors.cassandra.CassandraSinkBase	From	To
	Change Attribute Type cassandra : EmbeddedCassandraService to cassandra : CassandraService in class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase	From	To
	Change Attribute Type collection : ArrayList<Tuple3<String,Integer,Integer>> to collection : List<Tuple3<String,Integer,Integer>> in class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase	From	To