|
Pull Up Method public nextRecord(record OUT) : OUT from class org.apache.flink.api.scala.operators.ScalaCsvInputFormat to public nextRecord(record OUT) : OUT from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Method public setFields(sourceFieldIndices int[], fieldTypes Class<?>[]) : void from class org.apache.flink.api.java.io.CsvInputFormat to public setFields(sourceFieldIndices int[], fieldTypes Class<?>[]) : void from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Method public getFieldTypes() : Class<?>[] from class org.apache.flink.api.scala.operators.ScalaCsvInputFormat to public getFieldTypes() : Class<?>[] from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Method public setFieldTypes(fieldTypes Class<?>...) : void from class org.apache.flink.api.java.io.CsvInputFormat to public setFieldTypes(fieldTypes Class<?>...) : void from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Method public setFieldTypes(fieldTypes Class<?>[]) : void from class org.apache.flink.api.scala.operators.ScalaCsvInputFormat to public setFieldTypes(fieldTypes Class<?>...) : void from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Method public getFieldTypes() : Class<?>[] from class org.apache.flink.api.java.io.CsvInputFormat to public getFieldTypes() : Class<?>[] from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Method public readRecord(reuse OUT, bytes byte[], offset int, numBytes int) : OUT from class org.apache.flink.api.scala.operators.ScalaCsvInputFormat to public readRecord(reuse OUT, bytes byte[], offset int, numBytes int) : OUT from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Method public setOrderOfPOJOFields(fieldsOrder String[]) : void from class org.apache.flink.api.java.io.CsvInputFormat to public setOrderOfPOJOFields(fieldNames String[]) : void from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Method public setOrderOfPOJOFields(fieldsOrder String[]) : void from class org.apache.flink.api.scala.operators.ScalaCsvInputFormat to public setOrderOfPOJOFields(fieldNames String[]) : void from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Method public setFields(sourceFieldMask boolean[], fieldTypes Class<?>[]) : void from class org.apache.flink.api.java.io.CsvInputFormat to public setFields(sourceFieldMask boolean[], fieldTypes Class<?>[]) : void from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Method public setFields(sourceFieldMask boolean[], fieldTypes Class<?>[]) : void from class org.apache.flink.api.scala.operators.ScalaCsvInputFormat to public setFields(sourceFieldMask boolean[], fieldTypes Class<?>[]) : void from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Method public setFields(sourceFieldIndices int[], fieldTypes Class<?>[]) : void from class org.apache.flink.api.scala.operators.ScalaCsvInputFormat to public setFields(sourceFieldIndices int[], fieldTypes Class<?>[]) : void from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Method public open(split FileInputSplit) : void from class org.apache.flink.api.java.io.CsvInputFormat to public open(split FileInputSplit) : void from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Method public nextRecord(record OUT) : OUT from class org.apache.flink.api.java.io.CsvInputFormat to public nextRecord(record OUT) : OUT from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Method public readRecord(reuse OUT, bytes byte[], offset int, numBytes int) : OUT from class org.apache.flink.api.java.io.CsvInputFormat to public readRecord(reuse OUT, bytes byte[], offset int, numBytes int) : OUT from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Method public open(split FileInputSplit) : void from class org.apache.flink.api.scala.operators.ScalaCsvInputFormat to public open(split FileInputSplit) : void from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Attribute private pojoTypeClass : Class<OUT> from class org.apache.flink.api.scala.operators.ScalaCsvInputFormat to private pojoTypeClass : Class<OUT> from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Attribute public DEFAULT_LINE_DELIMITER : String from class org.apache.flink.api.java.io.CsvInputFormat to public DEFAULT_LINE_DELIMITER : String from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Attribute private pojoFields : Field[] from class org.apache.flink.api.java.io.CsvInputFormat to private pojoFields : Field[] from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Attribute private parsedValues : Object[] from class org.apache.flink.api.scala.operators.ScalaCsvInputFormat to protected parsedValues : Object[] from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Attribute private pojoTypeInfo : PojoTypeInfo<OUT> from class org.apache.flink.api.java.io.CsvInputFormat to private pojoTypeInfo : PojoTypeInfo<OUT> from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Attribute public DEFAULT_FIELD_DELIMITER : String from class org.apache.flink.api.java.io.CsvInputFormat to public DEFAULT_FIELD_DELIMITER : String from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Attribute private pojoTypeClass : Class<OUT> from class org.apache.flink.api.java.io.CsvInputFormat to private pojoTypeClass : Class<OUT> from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Attribute private pojoTypeInfo : PojoTypeInfo<OUT> from class org.apache.flink.api.scala.operators.ScalaCsvInputFormat to private pojoTypeInfo : PojoTypeInfo<OUT> from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Attribute private pojoFields : Field[] from class org.apache.flink.api.scala.operators.ScalaCsvInputFormat to private pojoFields : Field[] from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Pull Up Attribute private parsedValues : Object[] from class org.apache.flink.api.java.io.CsvInputFormat to protected parsedValues : Object[] from class org.apache.flink.api.java.io.CommonCsvInputFormat |
From |
To |
|
Change Variable Type typeInfo : TypeInformation<PojoItem> to typeInfo : PojoTypeInfo<PojoItem> in method public testPojoTypeWithMappingInfoAndPartialField() : void in class org.apache.flink.api.java.io.CsvInputFormatTest |
From |
To |
|
Change Variable Type typeInfo : TypeInformation<PrivatePojoItem> to typeInfo : PojoTypeInfo<PrivatePojoItem> in method public testPojoTypeWithPrivateField() : void in class org.apache.flink.api.java.io.CsvInputFormatTest |
From |
To |
|
Change Variable Type sourceType : TypeInformation<Sentence> to sourceType : PojoTypeInfo<Sentence> in method private getTextDataStream(env StreamExecutionEnvironment) : DataStream<Sentence> in class org.apache.flink.stormcompatibility.wordcount.BoltTokenizerWordCountPojo |
From |
To |
|
Change Variable Type typeInfo : TypeInformation<Tuple2<String,String>> to typeInfo : TupleTypeInfo<Tuple2<String,String>> in method public testQuotedStringParsingWithEscapedQuotes() : void in class org.apache.flink.api.java.io.CsvInputFormatTest |
From |
To |
|
Change Variable Type typeInfo : TypeInformation<PojoItem> to typeInfo : PojoTypeInfo<PojoItem> in method public testPojoTypeWithMappingInformation() : void in class org.apache.flink.api.java.io.CsvInputFormatTest |
From |
To |
|
Change Variable Type typeInfo : TypeInformation<Tuple2<String,String>> to typeInfo : CompositeType<Tuple2<String,String>> in method public testQuotedStringParsingWithIncludeFields() : void in class org.apache.flink.api.java.io.CsvInputFormatTest |
From |
To |
|
Change Variable Type typeInfo : TypeInformation<PojoItem> to typeInfo : PojoTypeInfo<PojoItem> in method public testPojoTypeWithInvalidFieldMapping() : void in class org.apache.flink.api.java.io.CsvInputFormatTest |
From |
To |
|
Change Variable Type typeInfo : TypeInformation<PojoItem> to typeInfo : PojoTypeInfo<PojoItem> in method public testPojoTypeWithPartialFieldInCSV() : void in class org.apache.flink.api.java.io.CsvInputFormatTest |
From |
To |
|
Change Variable Type typeInfo : TypeInformation<PojoItem> to typeInfo : PojoTypeInfo<PojoItem> in method public testPojoType() : void in class org.apache.flink.api.java.io.CsvInputFormatTest |
From |
To |
|
Change Variable Type sourceType : TypeInformation<Tuple1<String>> to sourceType : TupleTypeInfo<Tuple1<String>> in method private getTextDataStream(env StreamExecutionEnvironment) : DataStream<Tuple1<String>> in class org.apache.flink.stormcompatibility.wordcount.BoltTokenizerWordCountWithNames |
From |
To |