org.apache.beam.sdk.io.snowflake.data

Class SnowflakeTableSchema

java.lang.Object

org.apache.beam.sdk.io.snowflake.data.SnowflakeTableSchema

All Implemented Interfaces:

java.io.Serializable

public class SnowflakeTableSchema
extends java.lang.Object
implements java.io.Serializable

POJO representing schema of Table in Snowflake. Used by SnowflakeIO.Write when SnowflakeIO.Write.CreateDisposition#CREATE_IF_NEEDED disposition is used.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SnowflakeTableSchema()
SnowflakeTableSchema(SnowflakeColumn... columns)

Method Summary

Modifier and Type	Method and Description
SnowflakeColumn[]	getColumns()
static SnowflakeTableSchema	of(SnowflakeColumn... columns)
void	setColumns(SnowflakeColumn[] columns)
java.lang.String	sql()

Methods inherited from class java.lang.Object

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

Constructor Detail

SnowflakeTableSchema

public SnowflakeTableSchema()

SnowflakeTableSchema

public SnowflakeTableSchema(SnowflakeColumn... columns)

Method Detail

of

public static SnowflakeTableSchema of(SnowflakeColumn... columns)

sql

public java.lang.String sql()

getColumns

public SnowflakeColumn[] getColumns()

setColumns

public void setColumns(SnowflakeColumn[] columns)