[flink-statefun-playground] branch dev updated: [hotfix] Apply spotless on statefun-playground-entrypoint

[trohrmann]

This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/flink-statefun-playground.git


The following commit(s) were added to refs/heads/dev by this push:
     new d381b36  [hotfix] Apply spotless on statefun-playground-entrypoint
d381b36 is described below

commit d381b365b600e8861e7ad1947eb6e6cac960d497
Author: Till Rohrmann <trohrm...@apache.org>
AuthorDate: Wed Feb 16 09:15:10 2022 +0100

    [hotfix] Apply spotless on statefun-playground-entrypoint
---
 .../playground/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 @@ package 
org.apache.flink.statefun.playground.internal.io.flink;
 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<T> extends RichSinkFunction<T> {
   private static final ObjectMapper objectMapper = new ObjectMapper();