Class S3IcebergDirectTarget
- All Implemented Interfaces:
Serializable
,SdkPojo
,ToCopyableBuilder<S3IcebergDirectTarget.Builder,
S3IcebergDirectTarget>
Specifies a target that writes to an Iceberg data source in Amazon S3.
- See Also:
-
Nested Class Summary
Nested Classes -
Method Summary
Modifier and TypeMethodDescriptionProvides additional configuration options for customizing the Iceberg table behavior.builder()
Specifies the compression codec used for Iceberg table files in S3.final String
Specifies the compression codec used for Iceberg table files in S3.final boolean
final boolean
equalsBySdkFields
(Object obj) Indicates whether some other object is "equal to" this one by SDK fields.final TargetFormat
format()
Specifies the file format used for storing Iceberg table data (e.g., Parquet, ORC).final String
Specifies the file format used for storing Iceberg table data (e.g., Parquet, ORC).final <T> Optional
<T> getValueForField
(String fieldName, Class<T> clazz) final boolean
For responses, this returns true if the service returned a value for the AdditionalOptions property.final int
hashCode()
final boolean
For responses, this returns true if the service returned a value for the Inputs property.final boolean
For responses, this returns true if the service returned a value for the PartitionKeys property.inputs()
Defines the single input source that provides data to this Iceberg target.final String
name()
Specifies the unique identifier for the Iceberg target node in your data pipeline.final String
Sets the number of target partitions for distributing Iceberg table files across S3.Specifies the columns used to partition the Iceberg table data in S3.final String
path()
Defines the S3 location where the Iceberg table data will be stored.final DirectSchemaChangePolicy
Defines how schema changes are handled when writing data to the Iceberg table.static Class
<? extends S3IcebergDirectTarget.Builder> Take this object and create a builder that contains all of the current property values of this object.final String
toString()
Returns a string representation of this object.Methods inherited from interface software.amazon.awssdk.utils.builder.ToCopyableBuilder
copy
-
Method Details
-
name
Specifies the unique identifier for the Iceberg target node in your data pipeline.
- Returns:
- Specifies the unique identifier for the Iceberg target node in your data pipeline.
-
hasInputs
public final boolean hasInputs()For responses, this returns true if the service returned a value for the Inputs property. This DOES NOT check that the value is non-empty (for which, you should check theisEmpty()
method on the property). This is useful because the SDK will never return a null collection or map, but you may need to differentiate between the service returning nothing (or null) and the service returning an empty collection or map. For requests, this returns true if a value for the property was specified in the request builder, and false if a value was not specified. -
inputs
Defines the single input source that provides data to this Iceberg target.
Attempts to modify the collection returned by this method will result in an UnsupportedOperationException.
This method will never return null. If you would like to know whether the service returned this field (so that you can differentiate between null and empty), you can use the
hasInputs()
method.- Returns:
- Defines the single input source that provides data to this Iceberg target.
-
hasPartitionKeys
public final boolean hasPartitionKeys()For responses, this returns true if the service returned a value for the PartitionKeys property. This DOES NOT check that the value is non-empty (for which, you should check theisEmpty()
method on the property). This is useful because the SDK will never return a null collection or map, but you may need to differentiate between the service returning nothing (or null) and the service returning an empty collection or map. For requests, this returns true if a value for the property was specified in the request builder, and false if a value was not specified. -
partitionKeys
Specifies the columns used to partition the Iceberg table data in S3.
Attempts to modify the collection returned by this method will result in an UnsupportedOperationException.
This method will never return null. If you would like to know whether the service returned this field (so that you can differentiate between null and empty), you can use the
hasPartitionKeys()
method.- Returns:
- Specifies the columns used to partition the Iceberg table data in S3.
-
path
Defines the S3 location where the Iceberg table data will be stored.
- Returns:
- Defines the S3 location where the Iceberg table data will be stored.
-
format
Specifies the file format used for storing Iceberg table data (e.g., Parquet, ORC).
If the service returns an enum value that is not available in the current SDK version,
format
will returnTargetFormat.UNKNOWN_TO_SDK_VERSION
. The raw value returned by the service is available fromformatAsString()
.- Returns:
- Specifies the file format used for storing Iceberg table data (e.g., Parquet, ORC).
- See Also:
-
formatAsString
Specifies the file format used for storing Iceberg table data (e.g., Parquet, ORC).
If the service returns an enum value that is not available in the current SDK version,
format
will returnTargetFormat.UNKNOWN_TO_SDK_VERSION
. The raw value returned by the service is available fromformatAsString()
.- Returns:
- Specifies the file format used for storing Iceberg table data (e.g., Parquet, ORC).
- See Also:
-
hasAdditionalOptions
public final boolean hasAdditionalOptions()For responses, this returns true if the service returned a value for the AdditionalOptions property. This DOES NOT check that the value is non-empty (for which, you should check theisEmpty()
method on the property). This is useful because the SDK will never return a null collection or map, but you may need to differentiate between the service returning nothing (or null) and the service returning an empty collection or map. For requests, this returns true if a value for the property was specified in the request builder, and false if a value was not specified. -
additionalOptions
Provides additional configuration options for customizing the Iceberg table behavior.
Attempts to modify the collection returned by this method will result in an UnsupportedOperationException.
This method will never return null. If you would like to know whether the service returned this field (so that you can differentiate between null and empty), you can use the
hasAdditionalOptions()
method.- Returns:
- Provides additional configuration options for customizing the Iceberg table behavior.
-
schemaChangePolicy
Defines how schema changes are handled when writing data to the Iceberg table.
- Returns:
- Defines how schema changes are handled when writing data to the Iceberg table.
-
compression
Specifies the compression codec used for Iceberg table files in S3.
If the service returns an enum value that is not available in the current SDK version,
compression
will returnIcebergTargetCompressionType.UNKNOWN_TO_SDK_VERSION
. The raw value returned by the service is available fromcompressionAsString()
.- Returns:
- Specifies the compression codec used for Iceberg table files in S3.
- See Also:
-
compressionAsString
Specifies the compression codec used for Iceberg table files in S3.
If the service returns an enum value that is not available in the current SDK version,
compression
will returnIcebergTargetCompressionType.UNKNOWN_TO_SDK_VERSION
. The raw value returned by the service is available fromcompressionAsString()
.- Returns:
- Specifies the compression codec used for Iceberg table files in S3.
- See Also:
-
numberTargetPartitions
Sets the number of target partitions for distributing Iceberg table files across S3.
- Returns:
- Sets the number of target partitions for distributing Iceberg table files across S3.
-
toBuilder
Description copied from interface:ToCopyableBuilder
Take this object and create a builder that contains all of the current property values of this object.- Specified by:
toBuilder
in interfaceToCopyableBuilder<S3IcebergDirectTarget.Builder,
S3IcebergDirectTarget> - Returns:
- a builder for type T
-
builder
-
serializableBuilderClass
-
hashCode
-
equals
-
equalsBySdkFields
Description copied from interface:SdkPojo
Indicates whether some other object is "equal to" this one by SDK fields. An SDK field is a modeled, non-inherited field in anSdkPojo
class, and is generated based on a service model.If an
SdkPojo
class does not have any inherited fields,equalsBySdkFields
andequals
are essentially the same.- Specified by:
equalsBySdkFields
in interfaceSdkPojo
- Parameters:
obj
- the object to be compared with- Returns:
- true if the other object equals to this object by sdk fields, false otherwise.
-
toString
-
getValueForField
-
sdkFields
-
sdkFieldNameToField
- Specified by:
sdkFieldNameToField
in interfaceSdkPojo
- Returns:
- The mapping between the field name and its corresponding field.
-