org.apache.beam.sdk.extensions.sql.impl.rel

Class BeamIOSinkRel

java.lang.Object

TableModify

org.apache.beam.sdk.extensions.sql.impl.rel.BeamIOSinkRel

All Implemented Interfaces:

BeamRelNode

public class BeamIOSinkRel
extends TableModify
implements BeamRelNode

BeamRelNode to replace a TableModify node.

Constructor Summary

Constructors

Constructor and Description
BeamIOSinkRel(BeamSqlEnv sqlEnv, RelOptCluster cluster, RelTraitSet traits, RelOptTable table, Prepare.CatalogReader catalogReader, RelNode child, Operation operation, java.util.List<java.lang.String> updateColumnList, java.util.List<RexNode> sourceExpressionList, boolean flattened)

Method Summary

Modifier and Type	Method and Description
RelNode	copy(RelTraitSet traitSet, java.util.List<RelNode> inputs)
PTransform<PCollectionTuple,PCollection<Row>>	toPTransform() A BeamRelNode is a recursive structure, the BeamQueryPlanner visits it with a DFS(Depth-First-Search) algorithm.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BeamIOSinkRel

public BeamIOSinkRel(BeamSqlEnv sqlEnv,
                     RelOptCluster cluster,
                     RelTraitSet traits,
                     RelOptTable table,
                     Prepare.CatalogReader catalogReader,
                     RelNode child,
                     Operation operation,
                     java.util.List<java.lang.String> updateColumnList,
                     java.util.List<RexNode> sourceExpressionList,
                     boolean flattened)

Method Detail

copy

public RelNode copy(RelTraitSet traitSet,
                    java.util.List<RelNode> inputs)

toPTransform

public PTransform<PCollectionTuple,PCollection<Row>> toPTransform()

Description copied from interface: BeamRelNode

A BeamRelNode is a recursive structure, the BeamQueryPlanner visits it with a DFS(Depth-First-Search) algorithm.

Specified by:

toPTransform in interface BeamRelNode