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(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
PCollection<BeamRecord>	buildBeamPipeline(PCollectionTuple inputPCollections, BeamSqlEnv sqlEnv) Note that BeamIOSinkRel returns the input PCollection, which is the persisted PCollection.
RelNode	copy(RelTraitSet traitSet, java.util.List<RelNode> inputs)

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamIOSinkRel

public BeamIOSinkRel(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)

buildBeamPipeline

public PCollection<BeamRecord> buildBeamPipeline(PCollectionTuple inputPCollections,
                                                 BeamSqlEnv sqlEnv)
                                          throws java.lang.Exception

Note that BeamIOSinkRel returns the input PCollection, which is the persisted PCollection.

Specified by:

buildBeamPipeline in interface BeamRelNode

Throws:

java.lang.Exception