org.apache.beam.sdk.extensions.sql

Class BeamRecordSqlType.Builder

java.lang.Object

org.apache.beam.sdk.extensions.sql.BeamRecordSqlType.Builder

Enclosing class:

BeamRecordSqlType

public static class BeamRecordSqlType.Builder
extends java.lang.Object

Builder class to construct BeamRecordSqlType.

Method Summary

Modifier and Type	Method and Description
BeamRecordSqlType	build()
BeamRecordSqlType.Builder	withBigIntField(java.lang.String fieldName)
BeamRecordSqlType.Builder	withBooleanField(java.lang.String fieldName)
BeamRecordSqlType.Builder	withCharField(java.lang.String fieldName)
BeamRecordSqlType.Builder	withDateField(java.lang.String fieldName)
BeamRecordSqlType.Builder	withDecimalField(java.lang.String fieldName)
BeamRecordSqlType.Builder	withDoubleField(java.lang.String fieldName)
BeamRecordSqlType.Builder	withField(java.lang.String fieldName, java.lang.Integer fieldType)
BeamRecordSqlType.Builder	withFloatField(java.lang.String fieldName)
BeamRecordSqlType.Builder	withIntegerField(java.lang.String fieldName)
BeamRecordSqlType.Builder	withSmallIntField(java.lang.String fieldName)
BeamRecordSqlType.Builder	withTimeField(java.lang.String fieldName)
BeamRecordSqlType.Builder	withTimestampField(java.lang.String fieldName)
BeamRecordSqlType.Builder	withTinyIntField(java.lang.String fieldName)
BeamRecordSqlType.Builder	withVarcharField(java.lang.String fieldName)

Methods inherited from class java.lang.Object

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

Method Detail

withField

public BeamRecordSqlType.Builder withField(java.lang.String fieldName,
                                           java.lang.Integer fieldType)

withTinyIntField

public BeamRecordSqlType.Builder withTinyIntField(java.lang.String fieldName)

withSmallIntField

public BeamRecordSqlType.Builder withSmallIntField(java.lang.String fieldName)

withIntegerField

public BeamRecordSqlType.Builder withIntegerField(java.lang.String fieldName)

withBigIntField

public BeamRecordSqlType.Builder withBigIntField(java.lang.String fieldName)

withFloatField

public BeamRecordSqlType.Builder withFloatField(java.lang.String fieldName)

withDoubleField

public BeamRecordSqlType.Builder withDoubleField(java.lang.String fieldName)

withDecimalField

public BeamRecordSqlType.Builder withDecimalField(java.lang.String fieldName)

withBooleanField

public BeamRecordSqlType.Builder withBooleanField(java.lang.String fieldName)

withCharField

public BeamRecordSqlType.Builder withCharField(java.lang.String fieldName)

withVarcharField

public BeamRecordSqlType.Builder withVarcharField(java.lang.String fieldName)

withTimeField

public BeamRecordSqlType.Builder withTimeField(java.lang.String fieldName)

withDateField

public BeamRecordSqlType.Builder withDateField(java.lang.String fieldName)

withTimestampField

public BeamRecordSqlType.Builder withTimestampField(java.lang.String fieldName)

build

public BeamRecordSqlType build()