This is an automated email from the ASF dual-hosted git repository. rmetzger pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git
commit d818ccb2f6317e910764908af55937762a33c377 Author: Fabian Paul <[email protected]> AuthorDate: Wed Sep 15 16:49:16 2021 +0200 [hotfix][connectors/kafka] Rename EventDeSerializer to EventDeSerializationSchema in examples --- .../streaming/examples/statemachine/KafkaEventsGeneratorJob.java | 4 ++-- .../flink/streaming/examples/statemachine/StateMachineExample.java | 4 ++-- .../kafka/{EventDeSerializer.java => EventDeSerializationSchema.java} | 3 ++- .../examples/statemachine/kafka/KafkaStandaloneGenerator.java | 4 ++-- 4 files changed, 8 insertions(+), 7 deletions(-) diff --git a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/KafkaEventsGeneratorJob.java b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/KafkaEventsGeneratorJob.java index 822d17c..a065f84 100644 --- a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/KafkaEventsGeneratorJob.java +++ b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/KafkaEventsGeneratorJob.java @@ -24,7 +24,7 @@ import org.apache.flink.connector.kafka.sink.KafkaSink; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.streaming.examples.statemachine.event.Event; import org.apache.flink.streaming.examples.statemachine.generator.EventsGeneratorSource; -import org.apache.flink.streaming.examples.statemachine.kafka.EventDeSerializer; +import org.apache.flink.streaming.examples.statemachine.kafka.EventDeSerializationSchema; /** * Job to generate input events that are written to Kafka, for the {@link StateMachineExample} job. @@ -55,7 +55,7 @@ public class KafkaEventsGeneratorJob { .setRecordSerializer( KafkaRecordSerializationSchema.builder() .setValueSerializationSchema( - new EventDeSerializer()) + new EventDeSerializationSchema()) .setTopic(kafkaTopic) .build()) .build()); diff --git a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/StateMachineExample.java b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/StateMachineExample.java index 93d3326..72a1587 100644 --- a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/StateMachineExample.java +++ b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/StateMachineExample.java @@ -36,7 +36,7 @@ import org.apache.flink.streaming.examples.statemachine.dfa.State; import org.apache.flink.streaming.examples.statemachine.event.Alert; import org.apache.flink.streaming.examples.statemachine.event.Event; import org.apache.flink.streaming.examples.statemachine.generator.EventsGeneratorSource; -import org.apache.flink.streaming.examples.statemachine.kafka.EventDeSerializer; +import org.apache.flink.streaming.examples.statemachine.kafka.EventDeSerializationSchema; import org.apache.flink.util.Collector; /** @@ -102,7 +102,7 @@ public class StateMachineExample { .setTopics(kafkaTopic) .setDeserializer( KafkaRecordDeserializationSchema.valueOnly( - new EventDeSerializer())) + new EventDeSerializationSchema())) .setStartingOffsets(OffsetsInitializer.latest()) .build(); events = diff --git a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/kafka/EventDeSerializer.java b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/kafka/EventDeSerializationSchema.java similarity index 95% rename from flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/kafka/EventDeSerializer.java rename to flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/kafka/EventDeSerializationSchema.java index a0f4099..42bd675 100644 --- a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/kafka/EventDeSerializer.java +++ b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/kafka/EventDeSerializationSchema.java @@ -29,7 +29,8 @@ import java.nio.ByteBuffer; import java.nio.ByteOrder; /** A serializer and deserializer for the {@link Event} type. */ -public class EventDeSerializer implements DeserializationSchema<Event>, SerializationSchema<Event> { +public class EventDeSerializationSchema + implements DeserializationSchema<Event>, SerializationSchema<Event> { private static final long serialVersionUID = 1L; diff --git a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/kafka/KafkaStandaloneGenerator.java b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/kafka/KafkaStandaloneGenerator.java index 4c4acd7..781cb09 100644 --- a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/kafka/KafkaStandaloneGenerator.java +++ b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/kafka/KafkaStandaloneGenerator.java @@ -59,7 +59,7 @@ public class KafkaStandaloneGenerator extends StandaloneThreadedGenerator { private final KafkaProducer<Object, byte[]> producer; - private final EventDeSerializer serializer; + private final EventDeSerializationSchema serializer; private final String topic; @@ -68,7 +68,7 @@ public class KafkaStandaloneGenerator extends StandaloneThreadedGenerator { KafkaCollector(String brokerAddress, String topic, int partition) { this.topic = checkNotNull(topic); this.partition = partition; - this.serializer = new EventDeSerializer(); + this.serializer = new EventDeSerializationSchema(); // create Kafka producer Properties properties = new Properties();
