public class AssignWindowsFunction<T> extends java.lang.Object implements edu.iu.dsc.tws.api.tset.fn.ComputeCollectorFunc<WindowedValue<T>,java.util.Iterator<WindowedValue<T>>>
Constructor and Description |
---|
AssignWindowsFunction(WindowFn<T,BoundedWindow> windowFn,
PipelineOptions options) |
Modifier and Type | Method and Description |
---|---|
void |
compute(java.util.Iterator<WindowedValue<T>> input,
edu.iu.dsc.tws.api.tset.fn.RecordCollector<WindowedValue<T>> output) |
void |
prepare(edu.iu.dsc.tws.api.tset.TSetContext context) |
protected java.lang.Object |
readResolve() |
public AssignWindowsFunction(WindowFn<T,BoundedWindow> windowFn, PipelineOptions options)
public void compute(java.util.Iterator<WindowedValue<T>> input, edu.iu.dsc.tws.api.tset.fn.RecordCollector<WindowedValue<T>> output)
compute
in interface edu.iu.dsc.tws.api.tset.fn.ComputeCollectorFunc<WindowedValue<T>,java.util.Iterator<WindowedValue<T>>>
public void prepare(edu.iu.dsc.tws.api.tset.TSetContext context)
prepare
in interface edu.iu.dsc.tws.api.tset.fn.TFunction<WindowedValue<T>,java.util.Iterator<WindowedValue<T>>>
protected java.lang.Object readResolve() throws java.io.ObjectStreamException
java.io.ObjectStreamException