|
Change Parameter Type sink : CassandraIdempotentExactlyOnceSink<Tuple3<String,Integer,Integer>> to sink : CassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>> in method protected verifyResultsDataPersistenceUponMissedNotify(harness OneInputStreamTaskTestHarness<Tuple3<String,Integer,Integer>,Tuple3<String,Integer,Integer>>, task OneInputStreamTask<Tuple3<String,Integer,Integer>,Tuple3<String,Integer,Integer>>, sink CassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>>) : void in class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorTest |
From |
To |
|
Change Parameter Type sink : CassandraIdempotentExactlyOnceSink<Tuple3<String,Integer,Integer>> to sink : CassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>> in method protected verifyResultsIdealCircumstances(harness OneInputStreamTaskTestHarness<Tuple3<String,Integer,Integer>,Tuple3<String,Integer,Integer>>, task OneInputStreamTask<Tuple3<String,Integer,Integer>,Tuple3<String,Integer,Integer>>, sink CassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>>) : void in class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorTest |
From |
To |
|
Change Parameter Type sink : CassandraIdempotentExactlyOnceSink<Tuple3<String,Integer,Integer>> to sink : CassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>> in method protected verifyResultsDataDiscardingUponRestore(harness OneInputStreamTaskTestHarness<Tuple3<String,Integer,Integer>,Tuple3<String,Integer,Integer>>, task OneInputStreamTask<Tuple3<String,Integer,Integer>,Tuple3<String,Integer,Integer>>, sink CassandraTupleWriteAheadSink<Tuple3<String,Integer,Integer>>) : void in class org.apache.flink.streaming.connectors.cassandra.CassandraConnectorTest |
From |
To |
|
Rename Class org.apache.flink.streaming.connectors.cassandra.CassandraAtLeastOnceSink renamed to org.apache.flink.streaming.connectors.cassandra.CassandraSinkBase |
From |
To |
|
Rename Class org.apache.flink.streaming.connectors.cassandra.CassandraIdempotentExactlyOnceSink renamed to org.apache.flink.streaming.connectors.cassandra.CassandraTupleWriteAheadSink |
From |
To |
|
Rename Class org.apache.flink.streaming.runtime.operators.GenericAtLeastOnceSink renamed to org.apache.flink.streaming.runtime.operators.GenericWriteAheadSink |
From |
To |
|
Rename Class org.apache.flink.streaming.connectors.cassandra.CassandraPojoAtLeastOnceSink renamed to org.apache.flink.streaming.connectors.cassandra.CassandraPojoSink |
From |
To |
|
Rename Class org.apache.flink.streaming.connectors.cassandra.CassandraTupleAtLeastOnceSink renamed to org.apache.flink.streaming.connectors.cassandra.CassandraTupleSink |
From |
To |
|
Rename Class org.apache.flink.streaming.runtime.operators.AtLeastOnceSinkTestBase renamed to org.apache.flink.streaming.runtime.operators.WriteAheadSinkTestBase |
From |
To |
|
Rename Class org.apache.flink.streaming.connectors.cassandra.example.CassandraTupleAtLeastOnceSinkExample renamed to org.apache.flink.streaming.connectors.cassandra.example.CassandraTupleSinkExample |
From |
To |
|
Rename Class org.apache.flink.streaming.connectors.cassandra.example.CassandraPojoAtLeastOnceSinkExample renamed to org.apache.flink.streaming.connectors.cassandra.example.CassandraPojoSinkExample |
From |
To |
|
Rename Class org.apache.flink.streaming.connectors.cassandra.example.CassandraIdempotentExactlyOnceSinkExample renamed to org.apache.flink.streaming.connectors.cassandra.example.CassandraTupleWriteAheadSinkExample |
From |
To |
|
Rename Class org.apache.flink.streaming.runtime.operators.GenericAtLeastOnceSinkTest renamed to org.apache.flink.streaming.runtime.operators.GenericWriteAheadSinkTest |
From |
To |