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

Class BeamIOSinkRule

java.lang.Object

ConverterRule

org.apache.beam.sdk.extensions.sql.impl.rule.BeamIOSinkRule

public class BeamIOSinkRule
extends ConverterRule

A ConverterRule to replace TableModify with BeamIOSinkRel.

Method Summary

Modifier and Type	Method and Description
RelNode	convert(RelNode rel)
static BeamIOSinkRule	forSqlEnv(BeamSqlEnv sqlEnv)

Methods inherited from class java.lang.Object

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

Method Detail

forSqlEnv

public static BeamIOSinkRule forSqlEnv(BeamSqlEnv sqlEnv)

convert

public RelNode convert(RelNode rel)