@Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class S3DeltaDirectTarget extends Object implements Serializable, Cloneable, StructuredPojo
Specifies a target that writes to a Delta Lake data source in Amazon S3.
Constructor and Description |
---|
S3DeltaDirectTarget() |
Modifier and Type | Method and Description |
---|---|
S3DeltaDirectTarget |
addAdditionalOptionsEntry(String key,
String value)
Add a single AdditionalOptions entry
|
S3DeltaDirectTarget |
clearAdditionalOptionsEntries()
Removes all the entries added into AdditionalOptions.
|
S3DeltaDirectTarget |
clone() |
boolean |
equals(Object obj) |
Map<String,String> |
getAdditionalOptions()
Specifies additional connection options for the connector.
|
String |
getCompression()
Specifies how the data is compressed.
|
String |
getFormat()
Specifies the data output format for the target.
|
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.
|
String |
getPath()
The Amazon S3 path of your Delta Lake data source to write to.
|
DirectSchemaChangePolicy |
getSchemaChangePolicy()
A policy that specifies update behavior for the crawler.
|
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 |
setCompression(String compression)
Specifies how the data is compressed.
|
void |
setFormat(String format)
Specifies the data output format for the target.
|
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 |
setPath(String path)
The Amazon S3 path of your Delta Lake data source to write to.
|
void |
setSchemaChangePolicy(DirectSchemaChangePolicy schemaChangePolicy)
A policy that specifies update behavior for the crawler.
|
String |
toString()
Returns a string representation of this object.
|
S3DeltaDirectTarget |
withAdditionalOptions(Map<String,String> additionalOptions)
Specifies additional connection options for the connector.
|
S3DeltaDirectTarget |
withCompression(DeltaTargetCompressionType compression)
Specifies how the data is compressed.
|
S3DeltaDirectTarget |
withCompression(String compression)
Specifies how the data is compressed.
|
S3DeltaDirectTarget |
withFormat(String format)
Specifies the data output format for the target.
|
S3DeltaDirectTarget |
withFormat(TargetFormat format)
Specifies the data output format for the target.
|
S3DeltaDirectTarget |
withInputs(Collection<String> inputs)
The nodes that are inputs to the data target.
|
S3DeltaDirectTarget |
withInputs(String... inputs)
The nodes that are inputs to the data target.
|
S3DeltaDirectTarget |
withName(String name)
The name of the data target.
|
S3DeltaDirectTarget |
withPartitionKeys(Collection<List<String>> partitionKeys)
Specifies native partitioning using a sequence of keys.
|
S3DeltaDirectTarget |
withPartitionKeys(List<String>... partitionKeys)
Specifies native partitioning using a sequence of keys.
|
S3DeltaDirectTarget |
withPath(String path)
The Amazon S3 path of your Delta Lake data source to write to.
|
S3DeltaDirectTarget |
withSchemaChangePolicy(DirectSchemaChangePolicy schemaChangePolicy)
A policy that specifies update behavior for the crawler.
|
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 S3DeltaDirectTarget 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 S3DeltaDirectTarget 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 S3DeltaDirectTarget 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 S3DeltaDirectTarget 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 S3DeltaDirectTarget withPartitionKeys(Collection<List<String>> partitionKeys)
Specifies native partitioning using a sequence of keys.
partitionKeys
- Specifies native partitioning using a sequence of keys.public void setPath(String path)
The Amazon S3 path of your Delta Lake data source to write to.
path
- The Amazon S3 path of your Delta Lake data source to write to.public String getPath()
The Amazon S3 path of your Delta Lake data source to write to.
public S3DeltaDirectTarget withPath(String path)
The Amazon S3 path of your Delta Lake data source to write to.
path
- The Amazon S3 path of your Delta Lake data source to write to.public void setCompression(String compression)
Specifies how the data is compressed. This is generally not necessary if the data has a standard file extension.
Possible values are "gzip"
and "bzip"
).
compression
- Specifies how the data is compressed. This is generally not necessary if the data has a standard file
extension. Possible values are "gzip"
and "bzip"
).DeltaTargetCompressionType
public String getCompression()
Specifies how the data is compressed. This is generally not necessary if the data has a standard file extension.
Possible values are "gzip"
and "bzip"
).
"gzip"
and "bzip"
).DeltaTargetCompressionType
public S3DeltaDirectTarget withCompression(String compression)
Specifies how the data is compressed. This is generally not necessary if the data has a standard file extension.
Possible values are "gzip"
and "bzip"
).
compression
- Specifies how the data is compressed. This is generally not necessary if the data has a standard file
extension. Possible values are "gzip"
and "bzip"
).DeltaTargetCompressionType
public S3DeltaDirectTarget withCompression(DeltaTargetCompressionType compression)
Specifies how the data is compressed. This is generally not necessary if the data has a standard file extension.
Possible values are "gzip"
and "bzip"
).
compression
- Specifies how the data is compressed. This is generally not necessary if the data has a standard file
extension. Possible values are "gzip"
and "bzip"
).DeltaTargetCompressionType
public void setFormat(String format)
Specifies the data output format for the target.
format
- Specifies the data output format for the target.TargetFormat
public String getFormat()
Specifies the data output format for the target.
TargetFormat
public S3DeltaDirectTarget withFormat(String format)
Specifies the data output format for the target.
format
- Specifies the data output format for the target.TargetFormat
public S3DeltaDirectTarget withFormat(TargetFormat format)
Specifies the data output format for the target.
format
- Specifies the data output format for the target.TargetFormat
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 S3DeltaDirectTarget withAdditionalOptions(Map<String,String> additionalOptions)
Specifies additional connection options for the connector.
additionalOptions
- Specifies additional connection options for the connector.public S3DeltaDirectTarget addAdditionalOptionsEntry(String key, String value)
public S3DeltaDirectTarget clearAdditionalOptionsEntries()
public void setSchemaChangePolicy(DirectSchemaChangePolicy schemaChangePolicy)
A policy that specifies update behavior for the crawler.
schemaChangePolicy
- A policy that specifies update behavior for the crawler.public DirectSchemaChangePolicy getSchemaChangePolicy()
A policy that specifies update behavior for the crawler.
public S3DeltaDirectTarget withSchemaChangePolicy(DirectSchemaChangePolicy 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 S3DeltaDirectTarget clone()
public void marshall(ProtocolMarshaller protocolMarshaller)
StructuredPojo
ProtocolMarshaller
.marshall
in interface StructuredPojo
protocolMarshaller
- Implementation of ProtocolMarshaller
used to marshall this object's data.