org.apache.beam.sdk.extensions.sql

Class TableNameExtractionUtils

java.lang.Object

org.apache.beam.sdk.extensions.sql.TableNameExtractionUtils

public class TableNameExtractionUtils
extends java.lang.Object

Helper class to extract table identifiers from the query.

Supports queries:

   ... FROM table...
   ... FROM table1, table2 AS x...
   ... FROM table1 JOIN (LEFT, INNER, OUTER etc) table2 JOIN table3 ...
   ... FROM table1 UNION (INTERSECT etc) SELECT ...
 

Constructor Summary

Constructors

Constructor and Description
TableNameExtractionUtils()

Method Summary

Modifier and Type	Method and Description
static java.util.List<TableName>	extractTableNamesFromNode(@Nullable org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlNode node)

Methods inherited from class java.lang.Object

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

Constructor Detail

TableNameExtractionUtils

public TableNameExtractionUtils()

Method Detail

extractTableNamesFromNode

public static java.util.List<TableName> extractTableNamesFromNode(@Nullable org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.sql.SqlNode node)