public class OutputTagFilter<OutputT,InputT> extends java.lang.Object implements edu.iu.dsc.tws.api.tset.fn.ComputeCollectorFunc<org.apache.beam.sdk.util.WindowedValue<OutputT>,java.util.Iterator<RawUnionValue>>
Constructor and Description |
---|
OutputTagFilter() |
OutputTagFilter(int tag) |
Modifier and Type | Method and Description |
---|---|
void |
compute(java.util.Iterator<RawUnionValue> input,
edu.iu.dsc.tws.api.tset.fn.RecordCollector<org.apache.beam.sdk.util.WindowedValue<OutputT>> output) |
void |
prepare(edu.iu.dsc.tws.api.tset.TSetContext context) |
public OutputTagFilter()
public OutputTagFilter(int tag)
public void compute(java.util.Iterator<RawUnionValue> input, edu.iu.dsc.tws.api.tset.fn.RecordCollector<org.apache.beam.sdk.util.WindowedValue<OutputT>> output)
compute
in interface edu.iu.dsc.tws.api.tset.fn.ComputeCollectorFunc<org.apache.beam.sdk.util.WindowedValue<OutputT>,java.util.Iterator<RawUnionValue>>
public void prepare(edu.iu.dsc.tws.api.tset.TSetContext context)
prepare
in interface edu.iu.dsc.tws.api.tset.fn.TFunction<org.apache.beam.sdk.util.WindowedValue<OutputT>,java.util.Iterator<RawUnionValue>>