Package org.apache.beam.runners.jet.processors

Class FlattenP.Supplier

  • All Implemented Interfaces:
    com.hazelcast.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.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 Description
      Supplier​(java.util.Map<java.lang.String,​org.apache.beam.sdk.coders.Coder> inputCoders, org.apache.beam.sdk.coders.Coder outputCoder, java.lang.String ownerId)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method 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.function.SupplierEx

        get

    • Constructor Detail

      • Supplier

        public Supplier​(java.util.Map<java.lang.String,​org.apache.beam.sdk.coders.Coder> inputCoders,
                org.apache.beam.sdk.coders.Coder outputCoder,
                java.lang.String ownerId)

    • Method Detail

      • getEx

        public com.hazelcast.jet.core.Processor getEx()
        Specified by:
        getEx in interface com.hazelcast.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