From c5335e8c5dbaa7d3a6bb84154161c7e593ff0afe Mon Sep 17 00:00:00 2001 From: Till Rohrmann Date: Wed, 16 Feb 2022 09:03:20 +0100 Subject: [PATCH] [hotfix] Apply spotless on statefun-playground-entrypoint --- .../internal/io/flink/EgressRecord.java | 22 +++++++++---------- .../internal/io/flink/PlaygroundEgress.java | 10 ++++----- 2 files changed, 15 insertions(+), 17 deletions(-) diff --git a/playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressRecord.java b/playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressRecord.java index e53d2f2..b8e47f2 100644 --- a/playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressRecord.java +++ b/playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressRecord.java @@ -3,19 +3,19 @@ import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.annotation.JsonProperty; public class EgressRecord { - @JsonProperty("topic") - private String topic; + @JsonProperty("topic") + private String topic; - @JsonProperty("payload") - private String payload; + @JsonProperty("payload") + private String payload; - public EgressRecord() {} + public EgressRecord() {} - public String getTopic() { - return topic; - } + public String getTopic() { + return topic; + } - public String getPayload() { - return payload; - } + public String getPayload() { + return payload; + } } diff --git a/playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundEgress.java b/playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundEgress.java index d98ff8c..e97ea68 100644 --- a/playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundEgress.java +++ b/playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundEgress.java @@ -1,16 +1,14 @@ package org.apache.flink.statefun.playground.internal.io.flink; -import org.apache.flink.configuration.Configuration; -import org.apache.flink.statefun.playground.internal.io.Constants; -import org.apache.flink.statefun.sdk.reqreply.generated.TypedValue; -import org.apache.flink.streaming.api.functions.sink.RichSinkFunction; - import com.fasterxml.jackson.databind.ObjectMapper; import com.google.protobuf.ByteString; - import java.io.IOException; import java.util.HashSet; import java.util.Set; +import org.apache.flink.configuration.Configuration; +import org.apache.flink.statefun.playground.internal.io.Constants; +import org.apache.flink.statefun.sdk.reqreply.generated.TypedValue; +import org.apache.flink.streaming.api.functions.sink.RichSinkFunction; class PlaygroundEgress extends RichSinkFunction { private static final ObjectMapper objectMapper = new ObjectMapper();