@Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class AmazonRedshiftNodeData extends Object implements Serializable, Cloneable, StructuredPojo
Specifies an Amazon Redshift node.
Constructor and Description |
---|
AmazonRedshiftNodeData() |
Modifier and Type | Method and Description |
---|---|
AmazonRedshiftNodeData |
clone() |
boolean |
equals(Object obj) |
String |
getAccessType()
The access type for the Redshift connection.
|
String |
getAction()
Specifies how writing to a Redshift cluser will occur.
|
List<AmazonRedshiftAdvancedOption> |
getAdvancedOptions()
Optional values when connecting to the Redshift cluster.
|
Option |
getCatalogDatabase()
The name of the Glue Data Catalog database when working with a data catalog.
|
String |
getCatalogRedshiftSchema()
The Redshift schema name when working with a data catalog.
|
String |
getCatalogRedshiftTable()
The database table to read from.
|
Option |
getCatalogTable()
The Glue Data Catalog table name when working with a data catalog.
|
Option |
getConnection()
The Glue connection to the Redshift cluster.
|
String |
getCrawlerConnection()
Specifies the name of the connection that is associated with the catalog table used.
|
Option |
getIamRole()
Optional.
|
String |
getMergeAction()
The action used when to detemine how a MERGE in a Redshift sink will be handled.
|
String |
getMergeClause()
The SQL used in a custom merge to deal with matching records.
|
String |
getMergeWhenMatched()
The action used when to detemine how a MERGE in a Redshift sink will be handled when an existing record matches a
new record.
|
String |
getMergeWhenNotMatched()
The action used when to detemine how a MERGE in a Redshift sink will be handled when an existing record doesn't
match a new record.
|
String |
getPostAction()
The SQL used before a MERGE or APPEND with upsert is run.
|
String |
getPreAction()
The SQL used before a MERGE or APPEND with upsert is run.
|
String |
getSampleQuery()
The SQL used to fetch the data from a Redshift sources when the SourceType is 'query'.
|
Option |
getSchema()
The Redshift schema name when working with a direct connection.
|
List<Option> |
getSelectedColumns()
The list of column names used to determine a matching record when doing a MERGE or APPEND with upsert.
|
String |
getSourceType()
The source type to specify whether a specific table is the source or a custom query.
|
String |
getStagingTable()
The name of the temporary staging table that is used when doing a MERGE or APPEND with upsert.
|
Option |
getTable()
The Redshift table name when working with a direct connection.
|
String |
getTablePrefix()
Specifies the prefix to a table.
|
List<Option> |
getTableSchema()
The array of schema output for a given node.
|
String |
getTempDir()
The Amazon S3 path where temporary data can be staged when copying out of the database.
|
Boolean |
getUpsert()
The action used on Redshift sinks when doing an APPEND.
|
int |
hashCode() |
Boolean |
isUpsert()
The action used on Redshift sinks when doing an APPEND.
|
void |
marshall(ProtocolMarshaller protocolMarshaller)
Marshalls this structured data using the given
ProtocolMarshaller . |
void |
setAccessType(String accessType)
The access type for the Redshift connection.
|
void |
setAction(String action)
Specifies how writing to a Redshift cluser will occur.
|
void |
setAdvancedOptions(Collection<AmazonRedshiftAdvancedOption> advancedOptions)
Optional values when connecting to the Redshift cluster.
|
void |
setCatalogDatabase(Option catalogDatabase)
The name of the Glue Data Catalog database when working with a data catalog.
|
void |
setCatalogRedshiftSchema(String catalogRedshiftSchema)
The Redshift schema name when working with a data catalog.
|
void |
setCatalogRedshiftTable(String catalogRedshiftTable)
The database table to read from.
|
void |
setCatalogTable(Option catalogTable)
The Glue Data Catalog table name when working with a data catalog.
|
void |
setConnection(Option connection)
The Glue connection to the Redshift cluster.
|
void |
setCrawlerConnection(String crawlerConnection)
Specifies the name of the connection that is associated with the catalog table used.
|
void |
setIamRole(Option iamRole)
Optional.
|
void |
setMergeAction(String mergeAction)
The action used when to detemine how a MERGE in a Redshift sink will be handled.
|
void |
setMergeClause(String mergeClause)
The SQL used in a custom merge to deal with matching records.
|
void |
setMergeWhenMatched(String mergeWhenMatched)
The action used when to detemine how a MERGE in a Redshift sink will be handled when an existing record matches a
new record.
|
void |
setMergeWhenNotMatched(String mergeWhenNotMatched)
The action used when to detemine how a MERGE in a Redshift sink will be handled when an existing record doesn't
match a new record.
|
void |
setPostAction(String postAction)
The SQL used before a MERGE or APPEND with upsert is run.
|
void |
setPreAction(String preAction)
The SQL used before a MERGE or APPEND with upsert is run.
|
void |
setSampleQuery(String sampleQuery)
The SQL used to fetch the data from a Redshift sources when the SourceType is 'query'.
|
void |
setSchema(Option schema)
The Redshift schema name when working with a direct connection.
|
void |
setSelectedColumns(Collection<Option> selectedColumns)
The list of column names used to determine a matching record when doing a MERGE or APPEND with upsert.
|
void |
setSourceType(String sourceType)
The source type to specify whether a specific table is the source or a custom query.
|
void |
setStagingTable(String stagingTable)
The name of the temporary staging table that is used when doing a MERGE or APPEND with upsert.
|
void |
setTable(Option table)
The Redshift table name when working with a direct connection.
|
void |
setTablePrefix(String tablePrefix)
Specifies the prefix to a table.
|
void |
setTableSchema(Collection<Option> tableSchema)
The array of schema output for a given node.
|
void |
setTempDir(String tempDir)
The Amazon S3 path where temporary data can be staged when copying out of the database.
|
void |
setUpsert(Boolean upsert)
The action used on Redshift sinks when doing an APPEND.
|
String |
toString()
Returns a string representation of this object.
|
AmazonRedshiftNodeData |
withAccessType(String accessType)
The access type for the Redshift connection.
|
AmazonRedshiftNodeData |
withAction(String action)
Specifies how writing to a Redshift cluser will occur.
|
AmazonRedshiftNodeData |
withAdvancedOptions(AmazonRedshiftAdvancedOption... advancedOptions)
Optional values when connecting to the Redshift cluster.
|
AmazonRedshiftNodeData |
withAdvancedOptions(Collection<AmazonRedshiftAdvancedOption> advancedOptions)
Optional values when connecting to the Redshift cluster.
|
AmazonRedshiftNodeData |
withCatalogDatabase(Option catalogDatabase)
The name of the Glue Data Catalog database when working with a data catalog.
|
AmazonRedshiftNodeData |
withCatalogRedshiftSchema(String catalogRedshiftSchema)
The Redshift schema name when working with a data catalog.
|
AmazonRedshiftNodeData |
withCatalogRedshiftTable(String catalogRedshiftTable)
The database table to read from.
|
AmazonRedshiftNodeData |
withCatalogTable(Option catalogTable)
The Glue Data Catalog table name when working with a data catalog.
|
AmazonRedshiftNodeData |
withConnection(Option connection)
The Glue connection to the Redshift cluster.
|
AmazonRedshiftNodeData |
withCrawlerConnection(String crawlerConnection)
Specifies the name of the connection that is associated with the catalog table used.
|
AmazonRedshiftNodeData |
withIamRole(Option iamRole)
Optional.
|
AmazonRedshiftNodeData |
withMergeAction(String mergeAction)
The action used when to detemine how a MERGE in a Redshift sink will be handled.
|
AmazonRedshiftNodeData |
withMergeClause(String mergeClause)
The SQL used in a custom merge to deal with matching records.
|
AmazonRedshiftNodeData |
withMergeWhenMatched(String mergeWhenMatched)
The action used when to detemine how a MERGE in a Redshift sink will be handled when an existing record matches a
new record.
|
AmazonRedshiftNodeData |
withMergeWhenNotMatched(String mergeWhenNotMatched)
The action used when to detemine how a MERGE in a Redshift sink will be handled when an existing record doesn't
match a new record.
|
AmazonRedshiftNodeData |
withPostAction(String postAction)
The SQL used before a MERGE or APPEND with upsert is run.
|
AmazonRedshiftNodeData |
withPreAction(String preAction)
The SQL used before a MERGE or APPEND with upsert is run.
|
AmazonRedshiftNodeData |
withSampleQuery(String sampleQuery)
The SQL used to fetch the data from a Redshift sources when the SourceType is 'query'.
|
AmazonRedshiftNodeData |
withSchema(Option schema)
The Redshift schema name when working with a direct connection.
|
AmazonRedshiftNodeData |
withSelectedColumns(Collection<Option> selectedColumns)
The list of column names used to determine a matching record when doing a MERGE or APPEND with upsert.
|
AmazonRedshiftNodeData |
withSelectedColumns(Option... selectedColumns)
The list of column names used to determine a matching record when doing a MERGE or APPEND with upsert.
|
AmazonRedshiftNodeData |
withSourceType(String sourceType)
The source type to specify whether a specific table is the source or a custom query.
|
AmazonRedshiftNodeData |
withStagingTable(String stagingTable)
The name of the temporary staging table that is used when doing a MERGE or APPEND with upsert.
|
AmazonRedshiftNodeData |
withTable(Option table)
The Redshift table name when working with a direct connection.
|
AmazonRedshiftNodeData |
withTablePrefix(String tablePrefix)
Specifies the prefix to a table.
|
AmazonRedshiftNodeData |
withTableSchema(Collection<Option> tableSchema)
The array of schema output for a given node.
|
AmazonRedshiftNodeData |
withTableSchema(Option... tableSchema)
The array of schema output for a given node.
|
AmazonRedshiftNodeData |
withTempDir(String tempDir)
The Amazon S3 path where temporary data can be staged when copying out of the database.
|
AmazonRedshiftNodeData |
withUpsert(Boolean upsert)
The action used on Redshift sinks when doing an APPEND.
|
public void setAccessType(String accessType)
The access type for the Redshift connection. Can be a direct connection or catalog connections.
accessType
- The access type for the Redshift connection. Can be a direct connection or catalog connections.public String getAccessType()
The access type for the Redshift connection. Can be a direct connection or catalog connections.
public AmazonRedshiftNodeData withAccessType(String accessType)
The access type for the Redshift connection. Can be a direct connection or catalog connections.
accessType
- The access type for the Redshift connection. Can be a direct connection or catalog connections.public void setSourceType(String sourceType)
The source type to specify whether a specific table is the source or a custom query.
sourceType
- The source type to specify whether a specific table is the source or a custom query.public String getSourceType()
The source type to specify whether a specific table is the source or a custom query.
public AmazonRedshiftNodeData withSourceType(String sourceType)
The source type to specify whether a specific table is the source or a custom query.
sourceType
- The source type to specify whether a specific table is the source or a custom query.public void setConnection(Option connection)
The Glue connection to the Redshift cluster.
connection
- The Glue connection to the Redshift cluster.public Option getConnection()
The Glue connection to the Redshift cluster.
public AmazonRedshiftNodeData withConnection(Option connection)
The Glue connection to the Redshift cluster.
connection
- The Glue connection to the Redshift cluster.public void setSchema(Option schema)
The Redshift schema name when working with a direct connection.
schema
- The Redshift schema name when working with a direct connection.public Option getSchema()
The Redshift schema name when working with a direct connection.
public AmazonRedshiftNodeData withSchema(Option schema)
The Redshift schema name when working with a direct connection.
schema
- The Redshift schema name when working with a direct connection.public void setTable(Option table)
The Redshift table name when working with a direct connection.
table
- The Redshift table name when working with a direct connection.public Option getTable()
The Redshift table name when working with a direct connection.
public AmazonRedshiftNodeData withTable(Option table)
The Redshift table name when working with a direct connection.
table
- The Redshift table name when working with a direct connection.public void setCatalogDatabase(Option catalogDatabase)
The name of the Glue Data Catalog database when working with a data catalog.
catalogDatabase
- The name of the Glue Data Catalog database when working with a data catalog.public Option getCatalogDatabase()
The name of the Glue Data Catalog database when working with a data catalog.
public AmazonRedshiftNodeData withCatalogDatabase(Option catalogDatabase)
The name of the Glue Data Catalog database when working with a data catalog.
catalogDatabase
- The name of the Glue Data Catalog database when working with a data catalog.public void setCatalogTable(Option catalogTable)
The Glue Data Catalog table name when working with a data catalog.
catalogTable
- The Glue Data Catalog table name when working with a data catalog.public Option getCatalogTable()
The Glue Data Catalog table name when working with a data catalog.
public AmazonRedshiftNodeData withCatalogTable(Option catalogTable)
The Glue Data Catalog table name when working with a data catalog.
catalogTable
- The Glue Data Catalog table name when working with a data catalog.public void setCatalogRedshiftSchema(String catalogRedshiftSchema)
The Redshift schema name when working with a data catalog.
catalogRedshiftSchema
- The Redshift schema name when working with a data catalog.public String getCatalogRedshiftSchema()
The Redshift schema name when working with a data catalog.
public AmazonRedshiftNodeData withCatalogRedshiftSchema(String catalogRedshiftSchema)
The Redshift schema name when working with a data catalog.
catalogRedshiftSchema
- The Redshift schema name when working with a data catalog.public void setCatalogRedshiftTable(String catalogRedshiftTable)
The database table to read from.
catalogRedshiftTable
- The database table to read from.public String getCatalogRedshiftTable()
The database table to read from.
public AmazonRedshiftNodeData withCatalogRedshiftTable(String catalogRedshiftTable)
The database table to read from.
catalogRedshiftTable
- The database table to read from.public void setTempDir(String tempDir)
The Amazon S3 path where temporary data can be staged when copying out of the database.
tempDir
- The Amazon S3 path where temporary data can be staged when copying out of the database.public String getTempDir()
The Amazon S3 path where temporary data can be staged when copying out of the database.
public AmazonRedshiftNodeData withTempDir(String tempDir)
The Amazon S3 path where temporary data can be staged when copying out of the database.
tempDir
- The Amazon S3 path where temporary data can be staged when copying out of the database.public void setIamRole(Option iamRole)
Optional. The role name use when connection to S3. The IAM role ill default to the role on the job when left blank.
iamRole
- Optional. The role name use when connection to S3. The IAM role ill default to the role on the job when
left blank.public Option getIamRole()
Optional. The role name use when connection to S3. The IAM role ill default to the role on the job when left blank.
public AmazonRedshiftNodeData withIamRole(Option iamRole)
Optional. The role name use when connection to S3. The IAM role ill default to the role on the job when left blank.
iamRole
- Optional. The role name use when connection to S3. The IAM role ill default to the role on the job when
left blank.public List<AmazonRedshiftAdvancedOption> getAdvancedOptions()
Optional values when connecting to the Redshift cluster.
public void setAdvancedOptions(Collection<AmazonRedshiftAdvancedOption> advancedOptions)
Optional values when connecting to the Redshift cluster.
advancedOptions
- Optional values when connecting to the Redshift cluster.public AmazonRedshiftNodeData withAdvancedOptions(AmazonRedshiftAdvancedOption... advancedOptions)
Optional values when connecting to the Redshift cluster.
NOTE: This method appends the values to the existing list (if any). Use
setAdvancedOptions(java.util.Collection)
or withAdvancedOptions(java.util.Collection)
if you
want to override the existing values.
advancedOptions
- Optional values when connecting to the Redshift cluster.public AmazonRedshiftNodeData withAdvancedOptions(Collection<AmazonRedshiftAdvancedOption> advancedOptions)
Optional values when connecting to the Redshift cluster.
advancedOptions
- Optional values when connecting to the Redshift cluster.public void setSampleQuery(String sampleQuery)
The SQL used to fetch the data from a Redshift sources when the SourceType is 'query'.
sampleQuery
- The SQL used to fetch the data from a Redshift sources when the SourceType is 'query'.public String getSampleQuery()
The SQL used to fetch the data from a Redshift sources when the SourceType is 'query'.
public AmazonRedshiftNodeData withSampleQuery(String sampleQuery)
The SQL used to fetch the data from a Redshift sources when the SourceType is 'query'.
sampleQuery
- The SQL used to fetch the data from a Redshift sources when the SourceType is 'query'.public void setPreAction(String preAction)
The SQL used before a MERGE or APPEND with upsert is run.
preAction
- The SQL used before a MERGE or APPEND with upsert is run.public String getPreAction()
The SQL used before a MERGE or APPEND with upsert is run.
public AmazonRedshiftNodeData withPreAction(String preAction)
The SQL used before a MERGE or APPEND with upsert is run.
preAction
- The SQL used before a MERGE or APPEND with upsert is run.public void setPostAction(String postAction)
The SQL used before a MERGE or APPEND with upsert is run.
postAction
- The SQL used before a MERGE or APPEND with upsert is run.public String getPostAction()
The SQL used before a MERGE or APPEND with upsert is run.
public AmazonRedshiftNodeData withPostAction(String postAction)
The SQL used before a MERGE or APPEND with upsert is run.
postAction
- The SQL used before a MERGE or APPEND with upsert is run.public void setAction(String action)
Specifies how writing to a Redshift cluser will occur.
action
- Specifies how writing to a Redshift cluser will occur.public String getAction()
Specifies how writing to a Redshift cluser will occur.
public AmazonRedshiftNodeData withAction(String action)
Specifies how writing to a Redshift cluser will occur.
action
- Specifies how writing to a Redshift cluser will occur.public void setTablePrefix(String tablePrefix)
Specifies the prefix to a table.
tablePrefix
- Specifies the prefix to a table.public String getTablePrefix()
Specifies the prefix to a table.
public AmazonRedshiftNodeData withTablePrefix(String tablePrefix)
Specifies the prefix to a table.
tablePrefix
- Specifies the prefix to a table.public void setUpsert(Boolean upsert)
The action used on Redshift sinks when doing an APPEND.
upsert
- The action used on Redshift sinks when doing an APPEND.public Boolean getUpsert()
The action used on Redshift sinks when doing an APPEND.
public AmazonRedshiftNodeData withUpsert(Boolean upsert)
The action used on Redshift sinks when doing an APPEND.
upsert
- The action used on Redshift sinks when doing an APPEND.public Boolean isUpsert()
The action used on Redshift sinks when doing an APPEND.
public void setMergeAction(String mergeAction)
The action used when to detemine how a MERGE in a Redshift sink will be handled.
mergeAction
- The action used when to detemine how a MERGE in a Redshift sink will be handled.public String getMergeAction()
The action used when to detemine how a MERGE in a Redshift sink will be handled.
public AmazonRedshiftNodeData withMergeAction(String mergeAction)
The action used when to detemine how a MERGE in a Redshift sink will be handled.
mergeAction
- The action used when to detemine how a MERGE in a Redshift sink will be handled.public void setMergeWhenMatched(String mergeWhenMatched)
The action used when to detemine how a MERGE in a Redshift sink will be handled when an existing record matches a new record.
mergeWhenMatched
- The action used when to detemine how a MERGE in a Redshift sink will be handled when an existing record
matches a new record.public String getMergeWhenMatched()
The action used when to detemine how a MERGE in a Redshift sink will be handled when an existing record matches a new record.
public AmazonRedshiftNodeData withMergeWhenMatched(String mergeWhenMatched)
The action used when to detemine how a MERGE in a Redshift sink will be handled when an existing record matches a new record.
mergeWhenMatched
- The action used when to detemine how a MERGE in a Redshift sink will be handled when an existing record
matches a new record.public void setMergeWhenNotMatched(String mergeWhenNotMatched)
The action used when to detemine how a MERGE in a Redshift sink will be handled when an existing record doesn't match a new record.
mergeWhenNotMatched
- The action used when to detemine how a MERGE in a Redshift sink will be handled when an existing record
doesn't match a new record.public String getMergeWhenNotMatched()
The action used when to detemine how a MERGE in a Redshift sink will be handled when an existing record doesn't match a new record.
public AmazonRedshiftNodeData withMergeWhenNotMatched(String mergeWhenNotMatched)
The action used when to detemine how a MERGE in a Redshift sink will be handled when an existing record doesn't match a new record.
mergeWhenNotMatched
- The action used when to detemine how a MERGE in a Redshift sink will be handled when an existing record
doesn't match a new record.public void setMergeClause(String mergeClause)
The SQL used in a custom merge to deal with matching records.
mergeClause
- The SQL used in a custom merge to deal with matching records.public String getMergeClause()
The SQL used in a custom merge to deal with matching records.
public AmazonRedshiftNodeData withMergeClause(String mergeClause)
The SQL used in a custom merge to deal with matching records.
mergeClause
- The SQL used in a custom merge to deal with matching records.public void setCrawlerConnection(String crawlerConnection)
Specifies the name of the connection that is associated with the catalog table used.
crawlerConnection
- Specifies the name of the connection that is associated with the catalog table used.public String getCrawlerConnection()
Specifies the name of the connection that is associated with the catalog table used.
public AmazonRedshiftNodeData withCrawlerConnection(String crawlerConnection)
Specifies the name of the connection that is associated with the catalog table used.
crawlerConnection
- Specifies the name of the connection that is associated with the catalog table used.public List<Option> getTableSchema()
The array of schema output for a given node.
public void setTableSchema(Collection<Option> tableSchema)
The array of schema output for a given node.
tableSchema
- The array of schema output for a given node.public AmazonRedshiftNodeData withTableSchema(Option... tableSchema)
The array of schema output for a given node.
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
- The array of schema output for a given node.public AmazonRedshiftNodeData withTableSchema(Collection<Option> tableSchema)
The array of schema output for a given node.
tableSchema
- The array of schema output for a given node.public void setStagingTable(String stagingTable)
The name of the temporary staging table that is used when doing a MERGE or APPEND with upsert.
stagingTable
- The name of the temporary staging table that is used when doing a MERGE or APPEND with upsert.public String getStagingTable()
The name of the temporary staging table that is used when doing a MERGE or APPEND with upsert.
public AmazonRedshiftNodeData withStagingTable(String stagingTable)
The name of the temporary staging table that is used when doing a MERGE or APPEND with upsert.
stagingTable
- The name of the temporary staging table that is used when doing a MERGE or APPEND with upsert.public List<Option> getSelectedColumns()
The list of column names used to determine a matching record when doing a MERGE or APPEND with upsert.
public void setSelectedColumns(Collection<Option> selectedColumns)
The list of column names used to determine a matching record when doing a MERGE or APPEND with upsert.
selectedColumns
- The list of column names used to determine a matching record when doing a MERGE or APPEND with upsert.public AmazonRedshiftNodeData withSelectedColumns(Option... selectedColumns)
The list of column names used to determine a matching record when doing a MERGE or APPEND with upsert.
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
- The list of column names used to determine a matching record when doing a MERGE or APPEND with upsert.public AmazonRedshiftNodeData withSelectedColumns(Collection<Option> selectedColumns)
The list of column names used to determine a matching record when doing a MERGE or APPEND with upsert.
selectedColumns
- The list of column names used to determine a matching record when doing a MERGE or APPEND with upsert.public String toString()
toString
in class Object
Object.toString()
public AmazonRedshiftNodeData clone()
public void marshall(ProtocolMarshaller protocolMarshaller)
StructuredPojo
ProtocolMarshaller
.marshall
in interface StructuredPojo
protocolMarshaller
- Implementation of ProtocolMarshaller
used to marshall this object's data.