rkhachatryan commented on a change in pull request #13234:
URL: https://github.com/apache/flink/pull/13234#discussion_r479120389
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java
##########
@@ -628,4 +621,61 @@ public String toString() {
return builder.toString();
}
+
+ /**
+ * Interface representing chained inputs.
+ */
+ public interface InputConfig extends Serializable {
+ }
+
+ /**
+ * A representation of a Network {@link InputConfig}.
+ */
+ public static class NetworkInputConfig implements InputConfig {
+ private final TypeSerializer<?> typeSerializer;
+ private int inputGateIndex;
+
+ public NetworkInputConfig(TypeSerializer<?> typeSerializer, int
inputGateIndex) {
+ this.typeSerializer = typeSerializer;
+ this.inputGateIndex = inputGateIndex;
+ }
+
+ public TypeSerializer<?> getTypeSerializer() {
+ return typeSerializer;
+ }
+
+ public int getInputGateIndex() {
+ return inputGateIndex;
+ }
+ }
+
+ /**
+ * A serialized representation of an input.
+ */
+ public static class SourceInputConfig implements InputConfig {
+ private final StreamEdge inputEdge;
+
+ public SourceInputConfig(StreamEdge inputEdge) {
+ this.inputEdge = inputEdge;
+ }
+
+ public StreamEdge getInputEdge() {
+ return inputEdge;
+ }
+
+ @Override
+ public String toString() {
+ return inputEdge.toString();
+ }
+
+ @Override
+ public boolean equals(Object obj) {
+ return Objects.equals(obj, inputEdge);
Review comment:
Are we comparing `InputEdge` vs `SourceInputConfig` here?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
