|
Change Parameter Type scheme : SerializationScheme<IN,byte[]> to schema : SerializationSchema<IN,byte[]> in method public FlumeSink(host String, port int, schema SerializationSchema<IN,byte[]>) in class org.apache.flink.streaming.connectors.flume.FlumeSink |
From |
To |
|
Change Parameter Type scheme : DeserializationScheme<OUT> to deserializationSchema : DeserializationSchema<OUT> in method public RMQSource(HOST_NAME String, QUEUE_NAME String, deserializationSchema DeserializationSchema<OUT>) in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource |
From |
To |
|
Change Parameter Type scheme : DeserializationScheme<OUT> to deserializationSchema : DeserializationSchema<OUT> in method package FlumeSource(host String, port int, deserializationSchema DeserializationSchema<OUT>) in class org.apache.flink.streaming.connectors.flume.FlumeSource |
From |
To |
|
Change Parameter Type deserializationScheme : DeserializationScheme<OUT> to deserializationSchema : DeserializationSchema<OUT> in method public KafkaSource(zkQuorum String, groupId String, topicId String, deserializationSchema DeserializationSchema<OUT>) in class org.apache.flink.streaming.connectors.kafka.KafkaSource |
From |
To |
|
Change Parameter Type scheme : SerializationScheme<IN,byte[]> to schema : SerializationSchema<IN,byte[]> in method public RMQSink(HOST_NAME String, QUEUE_NAME String, schema SerializationSchema<IN,byte[]>) in class org.apache.flink.streaming.connectors.rabbitmq.RMQSink |
From |
To |
|
Change Parameter Type serializationScheme : SerializationScheme<IN,OUT> to serializationSchema : SerializationSchema<IN,OUT> in method public KafkaSink(topicId String, brokerAddr String, serializationSchema SerializationSchema<IN,OUT>) in class org.apache.flink.streaming.connectors.kafka.KafkaSink |
From |
To |
|
Rename Parameter scheme : SerializationScheme<IN,byte[]> to schema : SerializationSchema<IN,byte[]> in method public RMQSink(HOST_NAME String, QUEUE_NAME String, schema SerializationSchema<IN,byte[]>) in class org.apache.flink.streaming.connectors.rabbitmq.RMQSink |
From |
To |
|
Rename Parameter serializationScheme : SerializationScheme<IN,OUT> to serializationSchema : SerializationSchema<IN,OUT> in method public KafkaSink(topicId String, brokerAddr String, serializationSchema SerializationSchema<IN,OUT>) in class org.apache.flink.streaming.connectors.kafka.KafkaSink |
From |
To |
|
Rename Parameter scheme : SerializationScheme<IN,byte[]> to schema : SerializationSchema<IN,byte[]> in method public FlumeSink(host String, port int, schema SerializationSchema<IN,byte[]>) in class org.apache.flink.streaming.connectors.flume.FlumeSink |
From |
To |
|
Rename Parameter scheme : DeserializationScheme<OUT> to deserializationSchema : DeserializationSchema<OUT> in method public RMQSource(HOST_NAME String, QUEUE_NAME String, deserializationSchema DeserializationSchema<OUT>) in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource |
From |
To |
|
Rename Parameter scheme : DeserializationScheme<OUT> to deserializationSchema : DeserializationSchema<OUT> in method package FlumeSource(host String, port int, deserializationSchema DeserializationSchema<OUT>) in class org.apache.flink.streaming.connectors.flume.FlumeSource |
From |
To |
|
Rename Parameter deserializationScheme : DeserializationScheme<OUT> to deserializationSchema : DeserializationSchema<OUT> in method public KafkaSource(zkQuorum String, groupId String, topicId String, deserializationSchema DeserializationSchema<OUT>) in class org.apache.flink.streaming.connectors.kafka.KafkaSource |
From |
To |