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

Class ParDoP.Supplier<InputT,​OutputT>

  • Type Parameters:
    OutputT - the type of main output elements of the DoFn being used
    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:
    ParDoP<InputT,​OutputT>
    public static class ParDoP.Supplier<InputT,​OutputT>
extends java.lang.Object
    Jet Processor supplier that will provide instances of ParDoP.
    See Also:
    Serialized Form

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected java.lang.String ownerId  

    • Constructor Summary

      Constructors 
      Constructor Description
      Supplier​(java.lang.String stepId, java.lang.String ownerId, org.apache.beam.sdk.transforms.DoFn<InputT,​OutputT> doFn, org.apache.beam.sdk.values.WindowingStrategy<?,​?> windowingStrategy, org.apache.beam.sdk.transforms.DoFnSchemaInformation doFnSchemaInformation, org.apache.beam.runners.core.construction.SerializablePipelineOptions pipelineOptions, org.apache.beam.sdk.values.TupleTag<OutputT> mainOutputTag, java.util.Set<org.apache.beam.sdk.values.TupleTag<OutputT>> allOutputTags, org.apache.beam.sdk.coders.Coder<InputT> inputCoder, java.util.Map<org.apache.beam.sdk.values.PCollectionView<?>,​org.apache.beam.sdk.coders.Coder<?>> sideInputCoders, java.util.Map<org.apache.beam.sdk.values.TupleTag<?>,​org.apache.beam.sdk.coders.Coder<?>> outputCoders, org.apache.beam.sdk.coders.Coder<InputT> inputValueCoder, java.util.Map<org.apache.beam.sdk.values.TupleTag<?>,​org.apache.beam.sdk.coders.Coder<?>> outputValueCoders, java.util.Collection<org.apache.beam.sdk.values.PCollectionView<?>> sideInputs, java.util.Map<java.lang.String,​org.apache.beam.sdk.values.PCollectionView<?>> sideInputMapping)  

    • 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

    • Field Detail

      • ownerId

        protected final java.lang.String ownerId

    • Constructor Detail

      • Supplier

        public Supplier​(java.lang.String stepId,
                java.lang.String ownerId,
                org.apache.beam.sdk.transforms.DoFn<InputT,​OutputT> doFn,
                org.apache.beam.sdk.values.WindowingStrategy<?,​?> windowingStrategy,
                org.apache.beam.sdk.transforms.DoFnSchemaInformation doFnSchemaInformation,
                org.apache.beam.runners.core.construction.SerializablePipelineOptions pipelineOptions,
                org.apache.beam.sdk.values.TupleTag<OutputT> mainOutputTag,
                java.util.Set<org.apache.beam.sdk.values.TupleTag<OutputT>> allOutputTags,
                org.apache.beam.sdk.coders.Coder<InputT> inputCoder,
                java.util.Map<org.apache.beam.sdk.values.PCollectionView<?>,​org.apache.beam.sdk.coders.Coder<?>> sideInputCoders,
                java.util.Map<org.apache.beam.sdk.values.TupleTag<?>,​org.apache.beam.sdk.coders.Coder<?>> outputCoders,
                org.apache.beam.sdk.coders.Coder<InputT> inputValueCoder,
                java.util.Map<org.apache.beam.sdk.values.TupleTag<?>,​org.apache.beam.sdk.coders.Coder<?>> outputValueCoders,
                java.util.Collection<org.apache.beam.sdk.values.PCollectionView<?>> sideInputs,
                java.util.Map<java.lang.String,​org.apache.beam.sdk.values.PCollectionView<?>> sideInputMapping)

    • Method Detail

      • getEx

        public com.hazelcast.jet.core.Processor getEx()
        Specified by:
        getEx in interface com.hazelcast.function.SupplierEx<InputT>

      • 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