org.apache.beam.runners.twister2.translation.wrappers

Class Twister2EmptySource<T>

java.lang.Object

edu.iu.dsc.tws.api.tset.fn.BaseTFunction<T,T>

edu.iu.dsc.tws.api.tset.fn.BaseSourceFunc<org.apache.beam.sdk.util.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<org.apache.beam.sdk.util.WindowedValue<T>>, edu.iu.dsc.tws.api.tset.fn.TFunction<org.apache.beam.sdk.util.WindowedValue<T>,org.apache.beam.sdk.util.WindowedValue<T>>, java.io.Serializable

public class Twister2EmptySource<T>
extends edu.iu.dsc.tws.api.tset.fn.BaseSourceFunc<org.apache.beam.sdk.util.WindowedValue<T>>

Empty Source wrapper.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Twister2EmptySource()

Method Summary

Modifier and Type	Method and Description
boolean	hasNext()
org.apache.beam.sdk.util.WindowedValue<T>	next()

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.tset.fn.SourceFunc

close

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

prepare

Methods inherited from interface edu.iu.dsc.tws.api.compute.modifiers.Closable

reset

Constructor Detail

Twister2EmptySource

public Twister2EmptySource()

Method Detail

hasNext

public boolean hasNext()

next

public org.apache.beam.sdk.util.WindowedValue<T> next()