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

Class SnowflakeTableSchema

java.lang.Object

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

All Implemented Interfaces:

Serializable

public class SnowflakeTableSchema
extends Object
implements Serializable

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

See Also:

• Serialized Form

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

SnowflakeTableSchema

public SnowflakeTableSchema()

SnowflakeTableSchema

public SnowflakeTableSchema(SnowflakeColumn... columns)

Method Details

of

public static SnowflakeTableSchema of(SnowflakeColumn... columns)

sql

public String sql()

getColumns

public SnowflakeColumn[] getColumns()

setColumns

public void setColumns(SnowflakeColumn[] columns)