|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public KafkaFetcher(sourceContext SourceFunction.SourceContext<T>, assignedPartitionsWithInitialOffsets Map<KafkaTopicPartition,Long>, watermarksPeriodic SerializedValue<AssignerWithPeriodicWatermarks<T>>, watermarksPunctuated SerializedValue<AssignerWithPunctuatedWatermarks<T>>, processingTimeProvider ProcessingTimeService, autoWatermarkInterval long, userCodeClassLoader ClassLoader, taskNameWithSubtasks String, deserializer KafkaDeserializationSchema<T>, kafkaProperties Properties, pollTimeout long, subtaskMetricGroup MetricGroup, consumerMetricGroup MetricGroup, useMetrics boolean) in class org.apache.flink.streaming.connectors.kafka.internal.KafkaFetcher |
From |
To |
|
Change Parameter Type readSchema : KeyedDeserializationSchema<T> to readSchema : KafkaDeserializationSchema<T> in method public getConsumer(topic String, readSchema KafkaDeserializationSchema<T>, props Properties) : FlinkKafkaConsumerBase<T> in class org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironment |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public FlinkKafkaConsumer011(topic String, deserializer KafkaDeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer011 |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public FlinkKafkaConsumer08(topic String, deserializer KafkaDeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08 |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public FlinkKafkaConsumer010(subscriptionPattern Pattern, deserializer KafkaDeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer010 |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public FlinkKafkaConsumer011(topics List<String>, deserializer KafkaDeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer011 |
From |
To |
|
Change Parameter Type readSchema : KeyedDeserializationSchema<T> to readSchema : KafkaDeserializationSchema<T> in method public abstract getConsumer(topics List<String>, readSchema KafkaDeserializationSchema<T>, props Properties) : FlinkKafkaConsumerBase<T> in class org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironment |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public FlinkKafkaConsumer09(topic String, deserializer KafkaDeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09 |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public FlinkKafkaConsumer011(subscriptionPattern Pattern, deserializer KafkaDeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer011 |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method private FlinkKafkaConsumer09(topics List<String>, subscriptionPattern Pattern, deserializer KafkaDeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09 |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public FlinkKafkaConsumer08(topics List<String>, deserializer KafkaDeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08 |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public FlinkKafkaConsumer010(topic String, deserializer KafkaDeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer010 |
From |
To |
|
Change Parameter Type deserSchema : KeyedDeserializationSchema<Tuple2<Integer,Integer>> to deserSchema : KafkaDeserializationSchema<Tuple2<Integer,Integer>> in method private validateSequence(topic String, parallelism int, deserSchema KafkaDeserializationSchema<Tuple2<Integer,Integer>>, totalNumElements int) : boolean in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public FlinkKafkaConsumer09(subscriptionPattern Pattern, deserializer KafkaDeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09 |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method private FlinkKafkaConsumer08(topics List<String>, subscriptionPattern Pattern, deserializer KafkaDeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08 |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public FlinkKafkaConsumer(subscriptionPattern Pattern, deserializer KafkaDeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public Kafka09Fetcher(sourceContext SourceContext<T>, assignedPartitionsWithInitialOffsets Map<KafkaTopicPartition,Long>, watermarksPeriodic SerializedValue<AssignerWithPeriodicWatermarks<T>>, watermarksPunctuated SerializedValue<AssignerWithPunctuatedWatermarks<T>>, processingTimeProvider ProcessingTimeService, autoWatermarkInterval long, userCodeClassLoader ClassLoader, taskNameWithSubtasks String, deserializer KafkaDeserializationSchema<T>, kafkaProperties Properties, pollTimeout long, subtaskMetricGroup MetricGroup, consumerMetricGroup MetricGroup, useMetrics boolean) in class org.apache.flink.streaming.connectors.kafka.internal.Kafka09Fetcher |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public FlinkKafkaConsumer(topics List<String>, deserializer KafkaDeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public Kafka08Fetcher(sourceContext SourceContext<T>, seedPartitionsWithInitialOffsets Map<KafkaTopicPartition,Long>, watermarksPeriodic SerializedValue<AssignerWithPeriodicWatermarks<T>>, watermarksPunctuated SerializedValue<AssignerWithPunctuatedWatermarks<T>>, runtimeContext StreamingRuntimeContext, deserializer KafkaDeserializationSchema<T>, kafkaProperties Properties, autoCommitInterval long, consumerMetricGroup MetricGroup, useMetrics boolean) in class org.apache.flink.streaming.connectors.kafka.internals.Kafka08Fetcher |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public FlinkKafkaConsumer08(subscriptionPattern Pattern, deserializer KafkaDeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08 |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public FlinkKafkaConsumer010(topics List<String>, deserializer KafkaDeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer010 |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public FlinkKafkaConsumerBase(topics List<String>, topicPattern Pattern, deserializer KafkaDeserializationSchema<T>, discoveryIntervalMillis long, useMetrics boolean) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase |
From |
To |
|
Change Parameter Type readSchema : KeyedDeserializationSchema<T> to readSchema : KafkaDeserializationSchema<T> in method public getConsumer(topics List<String>, readSchema KafkaDeserializationSchema<T>, props Properties) : FlinkKafkaConsumerBase<T> in class org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public FlinkKafkaConsumer(topic String, deserializer KafkaDeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method private FlinkKafkaConsumer(topics List<String>, subscriptionPattern Pattern, deserializer KafkaDeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public SimpleConsumerThread(owner Kafka08Fetcher<T>, errorHandler ExceptionProxy, config Properties, broker Node, seedPartitions List<KafkaTopicPartitionState<TopicAndPartition>>, unassignedPartitions ClosableBlockingQueue<KafkaTopicPartitionState<TopicAndPartition>>, deserializer KafkaDeserializationSchema<T>, invalidOffsetBehavior long) in class org.apache.flink.streaming.connectors.kafka.internals.SimpleConsumerThread |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public FlinkKafkaConsumer09(topics List<String>, deserializer KafkaDeserializationSchema<T>, props Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09 |
From |
To |
|
Change Parameter Type deserializer : KeyedDeserializationSchema<T> to deserializer : KafkaDeserializationSchema<T> in method public Kafka010Fetcher(sourceContext SourceContext<T>, assignedPartitionsWithInitialOffsets Map<KafkaTopicPartition,Long>, watermarksPeriodic SerializedValue<AssignerWithPeriodicWatermarks<T>>, watermarksPunctuated SerializedValue<AssignerWithPunctuatedWatermarks<T>>, processingTimeProvider ProcessingTimeService, autoWatermarkInterval long, userCodeClassLoader ClassLoader, taskNameWithSubtasks String, deserializer KafkaDeserializationSchema<T>, kafkaProperties Properties, pollTimeout long, subtaskMetricGroup MetricGroup, consumerMetricGroup MetricGroup, useMetrics boolean) in class org.apache.flink.streaming.connectors.kafka.internal.Kafka010Fetcher |
From |
To |
|
Change Variable Type schema : KeyedDeserializationSchema<String> to schema : KafkaDeserializationSchema<String> in method public testCancellationWhenEmitBlocks() : void in class org.apache.flink.streaming.connectors.kafka.internal.Kafka09FetcherTest |
From |
To |
|
Change Variable Type schema : KeyedDeserializationSchema<String> to schema : KafkaDeserializationSchema<String> in method public testCommitDoesNotBlock() : void in class org.apache.flink.streaming.connectors.kafka.internal.Kafka010FetcherTest |
From |
To |
|
Change Variable Type clonedDeserializer : KeyedDeserializationSchema<T> to clonedDeserializer : KafkaDeserializationSchema<T> in method private createAndStartSimpleConsumerThread(seedPartitions List<KafkaTopicPartitionState<TopicAndPartition>>, leader Node, errorHandler ExceptionProxy) : SimpleConsumerThread<T> in class org.apache.flink.streaming.connectors.kafka.internals.Kafka08Fetcher |
From |
To |
|
Change Variable Type schema : KeyedDeserializationSchema<String> to schema : KafkaDeserializationSchema<String> in method public testCommitDoesNotBlock() : void in class org.apache.flink.streaming.connectors.kafka.internal.Kafka09FetcherTest |
From |
To |
|
Change Variable Type schema : KeyedDeserializationSchema<String> to schema : KafkaDeserializationSchema<String> in method public ensureOffsetsGetCommitted() : void in class org.apache.flink.streaming.connectors.kafka.internal.Kafka09FetcherTest |
From |
To |
|
Change Variable Type deserSchema : KeyedDeserializationSchema<Tuple2<Integer,Integer>> to deserSchema : KafkaDeserializationSchema<Tuple2<Integer,Integer>> in method protected writeAppendSequence(topicName String, originalNumElements int, numElementsToAppend int, parallelism int) : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase |
From |
To |
|
Change Variable Type readSchema : KeyedDeserializationSchema<Tuple2<Long,PojoValue>> to readSchema : KafkaDeserializationSchema<Tuple2<Long,PojoValue>> in method public runKeyValueTest() : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase |
From |
To |
|
Change Variable Type schema : KeyedDeserializationSchema<String> to schema : KafkaDeserializationSchema<String> in method public ensureOffsetsGetCommitted() : void in class org.apache.flink.streaming.connectors.kafka.internal.Kafka010FetcherTest |
From |
To |
|
Change Variable Type schema : KeyedDeserializationSchema<String> to schema : KafkaDeserializationSchema<String> in method public testCancellationWhenEmitBlocks() : void in class org.apache.flink.streaming.connectors.kafka.internal.Kafka010FetcherTest |
From |
To |
|
Change Variable Type deserSchema : KeyedDeserializationSchema<Tuple2<Integer,Integer>> to deserSchema : KafkaDeserializationSchema<Tuple2<Integer,Integer>> in method public runStartFromLatestOffsets() : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase |
From |
To |
|
Change Variable Type deserSchema : KeyedDeserializationSchema<Tuple2<Integer,Integer>> to deserSchema : KafkaDeserializationSchema<Tuple2<Integer,Integer>> in method protected writeSequence(baseTopicName String, numElements int, parallelism int, replicationFactor int) : String in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase |
From |
To |