Package 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 Object

Utility methods for ZetaSQL invalid input: '<'=> Beam translation.

Unsupported ZetaSQL types: INT32, UINT32, UINT64, FLOAT, ENUM, PROTO, GEOGRAPHY

Method Summary

Modifier and Type	Method	Description
static Object	toBeamObject(com.google.zetasql.Value value, boolean verifyValues)
static 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 Object object, Schema.FieldType fieldType)

Methods inherited from class java.lang.Object

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

Method Details

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 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 Object toBeamObject(com.google.zetasql.Value value,
 boolean verifyValues)

toBeamObject

public static 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)