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	createZetaSqlStructTypeFromBeamSchema(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	zetaSqlTypeToCalciteType(com.google.zetasql.ZetaSQLType.TypeKind zetaSqlType)
static java.lang.Object	zetaSqlValueToJavaObject(com.google.zetasql.Value value, Schema.FieldType fieldType)

Methods inherited from class java.lang.Object

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

Method Detail

zetaSqlTypeToCalciteType

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

beamFieldTypeToZetaSqlType

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

createZetaSqlStructTypeFromBeamSchema

public static com.google.zetasql.StructType createZetaSqlStructTypeFromBeamSchema(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)