public static class BeamJoinTransforms.SideInputJoinDoFn extends DoFn<KV<Row,Row>,Row>
DoFn
which implement the sideInput-JOIN.DoFn.BoundedPerElement, DoFn.BundleFinalizer, DoFn.Element, DoFn.FieldAccess, DoFn.FinishBundle, DoFn.FinishBundleContext, DoFn.GetInitialRestriction, DoFn.GetRestrictionCoder, DoFn.MultiOutputReceiver, DoFn.NewTracker, DoFn.OnTimer, DoFn.OnTimerContext, DoFn.OnWindowExpiration, DoFn.OutputReceiver<T>, DoFn.ProcessContext, DoFn.ProcessContinuation, DoFn.ProcessElement, DoFn.RequiresStableInput, DoFn.Setup, DoFn.SplitRestriction, DoFn.StartBundle, DoFn.StartBundleContext, DoFn.StateId, DoFn.Teardown, DoFn.TimerId, DoFn.Timestamp, DoFn.UnboundedPerElement, DoFn.WindowedContext
Constructor and Description |
---|
SideInputJoinDoFn(org.apache.calcite.rel.core.JoinRelType joinType,
Row rightNullRow,
PCollectionView<java.util.Map<Row,java.lang.Iterable<Row>>> sideInputView,
boolean swap,
Schema schema) |
Modifier and Type | Method and Description |
---|---|
void |
processElement(DoFn.ProcessContext context) |
getAllowedTimestampSkew, getInputTypeDescriptor, getOutputTypeDescriptor, populateDisplayData, prepareForProcessing
public SideInputJoinDoFn(org.apache.calcite.rel.core.JoinRelType joinType, Row rightNullRow, PCollectionView<java.util.Map<Row,java.lang.Iterable<Row>>> sideInputView, boolean swap, Schema schema)
@DoFn.ProcessElement public void processElement(DoFn.ProcessContext context)