|
Change Variable Type s : Row to s : com.datastax.driver.core.Row in method protected verifyResultsIdealCircumstances(sink CassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>>) : void in class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase |
From |
To |
|
Change Variable Type s : Row to s : com.datastax.driver.core.Row in method protected verifyResultsDataPersistenceUponMissedNotify(sink CassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>>) : void in class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase |
From |
To |
|
Change Variable Type row : Row to row : com.datastax.driver.core.Row in method public testCassandraScalaTupleAtLeastSink() : void in class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase |
From |
To |
|
Change Variable Type s : Row to s : com.datastax.driver.core.Row in method protected verifyResultsDataDiscardingUponRestore(sink CassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>>) : void in class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase |
From |
To |
|
Change Variable Type s : Row to s : com.datastax.driver.core.Row in method protected verifyResultsWhenReScaling(sink CassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>>, startElementCounter int, endElementCounter int) : void in class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorITCase |
From |
To |