|
Change Parameter Type typeInfo : TypeInformation<?>[] to typeInfo : TypeInformation<Row> in method protected createTableSource(topic String, properties Properties, typeInfo TypeInformation<Row>) : KafkaTableSource in class org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSourceTest |
From |
To |
|
Change Parameter Type typeInfo : TypeInformation<?>[] to typeInfo : TypeInformation<Row> in method protected createTableSource(topic String, properties Properties, typeInfo TypeInformation<Row>) : KafkaTableSource in class org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSourceTest |
From |
To |
|
Change Parameter Type typeInfo : TypeInformation<?>[] to typeInfo : TypeInformation<Row> in method protected abstract createTableSource(topic String, properties Properties, typeInfo TypeInformation<Row>) : KafkaTableSource in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceTestBase |
From |
To |
|
Change Parameter Type fieldTypes : Class[] to fieldTypes : TypeInformation<?>[] in method private serializeAndDeserialize(fieldNames String[], fieldTypes TypeInformation<?>[], row Row) : Row in class org.apache.flink.streaming.connectors.kafka.JsonRowSerializationSchemaTest |
From |
To |
|
Merge Parameter [fieldNames : String[], fieldTypes : TypeInformation<?>[]] to typeInfo : TypeInformation<Row> in method private createDeserializationSchema(typeInfo TypeInformation<Row>) : JsonRowDeserializationSchema in class org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSource |
From |
To |
|
Merge Parameter [fieldNames : String[], fieldTypes : TypeInformation<?>[]] to typeInfo : TypeInformation<Row> in method public Kafka09JsonTableSource(topic String, properties Properties, typeInfo TypeInformation<Row>) in class org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSource |
From |
To |
|
Merge Parameter [fieldNames : String[], fieldTypes : TypeInformation<?>[]] to typeInfo : TypeInformation<Row> in method public Kafka010JsonTableSource(topic String, properties Properties, typeInfo TypeInformation<Row>) in class org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSource |
From |
To |
|
Merge Parameter [fieldNames : String[], fieldTypes : TypeInformation<?>[]] to typeInfo : TypeInformation<Row> in method public Kafka08TableSource(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>, typeInfo TypeInformation<Row>) in class org.apache.flink.streaming.connectors.kafka.Kafka08TableSource |
From |
To |
|
Merge Parameter [fieldNames : String[], fieldTypes : TypeInformation<?>[]] to typeInfo : TypeInformation<Row> in method public Kafka010TableSource(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>, typeInfo TypeInformation<Row>) in class org.apache.flink.streaming.connectors.kafka.Kafka010TableSource |
From |
To |
|
Merge Parameter [fieldNames : String[], fieldTypes : TypeInformation<?>[]] to typeInfo : TypeInformation<Row> in method public Kafka08JsonTableSource(topic String, properties Properties, typeInfo TypeInformation<Row>) in class org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSource |
From |
To |
|
Merge Parameter [fieldNames : String[], fieldTypes : TypeInformation<?>[]] to typeInfo : TypeInformation<Row> in method public Kafka09TableSource(topic String, properties Properties, deserializationSchema DeserializationSchema<Row>, typeInfo TypeInformation<Row>) in class org.apache.flink.streaming.connectors.kafka.Kafka09TableSource |
From |
To |