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

Method Summary

Modifier and Type	Method and Description
static java.lang.Object	toBeamObject(com.google.zetasql.Value value, boolean verifyValues)
static java.lang.Object	toBeamObject(com.google.zetasql.Value value, Schema.FieldType fieldType, boolean verifyValues)
static Row	toBeamRow(com.google.zetasql.Value structValue, Schema schema, boolean verifyValues)
static Schema.FieldType	toBeamType(com.google.zetasql.Type type)
static com.google.zetasql.StructType	toZetaSqlStructType(Schema schema)
static com.google.zetasql.Value	toZetaSqlStructValue(Row row, Schema schema)
static com.google.zetasql.Type	toZetaSqlType(Schema.FieldType fieldType)
static com.google.zetasql.Value	toZetaSqlValue(@Nullable java.lang.Object object, Schema.FieldType fieldType)

Methods inherited from class java.lang.Object

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

Method Detail

toZetaSqlType

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

toZetaSqlStructType

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

toZetaSqlValue

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

toZetaSqlStructValue

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

toBeamType

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

toBeamObject

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

toBeamObject

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

toBeamRow

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