flink 02c10d312371aaad12ed8961cdf96288fe78a983

02c10d312371aaad12ed8961cdf96288fe78a983

Files Diff

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

Link to commit

Dependency Action

Refactorings reported:

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