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

Class AbstractDataStream<Solution_>

java.lang.Object

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

All Implemented Interfaces:

BavetStream

Direct Known Subclasses:

AbstractUniDataStream

public abstract class AbstractDataStream<Solution_>
extends Object
implements BavetStream

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<AbstractDataStream<Solution_>>	childStreamList
protected final DataStreamFactory<Solution_>	dataStreamFactory
protected final @Nullable AbstractDataStream<Solution_>	parent

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractDataStream(DataStreamFactory<Solution_> dataStreamFactory, @Nullable AbstractDataStream<Solution_> parent)

Method Summary

Modifier and Type	Method	Description
protected void	assertEmptyChildStreamList()
abstract void	buildNode(DataNodeBuildHelper<Solution_> buildHelper)
void	collectActiveDataStreams(Set<AbstractDataStream<Solution_>> constraintStreamSet)
final List<AbstractDataStream<Solution_>>	getChildStreamList()
final @Nullable AbstractDataStream<Solution_>	getParent()
AbstractDataStream<Solution_>	getTupleSource()	Returns the stream which first produced the tuple that this stream operates on.
final <Stream_ extends AbstractDataStream<Solution_>> Stream_	shareAndAddChild(Stream_ stream)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

dataStreamFactory

protected final DataStreamFactory<Solution_> dataStreamFactory

parent

protected final @Nullable AbstractDataStream<Solution_> parent

childStreamList

protected final List<AbstractDataStream<Solution_>> childStreamList

Constructor Details

AbstractDataStream

protected AbstractDataStream(DataStreamFactory<Solution_> dataStreamFactory,
 @Nullable AbstractDataStream<Solution_> parent)

Method Details

shareAndAddChild

public final <Stream_ extends AbstractDataStream<Solution_>>
Stream_ shareAndAddChild(Stream_ stream)

collectActiveDataStreams

public void collectActiveDataStreams(Set<AbstractDataStream<Solution_>> constraintStreamSet)

getTupleSource

public AbstractDataStream<Solution_> getTupleSource()

Returns the stream which first produced the tuple that this stream operates on. If a stream does not have a single parent nor is it a source, it is expected to override this method.

Returns:

this if TupleSource, otherwise parent's tuple source.

buildNode

public abstract void buildNode(DataNodeBuildHelper<Solution_> buildHelper)

assertEmptyChildStreamList

protected void assertEmptyChildStreamList()

getParent

public final @Nullable AbstractDataStream<Solution_> getParent()

Specified by:

getParent in interface BavetStream

getChildStreamList

public final List<AbstractDataStream<Solution_>> getChildStreamList()