org.apache.beam.runners.jet.processors

Class FlattenP.Supplier

java.lang.Object

org.apache.beam.runners.jet.processors.FlattenP.Supplier

All Implemented Interfaces:

com.hazelcast.jet.function.SupplierEx<com.hazelcast.jet.core.Processor>, java.io.Serializable, java.util.function.Supplier<com.hazelcast.jet.core.Processor>, DAGBuilder.WiringListener

Enclosing class:

FlattenP

public static final class FlattenP.Supplier
extends java.lang.Object
implements com.hazelcast.jet.function.SupplierEx<com.hazelcast.jet.core.Processor>, DAGBuilder.WiringListener

Jet Processor supplier that will provide instances of FlattenP.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Supplier(java.util.Map<java.lang.String,Coder> inputCoders, Coder outputCoder, java.lang.String ownerId)

Method Summary

Modifier and Type	Method and Description
com.hazelcast.jet.core.Processor	getEx()
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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.hazelcast.jet.function.SupplierEx

get

Constructor Detail

Supplier

public Supplier(java.util.Map<java.lang.String,Coder> inputCoders,
                Coder outputCoder,
                java.lang.String ownerId)

Method Detail

getEx

public com.hazelcast.jet.core.Processor getEx()

Specified by:

getEx in interface com.hazelcast.jet.function.SupplierEx<com.hazelcast.jet.core.Processor>

isOutboundEdgeOfVertex

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

Specified by:

isOutboundEdgeOfVertex in interface DAGBuilder.WiringListener

isInboundEdgeOfVertex

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

Specified by:

isInboundEdgeOfVertex in interface DAGBuilder.WiringListener