|
Change Parameter Type serializationSchema : SerializationSchema<IN,byte[]> to serializationSchema : SerializationSchema<IN> in method public FlinkKafkaProducer(topicId String, serializationSchema SerializationSchema<IN>, producerConfig Properties, customPartitioner KafkaPartitioner) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer |
From |
To |
|
Change Parameter Type schema : SerializationSchema<IN,byte[]> to schema : SerializationSchema<IN> in method public SocketClientSink(hostName String, port int, schema SerializationSchema<IN>, maxNumRetries int, autoflush boolean) in class org.apache.flink.streaming.api.functions.sink.SocketClientSink |
From |
To |
|
Change Parameter Type schema : SerializationSchema<IN,byte[]> to schema : SerializationSchema<IN> in method public FlumeSink(host String, port int, schema SerializationSchema<IN>) in class org.apache.flink.streaming.connectors.flume.FlumeSink |
From |
To |
|
Change Parameter Type serializationSchema : SerializationSchema<T,byte[]> to serializationSchema : SerializationSchema<T> in method public KeyedSerializationSchemaWrapper(serializationSchema SerializationSchema<T>) in class org.apache.flink.streaming.util.serialization.KeyedSerializationSchemaWrapper |
From |
To |
|
Change Parameter Type schema : SerializationSchema<IN,byte[]> to schema : SerializationSchema<IN> in method public RMQSink(HOST_NAME String, QUEUE_NAME String, schema SerializationSchema<IN>) in class org.apache.flink.streaming.connectors.rabbitmq.RMQSink |
From |
To |
|
Change Parameter Type serializationSchema : SerializationSchema<IN,byte[]> to serializationSchema : SerializationSchema<IN> in method public FlinkKafkaProducer(topicId String, serializationSchema SerializationSchema<IN>, producerConfig Properties) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer |
From |
To |
|
Change Parameter Type serializationSchema : SerializationSchema<IN,byte[]> to serializationSchema : SerializationSchema<IN> in method public FlinkKafkaProducer(brokerList String, topicId String, serializationSchema SerializationSchema<IN>) in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer |
From |
To |
|
Change Parameter Type schema : SerializationSchema<IN,byte[]> to schema : SerializationSchema<IN> in method public SocketClientSink(hostName String, port int, schema SerializationSchema<IN>) in class org.apache.flink.streaming.api.functions.sink.SocketClientSink |
From |
To |
|
Change Parameter Type serializationSchema : SerializationSchema<IN,byte[]> to serializationSchema : SerializationSchema<IN> in method public KafkaSink(brokerList String, topicId String, serializationSchema SerializationSchema<IN>) in class org.apache.flink.streaming.connectors.kafka.api.KafkaSink |
From |
To |
|
Change Parameter Type schema : SerializationSchema<IN,byte[]> to schema : SerializationSchema<IN> in method public SocketClientSink(hostName String, port int, schema SerializationSchema<IN>, maxNumRetries int) in class org.apache.flink.streaming.api.functions.sink.SocketClientSink |
From |
To |
|
Change Parameter Type schema : SerializationSchema<T,byte[]> to schema : SerializationSchema<T> in method public writeToSocket(hostName String, port int, schema SerializationSchema<T>) : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Attribute Type serializationSchema : SerializationSchema<T,byte[]> to serializationSchema : SerializationSchema<T> in class org.apache.flink.streaming.util.serialization.KeyedSerializationSchemaWrapper |
From |
To |
|
Change Attribute Type schema : SerializationSchema<IN,byte[]> to schema : SerializationSchema<IN> in class org.apache.flink.streaming.connectors.flume.FlumeSink |
From |
To |
|
Change Attribute Type schema : SerializationSchema<IN,byte[]> to schema : SerializationSchema<IN> in class org.apache.flink.streaming.connectors.rabbitmq.RMQSink |
From |
To |
|
Change Attribute Type simpleSchema : SerializationSchema<String,byte[]> to simpleSchema : SerializationSchema<String> in class org.apache.flink.streaming.api.functions.sink.SocketClientSinkTest |
From |
To |
|
Change Attribute Type schema : SerializationSchema<IN,byte[]> to schema : SerializationSchema<IN> in class org.apache.flink.streaming.api.functions.sink.SocketClientSink |
From |
To |