You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2022/02/16 08:16:41 UTC
[flink-statefun-playground] branch dev updated: [hotfix] Apply spotless on statefun-playground-entrypoint
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 <tr...@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();