@Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class S3HudiCatalogTarget extends Object implements Serializable, Cloneable, StructuredPojo
Specifies a target that writes to a Hudi data source in the Glue Data Catalog.
Constructor and Description |
---|
S3HudiCatalogTarget() |
Modifier and Type | Method and Description |
---|---|
S3HudiCatalogTarget |
addAdditionalOptionsEntry(String key,
String value)
Add a single AdditionalOptions entry
|
S3HudiCatalogTarget |
clearAdditionalOptionsEntries()
Removes all the entries added into AdditionalOptions.
|
S3HudiCatalogTarget |
clone() |
boolean |
equals(Object obj) |
Map<String,String> |
getAdditionalOptions()
Specifies additional connection options for the connector.
|
String |
getDatabase()
The name of the database to write to.
|
List<String> |
getInputs()
The nodes that are inputs to the data target.
|
String |
getName()
The name of the data target.
|
List<List<String>> |
getPartitionKeys()
Specifies native partitioning using a sequence of keys.
|
CatalogSchemaChangePolicy |
getSchemaChangePolicy()
A policy that specifies update behavior for the crawler.
|
String |
getTable()
The name of the table in the database to write to.
|
int |
hashCode() |
void |
marshall(ProtocolMarshaller protocolMarshaller)
Marshalls this structured data using the given
ProtocolMarshaller . |
void |
setAdditionalOptions(Map<String,String> additionalOptions)
Specifies additional connection options for the connector.
|
void |
setDatabase(String database)
The name of the database to write to.
|
void |
setInputs(Collection<String> inputs)
The nodes that are inputs to the data target.
|
void |
setName(String name)
The name of the data target.
|
void |
setPartitionKeys(Collection<List<String>> partitionKeys)
Specifies native partitioning using a sequence of keys.
|
void |
setSchemaChangePolicy(CatalogSchemaChangePolicy schemaChangePolicy)
A policy that specifies update behavior for the crawler.
|
void |
setTable(String table)
The name of the table in the database to write to.
|
String |
toString()
Returns a string representation of this object.
|
S3HudiCatalogTarget |
withAdditionalOptions(Map<String,String> additionalOptions)
Specifies additional connection options for the connector.
|
S3HudiCatalogTarget |
withDatabase(String database)
The name of the database to write to.
|
S3HudiCatalogTarget |
withInputs(Collection<String> inputs)
The nodes that are inputs to the data target.
|
S3HudiCatalogTarget |
withInputs(String... inputs)
The nodes that are inputs to the data target.
|
S3HudiCatalogTarget |
withName(String name)
The name of the data target.
|
S3HudiCatalogTarget |
withPartitionKeys(Collection<List<String>> partitionKeys)
Specifies native partitioning using a sequence of keys.
|
S3HudiCatalogTarget |
withPartitionKeys(List<String>... partitionKeys)
Specifies native partitioning using a sequence of keys.
|
S3HudiCatalogTarget |
withSchemaChangePolicy(CatalogSchemaChangePolicy schemaChangePolicy)
A policy that specifies update behavior for the crawler.
|
S3HudiCatalogTarget |
withTable(String table)
The name of the table in the database to write to.
|
public void setName(String name)
The name of the data target.
name
- The name of the data target.public String getName()
The name of the data target.
public S3HudiCatalogTarget withName(String name)
The name of the data target.
name
- The name of the data target.public List<String> getInputs()
The nodes that are inputs to the data target.
public void setInputs(Collection<String> inputs)
The nodes that are inputs to the data target.
inputs
- The nodes that are inputs to the data target.public S3HudiCatalogTarget withInputs(String... inputs)
The nodes that are inputs to the data target.
NOTE: This method appends the values to the existing list (if any). Use
setInputs(java.util.Collection)
or withInputs(java.util.Collection)
if you want to override the
existing values.
inputs
- The nodes that are inputs to the data target.public S3HudiCatalogTarget withInputs(Collection<String> inputs)
The nodes that are inputs to the data target.
inputs
- The nodes that are inputs to the data target.public List<List<String>> getPartitionKeys()
Specifies native partitioning using a sequence of keys.
public void setPartitionKeys(Collection<List<String>> partitionKeys)
Specifies native partitioning using a sequence of keys.
partitionKeys
- Specifies native partitioning using a sequence of keys.public S3HudiCatalogTarget withPartitionKeys(List<String>... partitionKeys)
Specifies native partitioning using a sequence of keys.
NOTE: This method appends the values to the existing list (if any). Use
setPartitionKeys(java.util.Collection)
or withPartitionKeys(java.util.Collection)
if you want
to override the existing values.
partitionKeys
- Specifies native partitioning using a sequence of keys.public S3HudiCatalogTarget withPartitionKeys(Collection<List<String>> partitionKeys)
Specifies native partitioning using a sequence of keys.
partitionKeys
- Specifies native partitioning using a sequence of keys.public void setTable(String table)
The name of the table in the database to write to.
table
- The name of the table in the database to write to.public String getTable()
The name of the table in the database to write to.
public S3HudiCatalogTarget withTable(String table)
The name of the table in the database to write to.
table
- The name of the table in the database to write to.public void setDatabase(String database)
The name of the database to write to.
database
- The name of the database to write to.public String getDatabase()
The name of the database to write to.
public S3HudiCatalogTarget withDatabase(String database)
The name of the database to write to.
database
- The name of the database to write to.public Map<String,String> getAdditionalOptions()
Specifies additional connection options for the connector.
public void setAdditionalOptions(Map<String,String> additionalOptions)
Specifies additional connection options for the connector.
additionalOptions
- Specifies additional connection options for the connector.public S3HudiCatalogTarget withAdditionalOptions(Map<String,String> additionalOptions)
Specifies additional connection options for the connector.
additionalOptions
- Specifies additional connection options for the connector.public S3HudiCatalogTarget addAdditionalOptionsEntry(String key, String value)
public S3HudiCatalogTarget clearAdditionalOptionsEntries()
public void setSchemaChangePolicy(CatalogSchemaChangePolicy schemaChangePolicy)
A policy that specifies update behavior for the crawler.
schemaChangePolicy
- A policy that specifies update behavior for the crawler.public CatalogSchemaChangePolicy getSchemaChangePolicy()
A policy that specifies update behavior for the crawler.
public S3HudiCatalogTarget withSchemaChangePolicy(CatalogSchemaChangePolicy schemaChangePolicy)
A policy that specifies update behavior for the crawler.
schemaChangePolicy
- A policy that specifies update behavior for the crawler.public String toString()
toString
in class Object
Object.toString()
public S3HudiCatalogTarget clone()
public void marshall(ProtocolMarshaller protocolMarshaller)
StructuredPojo
ProtocolMarshaller
.marshall
in interface StructuredPojo
protocolMarshaller
- Implementation of ProtocolMarshaller
used to marshall this object's data.