Class Partition$


  • public class Partition$
    extends java.lang.Object
    Create a new Partition operator with the specified input type, eagerCancel is false.

    param: outputCount number of output ports param: partitioner function deciding which output each element will be targeted

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static Partition$ MODULE$
      Static reference to the singleton instance of this Scala object.
    • Constructor Summary

      Constructors 
      Constructor Description
      Partition$()  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <T> Graph<UniformFanOutShape<T,​T>,​NotUsed> create​(int outputCount, Function<T,​java.lang.Integer> partitioner)  
      <T> Graph<UniformFanOutShape<T,​T>,​NotUsed> create​(int outputCount, Function<T,​java.lang.Integer> partitioner, boolean eagerCancel)
      Create a new Partition operator with the specified input type.
      <T> Graph<UniformFanOutShape<T,​T>,​NotUsed> create​(java.lang.Class<T> clazz, int outputCount, Function<T,​java.lang.Integer> partitioner)
      Create a new Partition operator with the specified input type, eagerCancel is false.
      <T> Graph<UniformFanOutShape<T,​T>,​NotUsed> create​(java.lang.Class<T> clazz, int outputCount, Function<T,​java.lang.Integer> partitioner, boolean eagerCancel)
      Create a new Partition operator with the specified input type.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • MODULE$

        public static final Partition$ MODULE$
        Static reference to the singleton instance of this Scala object.
    • Constructor Detail

      • Partition$

        public Partition$()
    • Method Detail

      • create

        public <T> Graph<UniformFanOutShape<T,​T>,​NotUsed> create​(int outputCount,
                                                                             Function<T,​java.lang.Integer> partitioner,
                                                                             boolean eagerCancel)
        Create a new Partition operator with the specified input type.

        Parameters:
        outputCount - number of output ports
        partitioner - function deciding which output each element will be targeted
        eagerCancel - this operator cancels, when any (true) or all (false) of the downstreams cancel
        Returns:
        (undocumented)
      • create

        public <T> Graph<UniformFanOutShape<T,​T>,​NotUsed> create​(java.lang.Class<T> clazz,
                                                                             int outputCount,
                                                                             Function<T,​java.lang.Integer> partitioner)
        Create a new Partition operator with the specified input type, eagerCancel is false.

        Parameters:
        clazz - a type hint for this method
        outputCount - number of output ports
        partitioner - function deciding which output each element will be targeted
        Returns:
        (undocumented)
      • create

        public <T> Graph<UniformFanOutShape<T,​T>,​NotUsed> create​(java.lang.Class<T> clazz,
                                                                             int outputCount,
                                                                             Function<T,​java.lang.Integer> partitioner,
                                                                             boolean eagerCancel)
        Create a new Partition operator with the specified input type.

        Parameters:
        clazz - a type hint for this method
        outputCount - number of output ports
        partitioner - function deciding which output each element will be targeted
        eagerCancel - this operator cancels, when any (true) or all (false) of the downstreams cancel
        Returns:
        (undocumented)