|
Change Parameter Type kafkaConnectionString : String to server : KafkaTestEnvironment in method public InfiniteStringsGenerator(server KafkaTestEnvironment, topic String) in class org.apache.flink.streaming.connectors.kafka.testutils.DataGenerators.InfiniteStringsGenerator |
From |
To |
|
Change Parameter Type brokerConnection : String to testServer : KafkaTestEnvironment in method public generateLongStringTupleSequence(env StreamExecutionEnvironment, testServer KafkaTestEnvironment, topic String, numPartitions int, from int, to int) : void in class org.apache.flink.streaming.connectors.kafka.testutils.DataGenerators |
From |
To |
|
Change Parameter Type topic : List<String> to topic : String in method public FlinkKafkaConsumer08(topic String, valueDeserializer DeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08 |
From |
To |
|
Change Parameter Type leaderToShutDown : String to shutdownBrokerId : int in method public BrokerKillingMapper(shutdownBrokerId int, failCount int) in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.BrokerKillingMapper |
From |
To |
|
Change Parameter Type consumer : FlinkKafkaConsumer<T> to consumer : FlinkKafkaConsumer08<T> in method public PeriodicOffsetCommitter(commitInterval long, consumer FlinkKafkaConsumer08<T>) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08.PeriodicOffsetCommitter |
From |
To |
|
Change Parameter Type brokerConnection : String to testServer : KafkaTestEnvironment in method public generateRandomizedIntegerSequence(env StreamExecutionEnvironment, testServer KafkaTestEnvironment, topic String, numPartitions int, numElements int, randomizeOrder boolean) : void in class org.apache.flink.streaming.connectors.kafka.testutils.DataGenerators |
From |
To |
|
Move Method public tryExecute(env StreamExecutionEnvironment, jobName String) : void from class org.apache.flink.test.checkpointing.WindowCheckpointingITCase to public tryExecute(see StreamExecutionEnvironment, name String) : JobExecutionResult from class org.apache.flink.test.util.TestUtils |
From |
To |
|
Move Method public tryExecute(env StreamExecutionEnvironment, jobName String) : void from class org.apache.flink.test.checkpointing.EventTimeAllWindowCheckpointingITCase to public tryExecute(see StreamExecutionEnvironment, name String) : JobExecutionResult from class org.apache.flink.test.util.TestUtils |
From |
To |
|
Move Method public tryExecute(env StreamExecutionEnvironment, jobName String) : void from class org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase to public tryExecute(see StreamExecutionEnvironment, name String) : JobExecutionResult from class org.apache.flink.test.util.TestUtils |
From |
To |
|
Pull Up Attribute public MAX_NUM_PENDING_CHECKPOINTS : int from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer to public MAX_NUM_PENDING_CHECKPOINTS : int from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase |
From |
To |
|
Pull Up Attribute private running : boolean from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer to protected running : boolean from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase |
From |
To |
|
Pull Up Attribute private pendingCheckpoints : LinkedMap from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer to protected pendingCheckpoints : LinkedMap from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase |
From |
To |
|
Pull Up Attribute private restoreToOffset : HashMap<KafkaTopicPartition,Long> from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer to protected restoreToOffset : HashMap<KafkaTopicPartition,Long> from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase |
From |
To |
|
Pull Up Attribute private deserializer : KeyedDeserializationSchema<T> from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer to protected deserializer : KeyedDeserializationSchema<T> from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase |
From |
To |
|
Change Variable Type producer : FlinkKafkaProducer<String> to producer : FlinkKafkaProducerBase<String> in method public run() : void in class org.apache.flink.streaming.connectors.kafka.testutils.DataGenerators.InfiniteStringsGenerator |
From |
To |
|
Change Variable Type consumer : FlinkKafkaConsumer<?> to consumer : FlinkKafkaConsumer08<?> in method public testSnapshot() : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTest |
From |
To |
|
Change Variable Type source : FlinkKafkaConsumer<Tuple2<Long,byte[]>> to source : FlinkKafkaConsumerBase<Tuple2<Long,byte[]>> in method public runBigRecordTestTopology() : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase |
From |
To |
|
Change Variable Type kafkaSource : FlinkKafkaConsumer<Integer> to kafkaSource : FlinkKafkaConsumerBase<Integer> in method public runFailOnDeployTest() : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase |
From |
To |
|
Change Variable Type consumer : FlinkKafkaConsumer<Tuple2<Integer,Integer>> to consumer : FlinkKafkaConsumerBase<Tuple2<Integer,Integer>> in method protected readSequence(env StreamExecutionEnvironment, cc Properties, sourceParallelism int, topicName String, valuesCount int, startFrom int) : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase |
From |
To |
|
Change Variable Type source : FlinkKafkaConsumer<String> to source : FlinkKafkaConsumerBase<String> in method public run() : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.runCancelingOnFullInputTest.jobRunner |
From |
To |
|
Change Variable Type kafkaSource : FlinkKafkaConsumer<Integer> to kafkaSource : FlinkKafkaConsumerBase<Integer> in method public runBrokerFailureTest() : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase |
From |
To |
|
Change Variable Type source : FlinkKafkaConsumer<String> to source : FlinkKafkaConsumerBase<String> in method public run() : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.runCancelingOnEmptyInputTest.jobRunner |
From |
To |
|
Change Variable Type source : FlinkKafkaConsumer<Tuple2<Long,String>> to source : FlinkKafkaConsumerBase<Tuple2<Long,String>> in method public runSimpleConcurrentProducerConsumerTopology() : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase |
From |
To |
|
Change Variable Type broker : KafkaServer to kafkaServer : KafkaTestEnvironment in method public shutDownServices() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Change Variable Type kafkaSource : FlinkKafkaConsumer<Integer> to kafkaSource : FlinkKafkaConsumerBase<Integer> in method public runOneToOneExactlyOnceTest() : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase |
From |
To |
|
Change Variable Type source : FlinkKafkaConsumer<String> to source : FlinkKafkaConsumerBase<String> in method public runCheckpointingTest() : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase |
From |
To |
|
Change Variable Type source : FlinkKafkaConsumer<String> to source : FlinkKafkaConsumerBase<String> in method public runFailOnNoBrokerTest() : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase |
From |
To |
|
Change Variable Type kafkaSource : FlinkKafkaConsumer<Integer> to kafkaSource : FlinkKafkaConsumerBase<Integer> in method public runMultipleSourcesOnePartitionExactlyOnceTest() : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase |
From |
To |
|
Change Variable Type kafkaSource : FlinkKafkaConsumer<Integer> to kafkaSource : FlinkKafkaConsumerBase<Integer> in method public runOneSourceMultiplePartitionsExactlyOnceTest() : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase |
From |
To |
|
Pull Up Method public restoreState(restoredOffsets HashMap<KafkaTopicPartition,Long>) : void from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer to public restoreState(restoredOffsets HashMap<KafkaTopicPartition,Long>) : void from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase |
From |
To |
|
Pull Up Method public getProducedType() : TypeInformation<T> from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer to public getProducedType() : TypeInformation<T> from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase |
From |
To |
|
Pull Up Method public notifyCheckpointComplete(checkpointId long) : void from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer to public notifyCheckpointComplete(checkpointId long) : void from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase |
From |
To |
|
Pull Up Method public snapshotState(checkpointId long, checkpointTimestamp long) : HashMap<KafkaTopicPartition,Long> from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer to public snapshotState(checkpointId long, checkpointTimestamp long) : HashMap<KafkaTopicPartition,Long> from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase |
From |
To |
|
Rename Parameter brokerConnection : String to testServer : KafkaTestEnvironment in method public generateRandomizedIntegerSequence(env StreamExecutionEnvironment, testServer KafkaTestEnvironment, topic String, numPartitions int, numElements int, randomizeOrder boolean) : void in class org.apache.flink.streaming.connectors.kafka.testutils.DataGenerators |
From |
To |
|
Rename Parameter deserializer : DeserializationSchema<T> to valueDeserializer : DeserializationSchema<T> in method public FlinkKafkaConsumer08(topic String, valueDeserializer DeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08 |
From |
To |
|
Rename Parameter brokerConnection : String to testServer : KafkaTestEnvironment in method public generateLongStringTupleSequence(env StreamExecutionEnvironment, testServer KafkaTestEnvironment, topic String, numPartitions int, from int, to int) : void in class org.apache.flink.streaming.connectors.kafka.testutils.DataGenerators |
From |
To |
|
Rename Parameter kafkaConnectionString : String to server : KafkaTestEnvironment in method public InfiniteStringsGenerator(server KafkaTestEnvironment, topic String) in class org.apache.flink.streaming.connectors.kafka.testutils.DataGenerators.InfiniteStringsGenerator |
From |
To |
|
Rename Parameter jobName : String to name : String in method public tryExecute(see StreamExecutionEnvironment, name String) : JobExecutionResult in class org.apache.flink.test.util.TestUtils |
From |
To |
|
Rename Parameter leaderToShutDown : String to shutdownBrokerId : int in method public BrokerKillingMapper(shutdownBrokerId int, failCount int) in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.BrokerKillingMapper |
From |
To |
|
Rename Parameter key : Object to next : Object in method public partition(next Object, serializedKey byte[], serializedValue byte[], numPartitions int) : int in class org.apache.flink.streaming.connectors.kafka.KafkaProducerTestBase.CustomPartitioner |
From |
To |
|
Rename Parameter env : StreamExecutionEnvironment to see : StreamExecutionEnvironment in method public tryExecute(see StreamExecutionEnvironment, name String) : JobExecutionResult in class org.apache.flink.test.util.TestUtils |
From |
To |