Class Partition$


  • public class Partition$
    extends java.lang.Object
    Create a new Partition operator with the specified input type. This method sets eagerCancel to false. To specify a different value for the eagerCancel parameter, then instantiate Partition using the constructor.

    If eagerCancel is true, partition cancels upstream if any of its downstreams cancel, if false, when all have cancelled.

    param: outputPorts 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> Partition<T> apply​(int outputPorts, scala.Function1<T,​java.lang.Object> partitioner)  
      • 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

      • apply

        public <T> Partition<T> apply​(int outputPorts,
                                      scala.Function1<T,​java.lang.Object> partitioner)