|
Pull Up Method public getProducedType() : TypeInformation<Row> from class org.apache.flink.streaming.util.serialization.JsonRowDeserializationSchema to public getProducedType() : TypeInformation<Row> from class org.apache.flink.formats.json.JsonRowDeserializationSchema |
From |
To |
|
Pull Up Method public setFailOnMissingField(failOnMissingField boolean) : void from class org.apache.flink.streaming.util.serialization.JsonRowDeserializationSchema to public setFailOnMissingField(failOnMissingField boolean) : void from class org.apache.flink.formats.json.JsonRowDeserializationSchema |
From |
To |
|
Pull Up Method public isEndOfStream(nextElement Row) : boolean from class org.apache.flink.streaming.util.serialization.JsonRowDeserializationSchema to public isEndOfStream(nextElement Row) : boolean from class org.apache.flink.formats.json.JsonRowDeserializationSchema |
From |
To |
|
Pull Up Method public deserialize(message byte[]) : Row from class org.apache.flink.streaming.util.serialization.JsonRowDeserializationSchema to public deserialize(message byte[]) : Row from class org.apache.flink.formats.json.JsonRowDeserializationSchema |
From |
To |
|
Pull Up Method public deserialize(message byte[]) : ObjectNode from class org.apache.flink.streaming.util.serialization.JSONDeserializationSchema to public deserialize(message byte[]) : ObjectNode from class org.apache.flink.formats.json.JsonNodeDeserializationSchema |
From |
To |
|
Pull Up Method public serialize(row Row) : byte[] from class org.apache.flink.streaming.util.serialization.JsonRowSerializationSchema to public serialize(row Row) : byte[] from class org.apache.flink.formats.json.JsonRowSerializationSchema |
From |
To |
|
Pull Up Attribute private failOnMissingField : boolean from class org.apache.flink.streaming.util.serialization.JsonRowDeserializationSchema to private failOnMissingField : boolean from class org.apache.flink.formats.json.JsonRowDeserializationSchema |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.util.serialization.JSONDeserializationSchema to private serialVersionUID : long from class org.apache.flink.formats.json.JsonNodeDeserializationSchema |
From |
To |
|
Pull Up Attribute private mapper : ObjectMapper from class org.apache.flink.streaming.util.serialization.JSONDeserializationSchema to private mapper : ObjectMapper from class org.apache.flink.formats.json.JsonNodeDeserializationSchema |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.util.serialization.JsonRowDeserializationSchema to private serialVersionUID : long from class org.apache.flink.formats.json.JsonRowDeserializationSchema |
From |
To |
|
Pull Up Attribute private objectMapper : ObjectMapper from class org.apache.flink.streaming.util.serialization.JsonRowDeserializationSchema to private objectMapper : ObjectMapper from class org.apache.flink.formats.json.JsonRowDeserializationSchema |
From |
To |
|
Pull Up Attribute private mapper : ObjectMapper from class org.apache.flink.streaming.util.serialization.JsonRowSerializationSchema to private mapper : ObjectMapper from class org.apache.flink.formats.json.JsonRowSerializationSchema |
From |
To |
|
Pull Up Attribute private typeInfo : TypeInformation<Row> from class org.apache.flink.streaming.util.serialization.JsonRowDeserializationSchema to private typeInfo : TypeInformation<Row> from class org.apache.flink.formats.json.JsonRowDeserializationSchema |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.util.serialization.JsonRowSerializationSchema to private serialVersionUID : long from class org.apache.flink.formats.json.JsonRowSerializationSchema |
From |
To |