Package org.apache.flink.cdc.runtime.parser

Class TransformParser

java.lang.Object

org.apache.flink.cdc.runtime.parser.TransformParser

public class TransformParser
extends Object

Use Flink's calcite parser to parse the statement of flink cdc pipeline transform.

Constructor Summary

Constructors

Constructor	Description
TransformParser()

Method Summary

Modifier and Type	Method	Description
static DataType	deduceSubExpressionType(List<Column> columns, org.apache.calcite.sql.SqlNode subExpression, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns)
static DataType	deduceSubExpressionType(List<Column> columns, org.apache.calcite.sql.SqlNode subExpression, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns, DecimalPrecisionMode decimalPrecisionMode)
static Map<String,String>	generateColumnNameMap(List<String> originalColumnNames)
static List<ProjectionColumn>	generateProjectionColumns(String projectionExpression, List<Column> columns, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns)
static List<ProjectionColumn>	generateProjectionColumns(String projectionExpression, List<Column> columns, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns, DecimalPrecisionMode decimalPrecisionMode)
static List<Column>	generateReferencedColumns(String projectionExpression, String filterExpression, List<Column> columns)
static boolean	hasAsterisk(String projection)
static List<String>	parseComputedColumnNames(String projection, SupportedMetadataColumn[] supportedMetadataColumns)
static List<String>	parseFilterColumnNameList(String filterExpression)
static org.apache.calcite.sql.SqlSelect	parseFilterExpression(String filterExpression)
static org.apache.calcite.sql.SqlSelect	parseSelect(String statement)
static ProjectionColumn	resolveProjectionColumnFromIdentifier(org.apache.calcite.rel.type.RelDataType relDataType, Map<String,Column> originalColumnMap, String identifier, String projectedColumnName, SupportedMetadataColumn[] supportedMetadataColumns)	Create a projection column from a simple identifier node (could be an upstream physical column or a metadata column).
static String	translateFilterExpressionToJaninoExpression(String filterExpression, List<Column> columns, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns, Map<String,String> columnNameMap)
static String	translateFilterExpressionToJaninoExpression(String filterExpression, List<Column> columns, List<UserDefinedFunctionDescriptor> udfDescriptors, SupportedMetadataColumn[] supportedMetadataColumns, Map<String,String> columnNameMap, DecimalPrecisionMode decimalPrecisionMode)

Methods inherited from class java.lang.Object

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

Constructor Detail

TransformParser

public TransformParser()

Method Detail

parseSelect

public static org.apache.calcite.sql.SqlSelect parseSelect(String statement)

generateReferencedColumns

public static List<Column> generateReferencedColumns(String projectionExpression,
                                                     @Nullable
                                                     String filterExpression,
                                                     List<Column> columns)

generateProjectionColumns

public static List<ProjectionColumn> generateProjectionColumns(String projectionExpression,
                                                               List<Column> columns,
                                                               List<UserDefinedFunctionDescriptor> udfDescriptors,
                                                               SupportedMetadataColumn[] supportedMetadataColumns)

generateProjectionColumns

public static List<ProjectionColumn> generateProjectionColumns(String projectionExpression,
                                                               List<Column> columns,
                                                               List<UserDefinedFunctionDescriptor> udfDescriptors,
                                                               SupportedMetadataColumn[] supportedMetadataColumns,
                                                               DecimalPrecisionMode decimalPrecisionMode)

resolveProjectionColumnFromIdentifier

public static ProjectionColumn resolveProjectionColumnFromIdentifier(org.apache.calcite.rel.type.RelDataType relDataType,
                                                                     Map<String,Column> originalColumnMap,
                                                                     String identifier,
                                                                     String projectedColumnName,
                                                                     SupportedMetadataColumn[] supportedMetadataColumns)

Create a projection column from a simple identifier node (could be an upstream physical column or a metadata column).

translateFilterExpressionToJaninoExpression

public static String translateFilterExpressionToJaninoExpression(String filterExpression,
                                                                 List<Column> columns,
                                                                 List<UserDefinedFunctionDescriptor> udfDescriptors,
                                                                 SupportedMetadataColumn[] supportedMetadataColumns,
                                                                 Map<String,String> columnNameMap)

translateFilterExpressionToJaninoExpression

public static String translateFilterExpressionToJaninoExpression(String filterExpression,
                                                                 List<Column> columns,
                                                                 List<UserDefinedFunctionDescriptor> udfDescriptors,
                                                                 SupportedMetadataColumn[] supportedMetadataColumns,
                                                                 Map<String,String> columnNameMap,
                                                                 DecimalPrecisionMode decimalPrecisionMode)

parseComputedColumnNames

public static List<String> parseComputedColumnNames(String projection,
                                                    SupportedMetadataColumn[] supportedMetadataColumns)

parseFilterColumnNameList

public static List<String> parseFilterColumnNameList(String filterExpression)

parseFilterExpression

public static org.apache.calcite.sql.SqlSelect parseFilterExpression(String filterExpression)

hasAsterisk

public static boolean hasAsterisk(@Nullable
                                  String projection)

generateColumnNameMap

public static Map<String,String> generateColumnNameMap(List<String> originalColumnNames)

deduceSubExpressionType

public static DataType deduceSubExpressionType(List<Column> columns,
                                               org.apache.calcite.sql.SqlNode subExpression,
                                               List<UserDefinedFunctionDescriptor> udfDescriptors,
                                               SupportedMetadataColumn[] supportedMetadataColumns)

deduceSubExpressionType

public static DataType deduceSubExpressionType(List<Column> columns,
                                               org.apache.calcite.sql.SqlNode subExpression,
                                               List<UserDefinedFunctionDescriptor> udfDescriptors,
                                               SupportedMetadataColumn[] supportedMetadataColumns,
                                               DecimalPrecisionMode decimalPrecisionMode)