Class Partition<T>

    • Constructor Detail

      • Partition

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

        public Partition​(int outputPorts,
                         scala.Function1<T,​java.lang.Object> partitioner)
        Deprecated.
        Use the constructor which also specifies the `eagerCancel` parameter. Since .
    • Method Detail

      • apply

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

        public int outputPorts()
      • partitioner

        public scala.Function1<T,​java.lang.Object> partitioner()
      • eagerCancel

        public boolean eagerCancel()
      • out

        public scala.collection.Seq<Outlet<T>> out()
      • shape

        public UniformFanOutShape<T,​T> shape()
        Description copied from interface: Graph
        The shape of a graph is all that is externally visible: its inlets and outlets.
        Returns:
        (undocumented)
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object