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

Class ZetaSqlUtils

java.lang.Object

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

@Internal
public final class ZetaSqlUtils
extends java.lang.Object

Utility methods for ZetaSQL related operations.

Unsupported ZetaSQL types: INT32, UINT32, UINT64, FLOAT, ENUM, PROTO, GEOGRAPHY TODO[BEAM-8630]: support ZetaSQL types: DATE, TIME, DATETIME

Method Summary

Modifier and Type	Method and Description
static com.google.zetasql.Type	beamFieldTypeToZetaSqlType(Schema.FieldType fieldType)
static com.google.zetasql.Value	beamRowToZetaSqlStructValue(Row row, Schema schema)
static com.google.zetasql.StructType	beamSchemaToZetaSqlStructType(Schema schema)
static com.google.zetasql.Value	javaObjectToZetaSqlValue(java.lang.Object object, Schema.FieldType fieldType)
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.type.SqlTypeName	zetaSqlTypeToCalciteTypeName(com.google.zetasql.ZetaSQLType.TypeKind zetaSqlType)
static java.lang.Object	zetaSqlValueToJavaObject(com.google.zetasql.Value value, Schema.FieldType fieldType, boolean verifyValues)

Methods inherited from class java.lang.Object

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

Method Detail

zetaSqlTypeToCalciteTypeName

public static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.type.SqlTypeName zetaSqlTypeToCalciteTypeName(com.google.zetasql.ZetaSQLType.TypeKind zetaSqlType)

beamFieldTypeToZetaSqlType

public static com.google.zetasql.Type beamFieldTypeToZetaSqlType(Schema.FieldType fieldType)

beamSchemaToZetaSqlStructType

public static com.google.zetasql.StructType beamSchemaToZetaSqlStructType(Schema schema)

javaObjectToZetaSqlValue

public static com.google.zetasql.Value javaObjectToZetaSqlValue(java.lang.Object object,
                                                                Schema.FieldType fieldType)

beamRowToZetaSqlStructValue

public static com.google.zetasql.Value beamRowToZetaSqlStructValue(Row row,
                                                                   Schema schema)

zetaSqlValueToJavaObject

public static java.lang.Object zetaSqlValueToJavaObject(com.google.zetasql.Value value,
                                                        Schema.FieldType fieldType,
                                                        boolean verifyValues)