@Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class SnowflakeNodeData extends Object implements Serializable, Cloneable, StructuredPojo
Specifies configuration for Snowflake nodes in Glue Studio.
Constructor and Description |
---|
SnowflakeNodeData() |
Modifier and Type | Method and Description |
---|---|
SnowflakeNodeData |
addAdditionalOptionsEntry(String key,
String value)
Add a single AdditionalOptions entry
|
SnowflakeNodeData |
clearAdditionalOptionsEntries()
Removes all the entries added into AdditionalOptions.
|
SnowflakeNodeData |
clone() |
boolean |
equals(Object obj) |
String |
getAction()
Specifies what action to take when writing to a table with preexisting data.
|
Map<String,String> |
getAdditionalOptions()
Specifies additional options passed to the Snowflake connector.
|
Boolean |
getAutoPushdown()
Specifies whether automatic query pushdown is enabled.
|
Option |
getConnection()
Specifies a Glue Data Catalog Connection to a Snowflake endpoint.
|
String |
getDatabase()
Specifies a Snowflake database for your node to use.
|
Option |
getIamRole()
Not currently used.
|
String |
getMergeAction()
Specifies a merge action.
|
String |
getMergeClause()
A SQL statement that specifies a custom merge behavior.
|
String |
getMergeWhenMatched()
Specifies how to resolve records that match preexisting data when merging.
|
String |
getMergeWhenNotMatched()
Specifies how to process records that do not match preexisting data when merging.
|
String |
getPostAction()
A SQL string run after the Snowflake connector performs its standard actions.
|
String |
getPreAction()
A SQL string run before the Snowflake connector performs its standard actions.
|
String |
getSampleQuery()
A SQL string used to retrieve data with the
query sourcetype. |
String |
getSchema()
Specifies a Snowflake database schema for your node to use.
|
List<Option> |
getSelectedColumns()
Specifies the columns combined to identify a record when detecting matches for merges and upserts.
|
String |
getSourceType()
Specifies how retrieved data is specified.
|
String |
getStagingTable()
The name of a staging table used when performing
merge or upsert append actions. |
String |
getTable()
Specifies a Snowflake table for your node to use.
|
List<Option> |
getTableSchema()
Manually defines the target schema for the node.
|
String |
getTempDir()
Not currently used.
|
Boolean |
getUpsert()
Used when Action is
append . |
int |
hashCode() |
Boolean |
isAutoPushdown()
Specifies whether automatic query pushdown is enabled.
|
Boolean |
isUpsert()
Used when Action is
append . |
void |
marshall(ProtocolMarshaller protocolMarshaller)
Marshalls this structured data using the given
ProtocolMarshaller . |
void |
setAction(String action)
Specifies what action to take when writing to a table with preexisting data.
|
void |
setAdditionalOptions(Map<String,String> additionalOptions)
Specifies additional options passed to the Snowflake connector.
|
void |
setAutoPushdown(Boolean autoPushdown)
Specifies whether automatic query pushdown is enabled.
|
void |
setConnection(Option connection)
Specifies a Glue Data Catalog Connection to a Snowflake endpoint.
|
void |
setDatabase(String database)
Specifies a Snowflake database for your node to use.
|
void |
setIamRole(Option iamRole)
Not currently used.
|
void |
setMergeAction(String mergeAction)
Specifies a merge action.
|
void |
setMergeClause(String mergeClause)
A SQL statement that specifies a custom merge behavior.
|
void |
setMergeWhenMatched(String mergeWhenMatched)
Specifies how to resolve records that match preexisting data when merging.
|
void |
setMergeWhenNotMatched(String mergeWhenNotMatched)
Specifies how to process records that do not match preexisting data when merging.
|
void |
setPostAction(String postAction)
A SQL string run after the Snowflake connector performs its standard actions.
|
void |
setPreAction(String preAction)
A SQL string run before the Snowflake connector performs its standard actions.
|
void |
setSampleQuery(String sampleQuery)
A SQL string used to retrieve data with the
query sourcetype. |
void |
setSchema(String schema)
Specifies a Snowflake database schema for your node to use.
|
void |
setSelectedColumns(Collection<Option> selectedColumns)
Specifies the columns combined to identify a record when detecting matches for merges and upserts.
|
void |
setSourceType(String sourceType)
Specifies how retrieved data is specified.
|
void |
setStagingTable(String stagingTable)
The name of a staging table used when performing
merge or upsert append actions. |
void |
setTable(String table)
Specifies a Snowflake table for your node to use.
|
void |
setTableSchema(Collection<Option> tableSchema)
Manually defines the target schema for the node.
|
void |
setTempDir(String tempDir)
Not currently used.
|
void |
setUpsert(Boolean upsert)
Used when Action is
append . |
String |
toString()
Returns a string representation of this object.
|
SnowflakeNodeData |
withAction(String action)
Specifies what action to take when writing to a table with preexisting data.
|
SnowflakeNodeData |
withAdditionalOptions(Map<String,String> additionalOptions)
Specifies additional options passed to the Snowflake connector.
|
SnowflakeNodeData |
withAutoPushdown(Boolean autoPushdown)
Specifies whether automatic query pushdown is enabled.
|
SnowflakeNodeData |
withConnection(Option connection)
Specifies a Glue Data Catalog Connection to a Snowflake endpoint.
|
SnowflakeNodeData |
withDatabase(String database)
Specifies a Snowflake database for your node to use.
|
SnowflakeNodeData |
withIamRole(Option iamRole)
Not currently used.
|
SnowflakeNodeData |
withMergeAction(String mergeAction)
Specifies a merge action.
|
SnowflakeNodeData |
withMergeClause(String mergeClause)
A SQL statement that specifies a custom merge behavior.
|
SnowflakeNodeData |
withMergeWhenMatched(String mergeWhenMatched)
Specifies how to resolve records that match preexisting data when merging.
|
SnowflakeNodeData |
withMergeWhenNotMatched(String mergeWhenNotMatched)
Specifies how to process records that do not match preexisting data when merging.
|
SnowflakeNodeData |
withPostAction(String postAction)
A SQL string run after the Snowflake connector performs its standard actions.
|
SnowflakeNodeData |
withPreAction(String preAction)
A SQL string run before the Snowflake connector performs its standard actions.
|
SnowflakeNodeData |
withSampleQuery(String sampleQuery)
A SQL string used to retrieve data with the
query sourcetype. |
SnowflakeNodeData |
withSchema(String schema)
Specifies a Snowflake database schema for your node to use.
|
SnowflakeNodeData |
withSelectedColumns(Collection<Option> selectedColumns)
Specifies the columns combined to identify a record when detecting matches for merges and upserts.
|
SnowflakeNodeData |
withSelectedColumns(Option... selectedColumns)
Specifies the columns combined to identify a record when detecting matches for merges and upserts.
|
SnowflakeNodeData |
withSourceType(String sourceType)
Specifies how retrieved data is specified.
|
SnowflakeNodeData |
withStagingTable(String stagingTable)
The name of a staging table used when performing
merge or upsert append actions. |
SnowflakeNodeData |
withTable(String table)
Specifies a Snowflake table for your node to use.
|
SnowflakeNodeData |
withTableSchema(Collection<Option> tableSchema)
Manually defines the target schema for the node.
|
SnowflakeNodeData |
withTableSchema(Option... tableSchema)
Manually defines the target schema for the node.
|
SnowflakeNodeData |
withTempDir(String tempDir)
Not currently used.
|
SnowflakeNodeData |
withUpsert(Boolean upsert)
Used when Action is
append . |
public void setSourceType(String sourceType)
Specifies how retrieved data is specified. Valid values: "table"
, "query"
.
sourceType
- Specifies how retrieved data is specified. Valid values: "table"
, "query"
.public String getSourceType()
Specifies how retrieved data is specified. Valid values: "table"
, "query"
.
"table"
, "query"
.public SnowflakeNodeData withSourceType(String sourceType)
Specifies how retrieved data is specified. Valid values: "table"
, "query"
.
sourceType
- Specifies how retrieved data is specified. Valid values: "table"
, "query"
.public void setConnection(Option connection)
Specifies a Glue Data Catalog Connection to a Snowflake endpoint.
connection
- Specifies a Glue Data Catalog Connection to a Snowflake endpoint.public Option getConnection()
Specifies a Glue Data Catalog Connection to a Snowflake endpoint.
public SnowflakeNodeData withConnection(Option connection)
Specifies a Glue Data Catalog Connection to a Snowflake endpoint.
connection
- Specifies a Glue Data Catalog Connection to a Snowflake endpoint.public void setSchema(String schema)
Specifies a Snowflake database schema for your node to use.
schema
- Specifies a Snowflake database schema for your node to use.public String getSchema()
Specifies a Snowflake database schema for your node to use.
public SnowflakeNodeData withSchema(String schema)
Specifies a Snowflake database schema for your node to use.
schema
- Specifies a Snowflake database schema for your node to use.public void setTable(String table)
Specifies a Snowflake table for your node to use.
table
- Specifies a Snowflake table for your node to use.public String getTable()
Specifies a Snowflake table for your node to use.
public SnowflakeNodeData withTable(String table)
Specifies a Snowflake table for your node to use.
table
- Specifies a Snowflake table for your node to use.public void setDatabase(String database)
Specifies a Snowflake database for your node to use.
database
- Specifies a Snowflake database for your node to use.public String getDatabase()
Specifies a Snowflake database for your node to use.
public SnowflakeNodeData withDatabase(String database)
Specifies a Snowflake database for your node to use.
database
- Specifies a Snowflake database for your node to use.public void setTempDir(String tempDir)
Not currently used.
tempDir
- Not currently used.public String getTempDir()
Not currently used.
public SnowflakeNodeData withTempDir(String tempDir)
Not currently used.
tempDir
- Not currently used.public void setIamRole(Option iamRole)
Not currently used.
iamRole
- Not currently used.public Option getIamRole()
Not currently used.
public SnowflakeNodeData withIamRole(Option iamRole)
Not currently used.
iamRole
- Not currently used.public Map<String,String> getAdditionalOptions()
Specifies additional options passed to the Snowflake connector. If options are specified elsewhere in this node, this will take precedence.
public void setAdditionalOptions(Map<String,String> additionalOptions)
Specifies additional options passed to the Snowflake connector. If options are specified elsewhere in this node, this will take precedence.
additionalOptions
- Specifies additional options passed to the Snowflake connector. If options are specified elsewhere in this
node, this will take precedence.public SnowflakeNodeData withAdditionalOptions(Map<String,String> additionalOptions)
Specifies additional options passed to the Snowflake connector. If options are specified elsewhere in this node, this will take precedence.
additionalOptions
- Specifies additional options passed to the Snowflake connector. If options are specified elsewhere in this
node, this will take precedence.public SnowflakeNodeData addAdditionalOptionsEntry(String key, String value)
public SnowflakeNodeData clearAdditionalOptionsEntries()
public void setSampleQuery(String sampleQuery)
A SQL string used to retrieve data with the query
sourcetype.
sampleQuery
- A SQL string used to retrieve data with the query
sourcetype.public String getSampleQuery()
A SQL string used to retrieve data with the query
sourcetype.
query
sourcetype.public SnowflakeNodeData withSampleQuery(String sampleQuery)
A SQL string used to retrieve data with the query
sourcetype.
sampleQuery
- A SQL string used to retrieve data with the query
sourcetype.public void setPreAction(String preAction)
A SQL string run before the Snowflake connector performs its standard actions.
preAction
- A SQL string run before the Snowflake connector performs its standard actions.public String getPreAction()
A SQL string run before the Snowflake connector performs its standard actions.
public SnowflakeNodeData withPreAction(String preAction)
A SQL string run before the Snowflake connector performs its standard actions.
preAction
- A SQL string run before the Snowflake connector performs its standard actions.public void setPostAction(String postAction)
A SQL string run after the Snowflake connector performs its standard actions.
postAction
- A SQL string run after the Snowflake connector performs its standard actions.public String getPostAction()
A SQL string run after the Snowflake connector performs its standard actions.
public SnowflakeNodeData withPostAction(String postAction)
A SQL string run after the Snowflake connector performs its standard actions.
postAction
- A SQL string run after the Snowflake connector performs its standard actions.public void setAction(String action)
Specifies what action to take when writing to a table with preexisting data. Valid values: append
,
merge
, truncate
, drop
.
action
- Specifies what action to take when writing to a table with preexisting data. Valid values:
append
, merge
, truncate
, drop
.public String getAction()
Specifies what action to take when writing to a table with preexisting data. Valid values: append
,
merge
, truncate
, drop
.
append
, merge
, truncate
, drop
.public SnowflakeNodeData withAction(String action)
Specifies what action to take when writing to a table with preexisting data. Valid values: append
,
merge
, truncate
, drop
.
action
- Specifies what action to take when writing to a table with preexisting data. Valid values:
append
, merge
, truncate
, drop
.public void setUpsert(Boolean upsert)
Used when Action is append
. Specifies the resolution behavior when a row already exists. If true,
preexisting rows will be updated. If false, those rows will be inserted.
upsert
- Used when Action is append
. Specifies the resolution behavior when a row already exists. If
true, preexisting rows will be updated. If false, those rows will be inserted.public Boolean getUpsert()
Used when Action is append
. Specifies the resolution behavior when a row already exists. If true,
preexisting rows will be updated. If false, those rows will be inserted.
append
. Specifies the resolution behavior when a row already exists. If
true, preexisting rows will be updated. If false, those rows will be inserted.public SnowflakeNodeData withUpsert(Boolean upsert)
Used when Action is append
. Specifies the resolution behavior when a row already exists. If true,
preexisting rows will be updated. If false, those rows will be inserted.
upsert
- Used when Action is append
. Specifies the resolution behavior when a row already exists. If
true, preexisting rows will be updated. If false, those rows will be inserted.public Boolean isUpsert()
Used when Action is append
. Specifies the resolution behavior when a row already exists. If true,
preexisting rows will be updated. If false, those rows will be inserted.
append
. Specifies the resolution behavior when a row already exists. If
true, preexisting rows will be updated. If false, those rows will be inserted.public void setMergeAction(String mergeAction)
Specifies a merge action. Valid values: simple
, custom
. If simple, merge behavior is
defined by MergeWhenMatched
and MergeWhenNotMatched
. If custom, defined by
MergeClause
.
mergeAction
- Specifies a merge action. Valid values: simple
, custom
. If simple, merge
behavior is defined by MergeWhenMatched
and MergeWhenNotMatched
. If custom,
defined by MergeClause
.public String getMergeAction()
Specifies a merge action. Valid values: simple
, custom
. If simple, merge behavior is
defined by MergeWhenMatched
and MergeWhenNotMatched
. If custom, defined by
MergeClause
.
simple
, custom
. If simple, merge
behavior is defined by MergeWhenMatched
and MergeWhenNotMatched
. If custom,
defined by MergeClause
.public SnowflakeNodeData withMergeAction(String mergeAction)
Specifies a merge action. Valid values: simple
, custom
. If simple, merge behavior is
defined by MergeWhenMatched
and MergeWhenNotMatched
. If custom, defined by
MergeClause
.
mergeAction
- Specifies a merge action. Valid values: simple
, custom
. If simple, merge
behavior is defined by MergeWhenMatched
and MergeWhenNotMatched
. If custom,
defined by MergeClause
.public void setMergeWhenMatched(String mergeWhenMatched)
Specifies how to resolve records that match preexisting data when merging. Valid values: update
,
delete
.
mergeWhenMatched
- Specifies how to resolve records that match preexisting data when merging. Valid values:
update
, delete
.public String getMergeWhenMatched()
Specifies how to resolve records that match preexisting data when merging. Valid values: update
,
delete
.
update
, delete
.public SnowflakeNodeData withMergeWhenMatched(String mergeWhenMatched)
Specifies how to resolve records that match preexisting data when merging. Valid values: update
,
delete
.
mergeWhenMatched
- Specifies how to resolve records that match preexisting data when merging. Valid values:
update
, delete
.public void setMergeWhenNotMatched(String mergeWhenNotMatched)
Specifies how to process records that do not match preexisting data when merging. Valid values:
insert
, none
.
mergeWhenNotMatched
- Specifies how to process records that do not match preexisting data when merging. Valid values:
insert
, none
.public String getMergeWhenNotMatched()
Specifies how to process records that do not match preexisting data when merging. Valid values:
insert
, none
.
insert
, none
.public SnowflakeNodeData withMergeWhenNotMatched(String mergeWhenNotMatched)
Specifies how to process records that do not match preexisting data when merging. Valid values:
insert
, none
.
mergeWhenNotMatched
- Specifies how to process records that do not match preexisting data when merging. Valid values:
insert
, none
.public void setMergeClause(String mergeClause)
A SQL statement that specifies a custom merge behavior.
mergeClause
- A SQL statement that specifies a custom merge behavior.public String getMergeClause()
A SQL statement that specifies a custom merge behavior.
public SnowflakeNodeData withMergeClause(String mergeClause)
A SQL statement that specifies a custom merge behavior.
mergeClause
- A SQL statement that specifies a custom merge behavior.public void setStagingTable(String stagingTable)
The name of a staging table used when performing merge
or upsert append
actions. Data
is written to this table, then moved to table
by a generated postaction.
stagingTable
- The name of a staging table used when performing merge
or upsert append
actions.
Data is written to this table, then moved to table
by a generated postaction.public String getStagingTable()
The name of a staging table used when performing merge
or upsert append
actions. Data
is written to this table, then moved to table
by a generated postaction.
merge
or upsert append
actions. Data is written to this table, then moved to table
by a generated postaction.public SnowflakeNodeData withStagingTable(String stagingTable)
The name of a staging table used when performing merge
or upsert append
actions. Data
is written to this table, then moved to table
by a generated postaction.
stagingTable
- The name of a staging table used when performing merge
or upsert append
actions.
Data is written to this table, then moved to table
by a generated postaction.public List<Option> getSelectedColumns()
Specifies the columns combined to identify a record when detecting matches for merges and upserts. A list of
structures with value
, label
and description
keys. Each structure
describes a column.
value
, label
and description
keys. Each
structure describes a column.public void setSelectedColumns(Collection<Option> selectedColumns)
Specifies the columns combined to identify a record when detecting matches for merges and upserts. A list of
structures with value
, label
and description
keys. Each structure
describes a column.
selectedColumns
- Specifies the columns combined to identify a record when detecting matches for merges and upserts. A list
of structures with value
, label
and description
keys. Each
structure describes a column.public SnowflakeNodeData withSelectedColumns(Option... selectedColumns)
Specifies the columns combined to identify a record when detecting matches for merges and upserts. A list of
structures with value
, label
and description
keys. Each structure
describes a column.
NOTE: This method appends the values to the existing list (if any). Use
setSelectedColumns(java.util.Collection)
or withSelectedColumns(java.util.Collection)
if you
want to override the existing values.
selectedColumns
- Specifies the columns combined to identify a record when detecting matches for merges and upserts. A list
of structures with value
, label
and description
keys. Each
structure describes a column.public SnowflakeNodeData withSelectedColumns(Collection<Option> selectedColumns)
Specifies the columns combined to identify a record when detecting matches for merges and upserts. A list of
structures with value
, label
and description
keys. Each structure
describes a column.
selectedColumns
- Specifies the columns combined to identify a record when detecting matches for merges and upserts. A list
of structures with value
, label
and description
keys. Each
structure describes a column.public void setAutoPushdown(Boolean autoPushdown)
Specifies whether automatic query pushdown is enabled. If pushdown is enabled, then when a query is run on Spark, if part of the query can be "pushed down" to the Snowflake server, it is pushed down. This improves performance of some queries.
autoPushdown
- Specifies whether automatic query pushdown is enabled. If pushdown is enabled, then when a query is run on
Spark, if part of the query can be "pushed down" to the Snowflake server, it is pushed down. This improves
performance of some queries.public Boolean getAutoPushdown()
Specifies whether automatic query pushdown is enabled. If pushdown is enabled, then when a query is run on Spark, if part of the query can be "pushed down" to the Snowflake server, it is pushed down. This improves performance of some queries.
public SnowflakeNodeData withAutoPushdown(Boolean autoPushdown)
Specifies whether automatic query pushdown is enabled. If pushdown is enabled, then when a query is run on Spark, if part of the query can be "pushed down" to the Snowflake server, it is pushed down. This improves performance of some queries.
autoPushdown
- Specifies whether automatic query pushdown is enabled. If pushdown is enabled, then when a query is run on
Spark, if part of the query can be "pushed down" to the Snowflake server, it is pushed down. This improves
performance of some queries.public Boolean isAutoPushdown()
Specifies whether automatic query pushdown is enabled. If pushdown is enabled, then when a query is run on Spark, if part of the query can be "pushed down" to the Snowflake server, it is pushed down. This improves performance of some queries.
public List<Option> getTableSchema()
Manually defines the target schema for the node. A list of structures with value
,
label
and description
keys. Each structure defines a column.
value
,
label
and description
keys. Each structure defines a column.public void setTableSchema(Collection<Option> tableSchema)
Manually defines the target schema for the node. A list of structures with value
,
label
and description
keys. Each structure defines a column.
tableSchema
- Manually defines the target schema for the node. A list of structures with value
,
label
and description
keys. Each structure defines a column.public SnowflakeNodeData withTableSchema(Option... tableSchema)
Manually defines the target schema for the node. A list of structures with value
,
label
and description
keys. Each structure defines a column.
NOTE: This method appends the values to the existing list (if any). Use
setTableSchema(java.util.Collection)
or withTableSchema(java.util.Collection)
if you want to
override the existing values.
tableSchema
- Manually defines the target schema for the node. A list of structures with value
,
label
and description
keys. Each structure defines a column.public SnowflakeNodeData withTableSchema(Collection<Option> tableSchema)
Manually defines the target schema for the node. A list of structures with value
,
label
and description
keys. Each structure defines a column.
tableSchema
- Manually defines the target schema for the node. A list of structures with value
,
label
and description
keys. Each structure defines a column.public String toString()
toString
in class Object
Object.toString()
public SnowflakeNodeData clone()
public void marshall(ProtocolMarshaller protocolMarshaller)
StructuredPojo
ProtocolMarshaller
.marshall
in interface StructuredPojo
protocolMarshaller
- Implementation of ProtocolMarshaller
used to marshall this object's data.