flink 537a10ea2ff6a2d8507483c66f413f77884e77c4

537a10ea2ff6a2d8507483c66f413f77884e77c4

Files Diff

Added: 34
Removed: 34
Renamed: 0
Modified: 27

Link to commit

Dependency Action
Removed
	org.apache.avro:avro-ipc:1.8.2
	org.apache.avro:avro:1.8.2

Refactorings reported:

Refactoring Name	Occurences
Rename Method	1
Rename Method public testAvroOut() : void renamed to public testChangingFileNames() : void in class org.apache.flink.hdfstests.HDFSTest	From	To
Move And Rename Method	1
Move And Rename Method private checkAndAddSerializerForTypeAvro(reg ExecutionConfig, type Class<?>) : void from class org.apache.flink.api.java.typeutils.runtime.kryo.Serializers to public addAvroSerializers(reg ExecutionConfig, type Class<?>) : void from class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils	From	To
Change Parameter Type	2
Change Parameter Type codec : Codec to codec : AvroOutputFormat.Codec in method private serializeAndDeserialize(codec AvroOutputFormat.Codec, schema Schema) : void in class org.apache.flink.formats.avro.AvroOutputFormatTest	From	To
Change Parameter Type typeHierarchy : ArrayList<Type> to typeHierarchy : List<Type> in method public getTypeHierarchy(typeHierarchy List<Type>, t Type, stopAtClass Class<?>) : Type in class org.apache.flink.api.java.typeutils.TypeExtractionUtils	From	To
Move Method	1
Move Method private getTypeHierarchy(typeHierarchy ArrayList<Type>, t Type, stopAtClass Class<?>) : Type from class org.apache.flink.api.java.typeutils.TypeExtractor to public getTypeHierarchy(typeHierarchy List<Type>, t Type, stopAtClass Class<?>) : Type from class org.apache.flink.api.java.typeutils.TypeExtractionUtils	From	To
Rename Variable	2
Rename Variable result : Path to hdfsPath : Path in method public testChangingFileNames() : void in class org.apache.flink.hdfstests.HDFSTest	From	To
Rename Variable avroOut : AvroOutputFormat<String> to outputFormat : TextOutputFormat<String> in method public testChangingFileNames() : void in class org.apache.flink.hdfstests.HDFSTest	From	To
Move And Rename Class	1
Move And Rename Class org.apache.flink.api.io.avro.AvroPojoTest moved and renamed to org.apache.flink.formats.avro.typeutils.AvroTypeExtractionTest	From	To
Move Class	25
Move Class org.apache.flink.streaming.util.serialization.AvroRowDeserializationSchema moved to org.apache.flink.formats.avro.AvroRowDeserializationSchema	From	To
Move Class org.apache.flink.api.java.typeutils.AvroTypeInfoTest moved to org.apache.flink.formats.avro.typeutils.AvroTypeInfoTest	From	To
Move Class org.apache.flink.api.avro.testjar.AvroExternalJarProgram moved to org.apache.flink.formats.avro.testjar.AvroExternalJarProgram	From	To
Move Class org.apache.flink.api.avro.DataOutputEncoder moved to org.apache.flink.formats.avro.utils.DataOutputEncoder	From	To
Move Class org.apache.flink.api.java.typeutils.runtime.AvroSerializerEmptyArrayTest moved to org.apache.flink.formats.avro.typeutils.AvroSerializerEmptyArrayTest	From	To
Move Class org.apache.flink.api.avro.DataInputDecoder moved to org.apache.flink.formats.avro.utils.DataInputDecoder	From	To
Move Class org.apache.flink.streaming.connectors.kafka.AvroRowDeSerializationSchemaTest moved to org.apache.flink.formats.avro.AvroRowDeSerializationSchemaTest	From	To
Move Class org.apache.flink.api.java.io.AvroInputFormatTypeExtractionTest moved to org.apache.flink.formats.avro.AvroInputFormatTypeExtractionTest	From	To
Move Class org.apache.flink.api.io.avro.AvroRecordInputFormatTest moved to org.apache.flink.formats.avro.AvroRecordInputFormatTest	From	To
Move Class org.apache.flink.streaming.connectors.kafka.testutils.AvroTestUtils moved to org.apache.flink.formats.avro.utils.AvroTestUtils	From	To
Move Class org.apache.flink.api.java.io.AvroOutputFormatTest moved to org.apache.flink.formats.avro.AvroOutputFormatTest	From	To
Move Class org.apache.flink.api.avro.AvroOutputFormatITCase moved to org.apache.flink.formats.avro.AvroOutputFormatITCase	From	To
Move Class org.apache.flink.api.java.io.AvroInputFormat moved to org.apache.flink.formats.avro.AvroInputFormat	From	To
Move Class org.apache.flink.api.avro.FSDataInputStreamWrapper moved to org.apache.flink.formats.avro.utils.FSDataInputStreamWrapper	From	To
Move Class org.apache.flink.api.io.avro.AvroSplittableInputFormatTest moved to org.apache.flink.formats.avro.AvroSplittableInputFormatTest	From	To
Move Class org.apache.flink.api.java.typeutils.AvroTypeInfo moved to org.apache.flink.formats.avro.typeutils.AvroTypeInfo	From	To
Move Class org.apache.flink.api.java.typeutils.runtime.AvroGenericArraySerializerTest moved to org.apache.flink.formats.avro.typeutils.AvroGenericArraySerializerTest	From	To
Move Class org.apache.flink.streaming.util.serialization.AvroRowSerializationSchema moved to org.apache.flink.formats.avro.AvroRowSerializationSchema	From	To
Move Class org.apache.flink.api.java.io.AvroOutputFormat moved to org.apache.flink.formats.avro.AvroOutputFormat	From	To
Move Class org.apache.flink.api.avro.EncoderDecoderTest moved to org.apache.flink.formats.avro.EncoderDecoderTest	From	To
Move Class org.apache.flink.api.java.typeutils.runtime.kryo.Serializers.AvroSchemaSerializer moved to org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils.AvroSchemaSerializer	From	To
Move Class org.apache.flink.api.java.typeutils.runtime.AvroSerializer moved to org.apache.flink.formats.avro.typeutils.AvroSerializer	From	To
Move Class org.apache.flink.api.java.typeutils.runtime.AvroGenericTypeComparatorTest moved to org.apache.flink.formats.avro.typeutils.AvroGenericTypeComparatorTest	From	To
Move Class org.apache.flink.api.avro.AvroExternalJarProgramITCase moved to org.apache.flink.formats.avro.AvroExternalJarProgramITCase	From	To
Move Class org.apache.flink.api.java.typeutils.runtime.AvroGenericTypeSerializerTest moved to org.apache.flink.formats.avro.typeutils.AvroGenericTypeSerializerTest	From	To
Change Variable Type	3
Change Variable Type codec : Codec to codec : AvroOutputFormat.Codec in method public testSerialization() : void in class org.apache.flink.formats.avro.AvroOutputFormatTest	From	To
Change Variable Type restoredCodec : Codec to restoredCodec : AvroOutputFormat.Codec in method private serializeAndDeserialize(codec AvroOutputFormat.Codec, schema Schema) : void in class org.apache.flink.formats.avro.AvroOutputFormatTest	From	To
Change Variable Type avroOut : AvroOutputFormat<String> to outputFormat : TextOutputFormat<String> in method public testChangingFileNames() : void in class org.apache.flink.hdfstests.HDFSTest	From	To
Change Package	5
Change Package org.apache.flink.api to org.apache.flink.formats	From	To
Change Package org.apache.flink.api.java.io to org.apache.flink.formats.avro	From	To
Change Package org.apache.flink.api.java to org.apache.flink.formats.avro	From	To
Change Package org.apache.flink.api.io to org.apache.flink.formats	From	To
Change Package org.apache.flink.api.avro to org.apache.flink.formats.avro.utils	From	To

537a10ea2ff6a2d8507483c66f413f77884e77c4

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: