Package org.apache.beam.runners.jet

Interface DAGBuilder.WiringListener

All Known Implementing Classes:

FlattenP.Supplier, ParDoP.Supplier, StatefulParDoP.Supplier

Enclosing class:

DAGBuilder

public static interface DAGBuilder.WiringListener

Listener that can be registered with a DAGBuilder in order to be notified when edges are being registered.

Method Summary

Modifier and Type	Method	Description
void	isInboundEdgeOfVertex(com.hazelcast.jet.core.Edge edge, java.lang.String edgeId, java.lang.String pCollId, java.lang.String vertexId)
void	isOutboundEdgeOfVertex(com.hazelcast.jet.core.Edge edge, java.lang.String edgeId, java.lang.String pCollId, java.lang.String vertexId)

Method Detail

isOutboundEdgeOfVertex

void isOutboundEdgeOfVertex(com.hazelcast.jet.core.Edge edge,
                            java.lang.String edgeId,
                            java.lang.String pCollId,
                            java.lang.String vertexId)

isInboundEdgeOfVertex

void isInboundEdgeOfVertex(com.hazelcast.jet.core.Edge edge,
                           java.lang.String edgeId,
                           java.lang.String pCollId,
                           java.lang.String vertexId)