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
-
-
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 newPartition
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 newPartition
operator with the specified input type,eagerCancel
isfalse
.<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.
-
-
-
Field Detail
-
MODULE$
public static final Partition$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
create
public <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(int outputCount, Function<T,java.lang.Integer> partitioner)
-
create
public <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 <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 <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)
-
-