Package akka.stream.javadsl
Class Partition
- java.lang.Object
-
- akka.stream.javadsl.Partition
-
public class Partition extends java.lang.Object
Create a newPartition
operator with the specified input type,eagerCancel
isfalse
.param: outputCount number of output ports param: partitioner function deciding which output each element will be targeted
-
-
Constructor Summary
Constructors Constructor Description Partition()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> Graph<UniformFanOutShape<T,T>,NotUsed>
create(int outputCount, Function<T,java.lang.Integer> partitioner)
static <T> Graph<UniformFanOutShape<T,T>,NotUsed>
create(int outputCount, Function<T,java.lang.Integer> partitioner, boolean eagerCancel)
Create a newPartition
operator with the specified input type.static <T> Graph<UniformFanOutShape<T,T>,NotUsed>
create(java.lang.Class<T> clazz, int outputCount, Function<T,java.lang.Integer> partitioner)
Create a newPartition
operator with the specified input type,eagerCancel
isfalse
.static <T> Graph<UniformFanOutShape<T,T>,NotUsed>
create(java.lang.Class<T> clazz, int outputCount, Function<T,java.lang.Integer> partitioner, boolean eagerCancel)
Create a newPartition
operator with the specified input type.
-
-
-
Method Detail
-
create
public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(int outputCount, Function<T,java.lang.Integer> partitioner)
-
create
public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(int outputCount, Function<T,java.lang.Integer> partitioner, boolean eagerCancel)
Create a newPartition
operator with the specified input type.- Parameters:
outputCount
- number of output portspartitioner
- function deciding which output each element will be targetedeagerCancel
- this operator cancels, when any (true) or all (false) of the downstreams cancel- Returns:
- (undocumented)
-
create
public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(java.lang.Class<T> clazz, int outputCount, Function<T,java.lang.Integer> partitioner)
Create a newPartition
operator with the specified input type,eagerCancel
isfalse
.- Parameters:
clazz
- a type hint for this methodoutputCount
- number of output portspartitioner
- function deciding which output each element will be targeted- Returns:
- (undocumented)
-
create
public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(java.lang.Class<T> clazz, int outputCount, Function<T,java.lang.Integer> partitioner, boolean eagerCancel)
Create a newPartition
operator with the specified input type.- Parameters:
clazz
- a type hint for this methodoutputCount
- number of output portspartitioner
- function deciding which output each element will be targetedeagerCancel
- this operator cancels, when any (true) or all (false) of the downstreams cancel- Returns:
- (undocumented)
-
-