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

Class ZetaSqlBeamTranslationUtils

java.lang.Object

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

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

Utility methods for ZetaSQL <=> Beam translation.

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

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 Row	zetaSqlStructValueToBeamRow(com.google.zetasql.Value structValue, Schema schema, boolean verifyValues)
static Schema.FieldType	zetaSqlTypeToBeamFieldType(com.google.zetasql.Type type)
static java.lang.Object	zetaSqlValueToJavaObject(com.google.zetasql.Value value, boolean verifyValues)
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

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)

zetaSqlTypeToBeamFieldType

public static Schema.FieldType zetaSqlTypeToBeamFieldType(com.google.zetasql.Type type)

zetaSqlValueToJavaObject

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

zetaSqlValueToJavaObject

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

zetaSqlStructValueToBeamRow

public static Row zetaSqlStructValueToBeamRow(com.google.zetasql.Value structValue,
                                              Schema schema,
                                              boolean verifyValues)