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.

Method Summary

Modifier and Type	Method and Description
static com.google.zetasql.Type	beamFieldTypeToZetaSqlType(Schema.FieldType fieldType)
static com.google.zetasql.Value	javaObjectToZetaSqlValue(java.lang.Object object, Schema.FieldType fieldType)
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

beamFieldTypeToZetaSqlType

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

javaObjectToZetaSqlValue

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

zetaSqlValueToJavaObject

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