|
Pull Up Method public isEndOfStream(nextElement String) : boolean from class org.apache.flink.streaming.util.serialization.SimpleStringSchema to public isEndOfStream(nextElement String) : boolean from class org.apache.flink.api.common.serialization.SimpleStringSchema |
From |
To |
|
Pull Up Method public isEndOfStream(nextElement T) : boolean from class org.apache.flink.streaming.util.serialization.TypeInformationSerializationSchema to public isEndOfStream(nextElement T) : boolean from class org.apache.flink.api.common.serialization.TypeInformationSerializationSchema |
From |
To |
|
Pull Up Method private readObject(in ObjectInputStream) : void from class org.apache.flink.streaming.util.serialization.SimpleStringSchema to private readObject(in ObjectInputStream) : void from class org.apache.flink.api.common.serialization.SimpleStringSchema |
From |
To |
|
Pull Up Method public deserialize(message byte[]) : T from class org.apache.flink.streaming.util.serialization.TypeInformationSerializationSchema to public deserialize(message byte[]) : T from class org.apache.flink.api.common.serialization.TypeInformationSerializationSchema |
From |
To |
|
Pull Up Method public getProducedType() : TypeInformation<T> from class org.apache.flink.streaming.util.serialization.TypeInformationSerializationSchema to public getProducedType() : TypeInformation<T> from class org.apache.flink.api.common.serialization.TypeInformationSerializationSchema |
From |
To |
|
Pull Up Method private writeObject(out ObjectOutputStream) : void from class org.apache.flink.streaming.util.serialization.SimpleStringSchema to private writeObject(out ObjectOutputStream) : void from class org.apache.flink.api.common.serialization.SimpleStringSchema |
From |
To |
|
Pull Up Method public getProducedType() : TypeInformation<String> from class org.apache.flink.streaming.util.serialization.SimpleStringSchema to public getProducedType() : TypeInformation<String> from class org.apache.flink.api.common.serialization.SimpleStringSchema |
From |
To |
|
Pull Up Method public getCharset() : Charset from class org.apache.flink.streaming.util.serialization.SimpleStringSchema to public getCharset() : Charset from class org.apache.flink.api.common.serialization.SimpleStringSchema |
From |
To |
|
Pull Up Method public abstract deserialize(message byte[]) : T from class org.apache.flink.streaming.util.serialization.AbstractDeserializationSchema to public abstract deserialize(message byte[]) : T from class org.apache.flink.api.common.serialization.AbstractDeserializationSchema |
From |
To |
|
Pull Up Method public isEndOfStream(nextElement T) : boolean from class org.apache.flink.streaming.util.serialization.AbstractDeserializationSchema to public isEndOfStream(nextElement T) : boolean from class org.apache.flink.api.common.serialization.AbstractDeserializationSchema |
From |
To |
|
Pull Up Method public deserialize(message byte[]) : String from class org.apache.flink.streaming.util.serialization.SimpleStringSchema to public deserialize(message byte[]) : String from class org.apache.flink.api.common.serialization.SimpleStringSchema |
From |
To |
|
Pull Up Method public serialize(element String) : byte[] from class org.apache.flink.streaming.util.serialization.SimpleStringSchema to public serialize(element String) : byte[] from class org.apache.flink.api.common.serialization.SimpleStringSchema |
From |
To |
|
Pull Up Method public getProducedType() : TypeInformation<T> from class org.apache.flink.streaming.util.serialization.AbstractDeserializationSchema to public getProducedType() : TypeInformation<T> from class org.apache.flink.api.common.serialization.AbstractDeserializationSchema |
From |
To |
|
Pull Up Method public serialize(element T) : byte[] from class org.apache.flink.streaming.util.serialization.TypeInformationSerializationSchema to public serialize(element T) : byte[] from class org.apache.flink.api.common.serialization.TypeInformationSerializationSchema |
From |
To |
|
Pull Up Attribute private serializer : TypeSerializer<T> from class org.apache.flink.streaming.util.serialization.TypeInformationSerializationSchema to private serializer : TypeSerializer<T> from class org.apache.flink.api.common.serialization.TypeInformationSerializationSchema |
From |
To |
|
Pull Up Attribute private dis : DataInputDeserializer from class org.apache.flink.streaming.util.serialization.TypeInformationSerializationSchema to private dis : DataInputDeserializer from class org.apache.flink.api.common.serialization.TypeInformationSerializationSchema |
From |
To |
|
Pull Up Attribute private typeInfo : TypeInformation<T> from class org.apache.flink.streaming.util.serialization.TypeInformationSerializationSchema to private typeInfo : TypeInformation<T> from class org.apache.flink.api.common.serialization.TypeInformationSerializationSchema |
From |
To |
|
Pull Up Attribute private charset : Charset from class org.apache.flink.streaming.util.serialization.SimpleStringSchema to private charset : Charset from class org.apache.flink.api.common.serialization.SimpleStringSchema |
From |
To |
|
Pull Up Attribute private dos : DataOutputSerializer from class org.apache.flink.streaming.util.serialization.TypeInformationSerializationSchema to private dos : DataOutputSerializer from class org.apache.flink.api.common.serialization.TypeInformationSerializationSchema |
From |
To |