org.apache.beam.sdk.extensions.sql.zetasql

Class SqlExtractTimestampOperatorRewriter

java.lang.Object

org.apache.beam.sdk.extensions.sql.zetasql.SqlExtractTimestampOperatorRewriter

All Implemented Interfaces:

SqlOperatorRewriter

public class SqlExtractTimestampOperatorRewriter
extends java.lang.Object
implements SqlOperatorRewriter

Rewrites EXTRACT calls by swapping first two arguments to fit for calcite SqlExtractOperator.

Constructor Summary

Constructors

Constructor and Description
SqlExtractTimestampOperatorRewriter()

Method Summary

Modifier and Type	Method and Description
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rex.RexNode	apply(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rex.RexBuilder rexBuilder, java.util.List<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rex.RexNode> operands) Create and return a new RexNode that represents a call to this operator with the specified operands.

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlExtractTimestampOperatorRewriter

public SqlExtractTimestampOperatorRewriter()

Method Detail

apply

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rex.RexNode apply(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rex.RexBuilder rexBuilder,
                                                                                   java.util.List<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rex.RexNode> operands)

Description copied from interface: SqlOperatorRewriter

Create and return a new RexNode that represents a call to this operator with the specified operands.

Specified by:

apply in interface SqlOperatorRewriter

Parameters:

rexBuilder - A RexBuilder instance to use for creating new RexNodes

operands - The original list of RexNode operands passed to this operator call

Returns:

The created RexNode