object Partition
- Source
- Graph.scala
- Alphabetic
- By Inheritance
- Partition
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
- case class PartitionOutOfBoundsException(msg: String) extends IndexOutOfBoundsException with NoStackTrace with Product with Serializable
Value Members
-
def
apply[T](outputPorts: Int, partitioner: (T) ⇒ Int): Partition[T]
Create a new
Partition
operator with the specified input type.Create a new
Partition
operator with the specified input type. This method setseagerCancel
tofalse
. To specify a different value for theeagerCancel
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.- outputPorts
number of output ports
- partitioner
function deciding which output each element will be targeted