org.apache.beam.runners.twister2.translators.functions

Class ImpulseSource

java.lang.Object

org.apache.beam.runners.twister2.translators.functions.ImpulseSource

All Implemented Interfaces:

edu.iu.dsc.tws.api.compute.modifiers.Closable, edu.iu.dsc.tws.api.tset.fn.SourceFunc<WindowedValue<byte[]>>, edu.iu.dsc.tws.api.tset.fn.TFunction<WindowedValue<byte[]>,WindowedValue<byte[]>>, java.io.Serializable

public class ImpulseSource
extends java.lang.Object
implements edu.iu.dsc.tws.api.tset.fn.SourceFunc<WindowedValue<byte[]>>

A SourceFunc which executes the impulse transform contract.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ImpulseSource()

Method Summary

Modifier and Type	Method and Description
boolean	hasNext()
WindowedValue<byte[]>	next()

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

ImpulseSource

public ImpulseSource()

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface edu.iu.dsc.tws.api.tset.fn.SourceFunc<WindowedValue<byte[]>>

next

public WindowedValue<byte[]> next()

Specified by:

next in interface edu.iu.dsc.tws.api.tset.fn.SourceFunc<WindowedValue<byte[]>>