@Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class S3HudiSource extends Object implements Serializable, Cloneable, StructuredPojo
Specifies a Hudi data source stored in Amazon S3.
Constructor and Description |
---|
S3HudiSource() |
Modifier and Type | Method and Description |
---|---|
S3HudiSource |
addAdditionalHudiOptionsEntry(String key,
String value)
Add a single AdditionalHudiOptions entry
|
S3HudiSource |
clearAdditionalHudiOptionsEntries()
Removes all the entries added into AdditionalHudiOptions.
|
S3HudiSource |
clone() |
boolean |
equals(Object obj) |
Map<String,String> |
getAdditionalHudiOptions()
Specifies additional connection options.
|
S3DirectSourceAdditionalOptions |
getAdditionalOptions()
Specifies additional options for the connector.
|
String |
getName()
The name of the Hudi source.
|
List<GlueSchema> |
getOutputSchemas()
Specifies the data schema for the Hudi source.
|
List<String> |
getPaths()
A list of the Amazon S3 paths to read from.
|
int |
hashCode() |
void |
marshall(ProtocolMarshaller protocolMarshaller)
Marshalls this structured data using the given
ProtocolMarshaller . |
void |
setAdditionalHudiOptions(Map<String,String> additionalHudiOptions)
Specifies additional connection options.
|
void |
setAdditionalOptions(S3DirectSourceAdditionalOptions additionalOptions)
Specifies additional options for the connector.
|
void |
setName(String name)
The name of the Hudi source.
|
void |
setOutputSchemas(Collection<GlueSchema> outputSchemas)
Specifies the data schema for the Hudi source.
|
void |
setPaths(Collection<String> paths)
A list of the Amazon S3 paths to read from.
|
String |
toString()
Returns a string representation of this object.
|
S3HudiSource |
withAdditionalHudiOptions(Map<String,String> additionalHudiOptions)
Specifies additional connection options.
|
S3HudiSource |
withAdditionalOptions(S3DirectSourceAdditionalOptions additionalOptions)
Specifies additional options for the connector.
|
S3HudiSource |
withName(String name)
The name of the Hudi source.
|
S3HudiSource |
withOutputSchemas(Collection<GlueSchema> outputSchemas)
Specifies the data schema for the Hudi source.
|
S3HudiSource |
withOutputSchemas(GlueSchema... outputSchemas)
Specifies the data schema for the Hudi source.
|
S3HudiSource |
withPaths(Collection<String> paths)
A list of the Amazon S3 paths to read from.
|
S3HudiSource |
withPaths(String... paths)
A list of the Amazon S3 paths to read from.
|
public void setName(String name)
The name of the Hudi source.
name
- The name of the Hudi source.public String getName()
The name of the Hudi source.
public S3HudiSource withName(String name)
The name of the Hudi source.
name
- The name of the Hudi source.public List<String> getPaths()
A list of the Amazon S3 paths to read from.
public void setPaths(Collection<String> paths)
A list of the Amazon S3 paths to read from.
paths
- A list of the Amazon S3 paths to read from.public S3HudiSource withPaths(String... paths)
A list of the Amazon S3 paths to read from.
NOTE: This method appends the values to the existing list (if any). Use
setPaths(java.util.Collection)
or withPaths(java.util.Collection)
if you want to override the
existing values.
paths
- A list of the Amazon S3 paths to read from.public S3HudiSource withPaths(Collection<String> paths)
A list of the Amazon S3 paths to read from.
paths
- A list of the Amazon S3 paths to read from.public Map<String,String> getAdditionalHudiOptions()
Specifies additional connection options.
public void setAdditionalHudiOptions(Map<String,String> additionalHudiOptions)
Specifies additional connection options.
additionalHudiOptions
- Specifies additional connection options.public S3HudiSource withAdditionalHudiOptions(Map<String,String> additionalHudiOptions)
Specifies additional connection options.
additionalHudiOptions
- Specifies additional connection options.public S3HudiSource addAdditionalHudiOptionsEntry(String key, String value)
public S3HudiSource clearAdditionalHudiOptionsEntries()
public void setAdditionalOptions(S3DirectSourceAdditionalOptions additionalOptions)
Specifies additional options for the connector.
additionalOptions
- Specifies additional options for the connector.public S3DirectSourceAdditionalOptions getAdditionalOptions()
Specifies additional options for the connector.
public S3HudiSource withAdditionalOptions(S3DirectSourceAdditionalOptions additionalOptions)
Specifies additional options for the connector.
additionalOptions
- Specifies additional options for the connector.public List<GlueSchema> getOutputSchemas()
Specifies the data schema for the Hudi source.
public void setOutputSchemas(Collection<GlueSchema> outputSchemas)
Specifies the data schema for the Hudi source.
outputSchemas
- Specifies the data schema for the Hudi source.public S3HudiSource withOutputSchemas(GlueSchema... outputSchemas)
Specifies the data schema for the Hudi source.
NOTE: This method appends the values to the existing list (if any). Use
setOutputSchemas(java.util.Collection)
or withOutputSchemas(java.util.Collection)
if you want
to override the existing values.
outputSchemas
- Specifies the data schema for the Hudi source.public S3HudiSource withOutputSchemas(Collection<GlueSchema> outputSchemas)
Specifies the data schema for the Hudi source.
outputSchemas
- Specifies the data schema for the Hudi source.public String toString()
toString
in class Object
Object.toString()
public S3HudiSource clone()
public void marshall(ProtocolMarshaller protocolMarshaller)
StructuredPojo
ProtocolMarshaller
.marshall
in interface StructuredPojo
protocolMarshaller
- Implementation of ProtocolMarshaller
used to marshall this object's data.