Skip to content
Permalink
Browse files
[hotfix] Apply spotless on statefun-playground-entrypoint
  • Loading branch information
tillrohrmann committed Feb 16, 2022
1 parent 1ba46ba commit c5335e8c5dbaa7d3a6bb84154161c7e593ff0afe
Showing 2 changed files with 15 additions and 17 deletions.
@@ -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;
}
}
@@ -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();

0 comments on commit c5335e8

Please sign in to comment.