Package akka.stream.impl
Class CompositeTraversalBuilder
- java.lang.Object
-
- akka.stream.impl.CompositeTraversalBuilder
-
- All Implemented Interfaces:
TraversalBuilder
,java.io.Serializable
,scala.Equals
,scala.Product
,scala.Serializable
public final class CompositeTraversalBuilder extends java.lang.Object implements TraversalBuilder, scala.Product, scala.Serializable
Convert this builder to aCompletedTraversalBuilder
if there are no more unwired outputs.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description CompositeTraversalBuilder(Traversal finalSteps, scala.collection.immutable.List<TraversalBuildStep> reverseBuildSteps, int inSlots, scala.collection.immutable.Map<InPort,java.lang.Object> inOffsets, scala.collection.immutable.Map<OutPort,java.lang.Object> inBaseOffsetForOut, scala.collection.immutable.Map<BuilderKey,TraversalBuilder> pendingBuilders, scala.collection.immutable.Map<OutPort,BuilderKey> outOwners, int unwiredOuts, Attributes attributes, OptionVal<IslandTag> islandTag)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static Traversal
$lessinit$greater$default$1()
static OptionVal<IslandTag>
$lessinit$greater$default$10()
static scala.collection.immutable.List<TraversalBuildStep>
$lessinit$greater$default$2()
static int
$lessinit$greater$default$3()
static scala.collection.immutable.Map<InPort,java.lang.Object>
$lessinit$greater$default$4()
static scala.collection.immutable.Map<OutPort,java.lang.Object>
$lessinit$greater$default$5()
static scala.collection.immutable.Map<BuilderKey,TraversalBuilder>
$lessinit$greater$default$6()
static scala.collection.immutable.Map<OutPort,BuilderKey>
$lessinit$greater$default$7()
static int
$lessinit$greater$default$8()
TraversalBuilder
add(TraversalBuilder submodule, Shape shape, scala.Function2<scala.runtime.Nothing$,scala.runtime.Nothing$,java.lang.Object> combineMat)
Adds a module to the builder.static CompositeTraversalBuilder
apply(Traversal finalSteps, scala.collection.immutable.List<TraversalBuildStep> reverseBuildSteps, int inSlots, scala.collection.immutable.Map<InPort,java.lang.Object> inOffsets, scala.collection.immutable.Map<OutPort,java.lang.Object> inBaseOffsetForOut, scala.collection.immutable.Map<BuilderKey,TraversalBuilder> pendingBuilders, scala.collection.immutable.Map<OutPort,BuilderKey> outOwners, int unwiredOuts, Attributes attributes, OptionVal<IslandTag> islandTag)
static Traversal
apply$default$1()
static OptionVal<IslandTag>
apply$default$10()
static scala.collection.immutable.List<TraversalBuildStep>
apply$default$2()
static int
apply$default$3()
static scala.collection.immutable.Map<InPort,java.lang.Object>
apply$default$4()
static scala.collection.immutable.Map<OutPort,java.lang.Object>
apply$default$5()
static scala.collection.immutable.Map<BuilderKey,TraversalBuilder>
apply$default$6()
static scala.collection.immutable.Map<OutPort,BuilderKey>
apply$default$7()
static int
apply$default$8()
TraversalBuilder
assign(OutPort out, int relativeSlot)
Assign an output port a relative slot (relative to the base input slot of its module, seeMaterializeAtomic
)Attributes
attributes()
boolean
canEqual(java.lang.Object x$1)
TraversalBuilder
completeIfPossible()
Convert this builder to aCompletedTraversalBuilder
if there are no more unwired outputs.CompositeTraversalBuilder
copy(Traversal finalSteps, scala.collection.immutable.List<TraversalBuildStep> reverseBuildSteps, int inSlots, scala.collection.immutable.Map<InPort,java.lang.Object> inOffsets, scala.collection.immutable.Map<OutPort,java.lang.Object> inBaseOffsetForOut, scala.collection.immutable.Map<BuilderKey,TraversalBuilder> pendingBuilders, scala.collection.immutable.Map<OutPort,BuilderKey> outOwners, int unwiredOuts, Attributes attributes, OptionVal<IslandTag> islandTag)
Traversal
copy$default$1()
OptionVal<IslandTag>
copy$default$10()
scala.collection.immutable.List<TraversalBuildStep>
copy$default$2()
int
copy$default$3()
scala.collection.immutable.Map<InPort,java.lang.Object>
copy$default$4()
scala.collection.immutable.Map<OutPort,java.lang.Object>
copy$default$5()
scala.collection.immutable.Map<BuilderKey,TraversalBuilder>
copy$default$6()
scala.collection.immutable.Map<OutPort,BuilderKey>
copy$default$7()
int
copy$default$8()
Attributes
copy$default$9()
boolean
equals(java.lang.Object x$1)
Traversal
finalSteps()
int
hashCode()
scala.collection.immutable.Map<OutPort,java.lang.Object>
inBaseOffsetForOut()
scala.collection.immutable.Map<InPort,java.lang.Object>
inOffsets()
int
inSlots()
The total number of input ports encountered so far.TraversalBuilder
internalSetAttributes(Attributes attributes)
OptionVal<IslandTag>
islandTag()
boolean
isTraversalComplete()
Returns true if the Traversal is available.boolean
isUnwired(InPort in)
Returns whether the given input port has been wired in the graph or not.boolean
isUnwired(OutPort out)
Returns whether the given output port has been wired in the graph or not.TraversalBuilder
makeIsland(IslandTag islandTag)
Wraps the builder in an island that can be materialized differently, using async boundaries to bridge between islands.int
offsetOf(InPort in)
Returns the number assigned to a certain input port *relative* to this module.int
offsetOfModule(OutPort out)
Returns the base offset (the first number an input port would receive if there is any) of the module to which the port belongs *relative to this builder*.scala.collection.immutable.Map<OutPort,BuilderKey>
outOwners()
scala.collection.immutable.Map<BuilderKey,TraversalBuilder>
pendingBuilders()
int
productArity()
java.lang.Object
productElement(int x$1)
scala.collection.Iterator<java.lang.Object>
productIterator()
java.lang.String
productPrefix()
scala.collection.immutable.List<TraversalBuildStep>
reverseBuildSteps()
java.lang.String
toString()
TraversalBuilder
transformMat(scala.Function1<scala.runtime.Nothing$,java.lang.Object> f)
Maps the materialized value produced by the module built-up so far with the provided function, providing a new TraversalBuilder returning the mapped materialized value.static scala.Option<scala.Tuple10<Traversal,scala.collection.immutable.List<TraversalBuildStep>,java.lang.Object,scala.collection.immutable.Map<InPort,java.lang.Object>,scala.collection.immutable.Map<OutPort,java.lang.Object>,scala.collection.immutable.Map<BuilderKey,TraversalBuilder>,scala.collection.immutable.Map<OutPort,BuilderKey>,java.lang.Object,Attributes,OptionVal<IslandTag>>>
unapply(CompositeTraversalBuilder x$0)
int
unwiredOuts()
The number of output ports that have not been wired.TraversalBuilder
wire(OutPort out, InPort in)
Connects two unwired ports in the graph.-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface akka.stream.impl.TraversalBuilder
setAttributes, traversal
-
-
-
-
Constructor Detail
-
CompositeTraversalBuilder
public CompositeTraversalBuilder(Traversal finalSteps, scala.collection.immutable.List<TraversalBuildStep> reverseBuildSteps, int inSlots, scala.collection.immutable.Map<InPort,java.lang.Object> inOffsets, scala.collection.immutable.Map<OutPort,java.lang.Object> inBaseOffsetForOut, scala.collection.immutable.Map<BuilderKey,TraversalBuilder> pendingBuilders, scala.collection.immutable.Map<OutPort,BuilderKey> outOwners, int unwiredOuts, Attributes attributes, OptionVal<IslandTag> islandTag)
-
-
Method Detail
-
$lessinit$greater$default$1
public static Traversal $lessinit$greater$default$1()
-
$lessinit$greater$default$2
public static scala.collection.immutable.List<TraversalBuildStep> $lessinit$greater$default$2()
-
$lessinit$greater$default$3
public static int $lessinit$greater$default$3()
-
$lessinit$greater$default$4
public static scala.collection.immutable.Map<InPort,java.lang.Object> $lessinit$greater$default$4()
-
$lessinit$greater$default$5
public static scala.collection.immutable.Map<OutPort,java.lang.Object> $lessinit$greater$default$5()
-
$lessinit$greater$default$6
public static scala.collection.immutable.Map<BuilderKey,TraversalBuilder> $lessinit$greater$default$6()
-
$lessinit$greater$default$7
public static scala.collection.immutable.Map<OutPort,BuilderKey> $lessinit$greater$default$7()
-
$lessinit$greater$default$8
public static int $lessinit$greater$default$8()
-
apply
public static CompositeTraversalBuilder apply(Traversal finalSteps, scala.collection.immutable.List<TraversalBuildStep> reverseBuildSteps, int inSlots, scala.collection.immutable.Map<InPort,java.lang.Object> inOffsets, scala.collection.immutable.Map<OutPort,java.lang.Object> inBaseOffsetForOut, scala.collection.immutable.Map<BuilderKey,TraversalBuilder> pendingBuilders, scala.collection.immutable.Map<OutPort,BuilderKey> outOwners, int unwiredOuts, Attributes attributes, OptionVal<IslandTag> islandTag)
-
apply$default$1
public static Traversal apply$default$1()
-
apply$default$2
public static scala.collection.immutable.List<TraversalBuildStep> apply$default$2()
-
apply$default$3
public static int apply$default$3()
-
apply$default$4
public static scala.collection.immutable.Map<InPort,java.lang.Object> apply$default$4()
-
apply$default$5
public static scala.collection.immutable.Map<OutPort,java.lang.Object> apply$default$5()
-
apply$default$6
public static scala.collection.immutable.Map<BuilderKey,TraversalBuilder> apply$default$6()
-
apply$default$7
public static scala.collection.immutable.Map<OutPort,BuilderKey> apply$default$7()
-
apply$default$8
public static int apply$default$8()
-
unapply
public static scala.Option<scala.Tuple10<Traversal,scala.collection.immutable.List<TraversalBuildStep>,java.lang.Object,scala.collection.immutable.Map<InPort,java.lang.Object>,scala.collection.immutable.Map<OutPort,java.lang.Object>,scala.collection.immutable.Map<BuilderKey,TraversalBuilder>,scala.collection.immutable.Map<OutPort,BuilderKey>,java.lang.Object,Attributes,OptionVal<IslandTag>>> unapply(CompositeTraversalBuilder x$0)
-
finalSteps
public Traversal finalSteps()
-
reverseBuildSteps
public scala.collection.immutable.List<TraversalBuildStep> reverseBuildSteps()
-
inSlots
public int inSlots()
Description copied from interface:TraversalBuilder
The total number of input ports encountered so far. Gives the first slot to which a new input port can be assigned (if a new module is added).- Specified by:
inSlots
in interfaceTraversalBuilder
- Returns:
- (undocumented)
-
inOffsets
public scala.collection.immutable.Map<InPort,java.lang.Object> inOffsets()
-
inBaseOffsetForOut
public scala.collection.immutable.Map<OutPort,java.lang.Object> inBaseOffsetForOut()
-
pendingBuilders
public scala.collection.immutable.Map<BuilderKey,TraversalBuilder> pendingBuilders()
-
outOwners
public scala.collection.immutable.Map<OutPort,BuilderKey> outOwners()
-
unwiredOuts
public int unwiredOuts()
Description copied from interface:TraversalBuilder
The number of output ports that have not been wired.- Specified by:
unwiredOuts
in interfaceTraversalBuilder
- Returns:
- (undocumented)
-
attributes
public Attributes attributes()
- Specified by:
attributes
in interfaceTraversalBuilder
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
offsetOfModule
public int offsetOfModule(OutPort out)
Description copied from interface:TraversalBuilder
Returns the base offset (the first number an input port would receive if there is any) of the module to which the port belongs *relative to this builder*. This is used to calculate the relative offset of output port mappings (seeMaterializeAtomic
).This method only guarantees to return the offset of modules for output ports that have not been wired.
- Specified by:
offsetOfModule
in interfaceTraversalBuilder
- Parameters:
out
- (undocumented)- Returns:
- (undocumented)
-
isUnwired
public boolean isUnwired(OutPort out)
Description copied from interface:TraversalBuilder
Returns whether the given output port has been wired in the graph or not.- Specified by:
isUnwired
in interfaceTraversalBuilder
- Parameters:
out
- (undocumented)- Returns:
- (undocumented)
-
isUnwired
public boolean isUnwired(InPort in)
Description copied from interface:TraversalBuilder
Returns whether the given input port has been wired in the graph or not.- Specified by:
isUnwired
in interfaceTraversalBuilder
- Parameters:
in
- (undocumented)- Returns:
- (undocumented)
-
offsetOf
public int offsetOf(InPort in)
Description copied from interface:TraversalBuilder
Returns the number assigned to a certain input port *relative* to this module.This method only guarantees to return the offset of input ports that have not been wired.
- Specified by:
offsetOf
in interfaceTraversalBuilder
- Parameters:
in
- (undocumented)- Returns:
- (undocumented)
-
isTraversalComplete
public boolean isTraversalComplete()
Description copied from interface:TraversalBuilder
Returns true if the Traversal is available. Not all builders are able to build up the Traversal incrementally. Generally a traversal is complete if there are no unwired output ports.- Specified by:
isTraversalComplete
in interfaceTraversalBuilder
- Returns:
- (undocumented)
-
internalSetAttributes
public TraversalBuilder internalSetAttributes(Attributes attributes)
- Specified by:
internalSetAttributes
in interfaceTraversalBuilder
-
completeIfPossible
public TraversalBuilder completeIfPossible()
Convert this builder to aCompletedTraversalBuilder
if there are no more unwired outputs.- Returns:
- (undocumented)
-
assign
public TraversalBuilder assign(OutPort out, int relativeSlot)
Assign an output port a relative slot (relative to the base input slot of its module, seeMaterializeAtomic
)- Specified by:
assign
in interfaceTraversalBuilder
- Parameters:
out
- (undocumented)relativeSlot
- (undocumented)- Returns:
- (undocumented)
-
add
public TraversalBuilder add(TraversalBuilder submodule, Shape shape, scala.Function2<scala.runtime.Nothing$,scala.runtime.Nothing$,java.lang.Object> combineMat)
Description copied from interface:TraversalBuilder
Adds a module to the builder. It is possible to add a module with a different Shape (import), in this case the ports of the shape MUST have theirmappedTo
field pointing to the original ports. The act of being imported will not be reflected in the final Traversal, the Shape is only used by the builder to disambiguate between multiple imported instances of the same module.See append in the
LinearTraversalBuilder
for a more efficient alternative for linear graphs.- Specified by:
add
in interfaceTraversalBuilder
- Parameters:
submodule
- (undocumented)shape
- (undocumented)combineMat
- (undocumented)- Returns:
- (undocumented)
-
wire
public TraversalBuilder wire(OutPort out, InPort in)
Description copied from interface:TraversalBuilder
Connects two unwired ports in the graph. For imported modules, use the ports of their "import shape". These ports must have theirmappedTo
field set and point to the original ports.See append in the
LinearTraversalBuilder
for a more efficient alternative for linear graphs.- Specified by:
wire
in interfaceTraversalBuilder
- Parameters:
out
- (undocumented)in
- (undocumented)- Returns:
- (undocumented)
-
transformMat
public TraversalBuilder transformMat(scala.Function1<scala.runtime.Nothing$,java.lang.Object> f)
Description copied from interface:TraversalBuilder
Maps the materialized value produced by the module built-up so far with the provided function, providing a new TraversalBuilder returning the mapped materialized value.- Specified by:
transformMat
in interfaceTraversalBuilder
- Parameters:
f
- (undocumented)- Returns:
- (undocumented)
-
makeIsland
public TraversalBuilder makeIsland(IslandTag islandTag)
Description copied from interface:TraversalBuilder
Wraps the builder in an island that can be materialized differently, using async boundaries to bridge between islands.- Specified by:
makeIsland
in interfaceTraversalBuilder
- Parameters:
islandTag
- (undocumented)- Returns:
- (undocumented)
-
copy
public CompositeTraversalBuilder copy(Traversal finalSteps, scala.collection.immutable.List<TraversalBuildStep> reverseBuildSteps, int inSlots, scala.collection.immutable.Map<InPort,java.lang.Object> inOffsets, scala.collection.immutable.Map<OutPort,java.lang.Object> inBaseOffsetForOut, scala.collection.immutable.Map<BuilderKey,TraversalBuilder> pendingBuilders, scala.collection.immutable.Map<OutPort,BuilderKey> outOwners, int unwiredOuts, Attributes attributes, OptionVal<IslandTag> islandTag)
-
copy$default$1
public Traversal copy$default$1()
-
copy$default$2
public scala.collection.immutable.List<TraversalBuildStep> copy$default$2()
-
copy$default$3
public int copy$default$3()
-
copy$default$4
public scala.collection.immutable.Map<InPort,java.lang.Object> copy$default$4()
-
copy$default$5
public scala.collection.immutable.Map<OutPort,java.lang.Object> copy$default$5()
-
copy$default$6
public scala.collection.immutable.Map<BuilderKey,TraversalBuilder> copy$default$6()
-
copy$default$7
public scala.collection.immutable.Map<OutPort,BuilderKey> copy$default$7()
-
copy$default$8
public int copy$default$8()
-
copy$default$9
public Attributes copy$default$9()
-
productPrefix
public java.lang.String productPrefix()
- Specified by:
productPrefix
in interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArity
in interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElement
in interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIterator
in interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqual
in interfacescala.Equals
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object x$1)
- Specified by:
equals
in interfacescala.Equals
- Overrides:
equals
in classjava.lang.Object
-
-