Class FlattenP.Supplier
java.lang.Object
org.apache.beam.runners.jet.processors.FlattenP.Supplier
- All Implemented Interfaces:
com.hazelcast.function.SupplierEx<com.hazelcast.jet.core.Processor>
,Serializable
,Supplier<com.hazelcast.jet.core.Processor>
,DAGBuilder.WiringListener
- Enclosing class:
FlattenP
public static final class FlattenP.Supplier
extends Object
implements com.hazelcast.function.SupplierEx<com.hazelcast.jet.core.Processor>, DAGBuilder.WiringListener
Jet
Processor
supplier that will provide instances of FlattenP
.- See Also:
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptioncom.hazelcast.jet.core.Processor
getEx()
void
isInboundEdgeOfVertex
(com.hazelcast.jet.core.Edge edge, String edgeId, String pCollId, String vertexId) void
isOutboundEdgeOfVertex
(com.hazelcast.jet.core.Edge edge, String edgeId, String pCollId, String vertexId) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface com.hazelcast.function.SupplierEx
get
-
Constructor Details
-
Supplier
-
-
Method Details
-
getEx
public com.hazelcast.jet.core.Processor getEx()- Specified by:
getEx
in interfacecom.hazelcast.function.SupplierEx<com.hazelcast.jet.core.Processor>
-
isOutboundEdgeOfVertex
public void isOutboundEdgeOfVertex(com.hazelcast.jet.core.Edge edge, String edgeId, String pCollId, String vertexId) - Specified by:
isOutboundEdgeOfVertex
in interfaceDAGBuilder.WiringListener
-
isInboundEdgeOfVertex
public void isInboundEdgeOfVertex(com.hazelcast.jet.core.Edge edge, String edgeId, String pCollId, String vertexId) - Specified by:
isInboundEdgeOfVertex
in interfaceDAGBuilder.WiringListener
-