public class DoFnFunction<OutputT,InputT> extends java.lang.Object implements edu.iu.dsc.tws.api.tset.fn.ComputeCollectorFunc<RawUnionValue,java.util.Iterator<org.apache.beam.sdk.util.WindowedValue<InputT>>>
Constructor and Description |
---|
DoFnFunction() |
DoFnFunction(Twister2TranslationContext context,
DoFn<InputT,OutputT> doFn,
Coder<InputT> inputCoder,
java.util.Map<TupleTag<?>,Coder<?>> outputCoders,
java.util.List<TupleTag<?>> sideOutputs,
WindowingStrategy<?,?> windowingStrategy,
java.util.Map<PCollectionView<?>,WindowingStrategy<?,?>> sideInputs,
TupleTag<OutputT> mainOutput,
DoFnSchemaInformation doFnSchemaInformation,
java.util.Map<TupleTag<?>,java.lang.Integer> outputMap,
java.util.Map<java.lang.String,PCollectionView<?>> sideInputMapping) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
compute(java.util.Iterator<org.apache.beam.sdk.util.WindowedValue<InputT>> input,
edu.iu.dsc.tws.api.tset.fn.RecordCollector<RawUnionValue> output) |
java.util.Set<java.lang.String> |
getSideInputKeys()
get the tag id's of all the keys.
|
void |
prepare(edu.iu.dsc.tws.api.tset.TSetContext context) |
protected java.lang.Object |
readResolve() |
public DoFnFunction()
public DoFnFunction(Twister2TranslationContext context, DoFn<InputT,OutputT> doFn, Coder<InputT> inputCoder, java.util.Map<TupleTag<?>,Coder<?>> outputCoders, java.util.List<TupleTag<?>> sideOutputs, WindowingStrategy<?,?> windowingStrategy, java.util.Map<PCollectionView<?>,WindowingStrategy<?,?>> sideInputs, TupleTag<OutputT> mainOutput, DoFnSchemaInformation doFnSchemaInformation, java.util.Map<TupleTag<?>,java.lang.Integer> outputMap, java.util.Map<java.lang.String,PCollectionView<?>> sideInputMapping)
public java.util.Set<java.lang.String> getSideInputKeys()
public void prepare(edu.iu.dsc.tws.api.tset.TSetContext context)
prepare
in interface edu.iu.dsc.tws.api.tset.fn.TFunction<RawUnionValue,java.util.Iterator<org.apache.beam.sdk.util.WindowedValue<InputT>>>
public void compute(java.util.Iterator<org.apache.beam.sdk.util.WindowedValue<InputT>> input, edu.iu.dsc.tws.api.tset.fn.RecordCollector<RawUnionValue> output)
compute
in interface edu.iu.dsc.tws.api.tset.fn.ComputeCollectorFunc<RawUnionValue,java.util.Iterator<org.apache.beam.sdk.util.WindowedValue<InputT>>>
public void close()
close
in interface edu.iu.dsc.tws.api.compute.modifiers.Closable
close
in interface edu.iu.dsc.tws.api.tset.fn.TFunction<RawUnionValue,java.util.Iterator<org.apache.beam.sdk.util.WindowedValue<InputT>>>
protected java.lang.Object readResolve() throws java.io.ObjectStreamException
java.io.ObjectStreamException