Class Twister2EmptySource<T>
java.lang.Object
edu.iu.dsc.tws.api.tset.fn.BaseTFunction<WindowedValue<T>,WindowedValue<T>>
edu.iu.dsc.tws.api.tset.fn.BaseSourceFunc<WindowedValue<T>>
org.apache.beam.runners.twister2.translation.wrappers.Twister2EmptySource<T>
- Type Parameters:
T
- type of the source
- All Implemented Interfaces:
edu.iu.dsc.tws.api.compute.modifiers.Closable
,edu.iu.dsc.tws.api.tset.fn.SourceFunc<WindowedValue<T>>
,edu.iu.dsc.tws.api.tset.fn.TFunction<WindowedValue<T>,
,WindowedValue<T>> Serializable
public class Twister2EmptySource<T>
extends edu.iu.dsc.tws.api.tset.fn.BaseSourceFunc<WindowedValue<T>>
Empty Source wrapper.
- See Also:
-
Constructor Summary
Constructors -
Method Summary
Methods inherited from class edu.iu.dsc.tws.api.tset.fn.BaseTFunction
getInput, getTSetContext, prepare
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface edu.iu.dsc.tws.api.compute.modifiers.Closable
reset
Methods inherited from interface edu.iu.dsc.tws.api.tset.fn.SourceFunc
close
Methods inherited from interface edu.iu.dsc.tws.api.tset.fn.TFunction
prepare
-
Constructor Details
-
Twister2EmptySource
public Twister2EmptySource()
-
-
Method Details
-
hasNext
public boolean hasNext() -
next
-