Package ai.timefold.solver.core.impl.move.streams.dataset

Class ForEachIncludingPinnedDataStream<Solution_,A>

java.lang.Object

ai.timefold.solver.core.impl.move.streams.dataset.AbstractDataStream<Solution_>

ai.timefold.solver.core.impl.move.streams.dataset.AbstractUniDataStream<Solution_,A>

ai.timefold.solver.core.impl.move.streams.dataset.ForEachIncludingPinnedDataStream<Solution_,A>

All Implemented Interfaces:

BavetStream, TupleSource, DataStream<Solution_>, UniDataStream<Solution_,A>

@NullMarked
public final class ForEachIncludingPinnedDataStream<Solution_,A>
extends AbstractUniDataStream<Solution_,A>
implements TupleSource

Field Summary

Fields

Modifier and Type	Field	Description
protected final Class<A>	forEachClass

Fields inherited from class ai.timefold.solver.core.impl.move.streams.dataset.AbstractDataStream

childStreamList, dataStreamFactory, parent

Constructor Summary

Constructors

Constructor	Description
ForEachIncludingPinnedDataStream(DataStreamFactory<Solution_> dataStreamFactory, Class<A> forEachClass)

Method Summary

Modifier and Type	Method	Description
final void	buildNode(DataNodeBuildHelper<Solution_> buildHelper)
final void	collectActiveDataStreams(Set<AbstractDataStream<Solution_>> dataStreamSet)
boolean	equals(Object o)
protected AbstractForEachUniNode<A>	getNode(TupleLifecycle<UniTuple<A>> tupleLifecycle, int outputStoreSize)
int	hashCode()
String	toString()

Methods inherited from class ai.timefold.solver.core.impl.move.streams.dataset.AbstractUniDataStream

createDataset, filter, ifExists, ifExists, ifNotExists, ifNotExists

Methods inherited from class ai.timefold.solver.core.impl.move.streams.dataset.AbstractDataStream

assertEmptyChildStreamList, getChildStreamList, getParent, getTupleSource, shareAndAddChild

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface ai.timefold.solver.core.impl.move.streams.maybeapi.stream.UniDataStream

ifExistsOther, ifNotExistsOther

Field Details

forEachClass

protected final Class<A> forEachClass

Constructor Details

ForEachIncludingPinnedDataStream

public ForEachIncludingPinnedDataStream(DataStreamFactory<Solution_> dataStreamFactory,
 Class<A> forEachClass)

Method Details

getNode

protected AbstractForEachUniNode<A> getNode(TupleLifecycle<UniTuple<A>> tupleLifecycle,
 int outputStoreSize)

equals

public boolean equals(Object o)

hashCode

public int hashCode()

toString

public String toString()

collectActiveDataStreams

public final void collectActiveDataStreams(Set<AbstractDataStream<Solution_>> dataStreamSet)

Overrides:

collectActiveDataStreams in class AbstractDataStream<Solution_>

buildNode

public final void buildNode(DataNodeBuildHelper<Solution_> buildHelper)

Specified by:

buildNode in class AbstractDataStream<Solution_>