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

Class BeamJoinRule

java.lang.Object

ConverterRule

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

public class BeamJoinRule
extends ConverterRule

ConverterRule to replace Join with BeamJoinRel.

Method Summary

Modifier and Type	Method and Description
RelNode	convert(RelNode rel)
static BeamJoinRule	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 BeamJoinRule forSqlEnv(BeamSqlEnv sqlEnv)

convert

public RelNode convert(RelNode rel)