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

Class DataStreamFactory<Solution_>

java.lang.Object

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

@NullMarked
public final class DataStreamFactory<Solution_>
extends Object

Constructor Summary

Constructors

Constructor	Description
DataStreamFactory(SolutionDescriptor<Solution_> solutionDescriptor)

Method Summary

Modifier and Type	Method	Description
<A> void	assertValidForEachType(Class<A> fromType)
<A> UniDataStream<Solution_,A>	forEachExcludingPinned(Class<A> sourceClass)
<A> UniDataStream<Solution_,A>	forEachFromSolution(FromSolutionValueCollectingFunction<Solution_,A> valueCollectingFunction)
<A> UniDataStream<Solution_,A>	forEachNonDiscriminating(Class<A> sourceClass)
List<AbstractDataset<Solution_,?>>	getDatasets()
SolutionDescriptor<Solution_>	getSolutionDescriptor()
<Stream_ extends AbstractDataStream<Solution_>> Stream_	share(Stream_ stream)
<Stream_ extends AbstractDataStream<Solution_>> Stream_	share(Stream_ stream, Consumer<Stream_> consumer)	Enables node sharing.

Methods inherited from class java.lang.Object

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

Constructor Details

DataStreamFactory

public DataStreamFactory(SolutionDescriptor<Solution_> solutionDescriptor)

Method Details

forEachNonDiscriminating

public <A> UniDataStream<Solution_,A> forEachNonDiscriminating(Class<A> sourceClass)

forEachExcludingPinned

public <A> UniDataStream<Solution_,A> forEachExcludingPinned(Class<A> sourceClass)

forEachFromSolution

public <A> UniDataStream<Solution_,A> forEachFromSolution(FromSolutionValueCollectingFunction<Solution_,A> valueCollectingFunction)

assertValidForEachType

public <A> void assertValidForEachType(Class<A> fromType)

share

public <Stream_ extends AbstractDataStream<Solution_>>
Stream_ share(Stream_ stream)

share

public <Stream_ extends AbstractDataStream<Solution_>>
Stream_ share(Stream_ stream,
 Consumer<Stream_> consumer)

Enables node sharing. If a stream already exists in this factory, it replaces it with the old copy. AbstractDataStream implement equals/hashcode ignoring child streams.

DatasetSessionFactory.buildSession() needs this to happen for all streams.

This must be called before the stream receives child streams.

Type Parameters:

Stream_ - the AbstractDataStream subclass

Parameters:

stream - never null

consumer - never null

Returns:

never null

getSolutionDescriptor

public SolutionDescriptor<Solution_> getSolutionDescriptor()

getDatasets

public List<AbstractDataset<Solution_,?>> getDatasets()