flink 85e7b2878eb50767ba64bbbd5794929d151f81ef

85e7b2878eb50767ba64bbbd5794929d151f81ef

Files Diff

Added: 5
Removed: 0
Renamed: 0
Modified: 8

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Change Parameter Type	3
	Change Parameter Type valueDeserializer : DeserializationSchema<T> to deserializer : KeyedDeserializationSchema<T> in method public SimpleConsumerThread(owner LegacyFetcher, config Properties, topic String, broker Node, partitions FetchPartition[], sourceContext SourceFunction.SourceContext<T>, deserializer KeyedDeserializationSchema<T>, offsetsState long[]) in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher.SimpleConsumerThread	From	To
	Change Parameter Type valueDeserializer : DeserializationSchema<T> to deserializer : KeyedDeserializationSchema<T> in method public run(sourceContext SourceFunction.SourceContext<T>, deserializer KeyedDeserializationSchema<T>, lastOffsets long[]) : void in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher	From	To
	Change Parameter Type valueDeserializer : DeserializationSchema<T> to valueDeserializer : KeyedDeserializationSchema<T> in method public run(sourceContext SourceFunction.SourceContext<T>, valueDeserializer KeyedDeserializationSchema<T>, lastOffsets long[]) : void in class org.apache.flink.streaming.connectors.kafka.internals.Fetcher	From	To
	Rename Variable	2
	Rename Variable serialized : byte[] to serializedValue : byte[] in method public invoke(next IN) : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer	From	To
	Rename Variable valueByte : byte[] to valueBytes : byte[] in method public run() : void in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher.SimpleConsumerThread	From	To
	Rename Attribute	2
	Rename Attribute valueDeserializer : DeserializationSchema<T> to deserializer : KeyedDeserializationSchema<T> in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer	From	To
	Rename Attribute valueDeserializer : DeserializationSchema<T> to deserializer : KeyedDeserializationSchema<T> in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher.SimpleConsumerThread	From	To
	Change Attribute Type	3
	Change Attribute Type valueDeserializer : DeserializationSchema<T> to deserializer : KeyedDeserializationSchema<T> in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher.SimpleConsumerThread	From	To
	Change Attribute Type schema : SerializationSchema<IN,byte[]> to schema : KeyedSerializationSchema<IN> in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer	From	To
	Change Attribute Type valueDeserializer : DeserializationSchema<T> to deserializer : KeyedDeserializationSchema<T> in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer	From	To
	Rename Parameter	3
	Rename Parameter valueDeserializer : DeserializationSchema<T> to deserializer : DeserializationSchema<T> in method public FlinkKafkaConsumer(topic String, deserializer DeserializationSchema<T>, props Properties, offsetStore OffsetStore, fetcherType FetcherType) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer	From	To
	Rename Parameter valueDeserializer : DeserializationSchema<T> to deserializer : KeyedDeserializationSchema<T> in method public SimpleConsumerThread(owner LegacyFetcher, config Properties, topic String, broker Node, partitions FetchPartition[], sourceContext SourceFunction.SourceContext<T>, deserializer KeyedDeserializationSchema<T>, offsetsState long[]) in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher.SimpleConsumerThread	From	To
	Rename Parameter valueDeserializer : DeserializationSchema<T> to deserializer : KeyedDeserializationSchema<T> in method public run(sourceContext SourceFunction.SourceContext<T>, deserializer KeyedDeserializationSchema<T>, lastOffsets long[]) : void in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher	From	To