edu.iu.dsc.tws.api.tset.fn

Interface SourceFunc<T>

Type Parameters:

T - type of values produced by source

All Superinterfaces:

java.io.Serializable, TFunction<T,T>

All Known Implementing Classes:

ArrowBasedSourceFunction, BaseSourceFunc, BaseTSetBatchWorker.TestBaseSource, CollectionSource, CSVBasedSourceFunction, DataLoadingTask, DataPartitionSourceFunc, DiskPartitionBackedSource, DiskPartitionBackedSourceWrapper, FileSource, HadoopSource, HadoopSourceWithMap, KMeansTsetJob.CenterSource, ListBasedSourceFunction, MapBasedSourceFunction, PyTSetKeyedSource, PyTSetSource, TextBasedSourceFunction, Twister2BoundedSource, WeightVectorLoad

public interface SourceFunc<T>
extends TFunction<T,T>

Represents a source producing values

Method Summary

Modifier and Type	Method and Description
default void	close() Closes the source
boolean	hasNext() Weather we have more data
T	next() Get the next value

Methods inherited from interface edu.iu.dsc.tws.api.tset.fn.TFunction

end, prepare

Method Detail

hasNext

boolean hasNext()

Weather we have more data

Returns:

true if there is more data to be read

next

T next()

Get the next value

Returns:

the next value

close

default void close()

Closes the source

Specified by:

close in interface TFunction<T,T>