Package org.apache.beam.sdk.extensions.sql

Class TableNameExtractionUtils

java.lang.Object

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

public class TableNameExtractionUtils
extends 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	Description
TableNameExtractionUtils()

Method Summary

Modifier and Type	Method	Description
static List<TableName>	extractTableNamesFromNode(@Nullable org.apache.beam.vendor.calcite.v1_40_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 Details

TableNameExtractionUtils

public TableNameExtractionUtils()

Method Details

extractTableNamesFromNode

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