@Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class S3CsvSource extends Object implements Serializable, Cloneable, StructuredPojo
Specifies a command-separated value (CSV) data store stored in Amazon S3.
Constructor and Description |
---|
S3CsvSource() |
Modifier and Type | Method and Description |
---|---|
S3CsvSource |
clone() |
boolean |
equals(Object obj) |
S3DirectSourceAdditionalOptions |
getAdditionalOptions()
Specifies additional connection options.
|
String |
getCompressionType()
Specifies how the data is compressed.
|
String |
getEscaper()
Specifies a character to use for escaping.
|
List<String> |
getExclusions()
A string containing a JSON list of Unix-style glob patterns to exclude.
|
String |
getGroupFiles()
Grouping files is turned on by default when the input contains more than 50,000 files.
|
String |
getGroupSize()
The target group size in bytes.
|
Integer |
getMaxBand()
This option controls the duration in milliseconds after which the s3 listing is likely to be consistent.
|
Integer |
getMaxFilesInBand()
This option specifies the maximum number of files to save from the last maxBand seconds.
|
Boolean |
getMultiline()
A Boolean value that specifies whether a single record can span multiple lines.
|
String |
getName()
The name of the data store.
|
Boolean |
getOptimizePerformance()
A Boolean value that specifies whether to use the advanced SIMD CSV reader along with Apache Arrow based columnar
memory formats.
|
List<GlueSchema> |
getOutputSchemas()
Specifies the data schema for the S3 CSV source.
|
List<String> |
getPaths()
A list of the Amazon S3 paths to read from.
|
String |
getQuoteChar()
Specifies the character to use for quoting.
|
Boolean |
getRecurse()
If set to true, recursively reads files in all subdirectories under the specified paths.
|
String |
getSeparator()
Specifies the delimiter character.
|
Boolean |
getSkipFirst()
A Boolean value that specifies whether to skip the first data line.
|
Boolean |
getWithHeader()
A Boolean value that specifies whether to treat the first line as a header.
|
Boolean |
getWriteHeader()
A Boolean value that specifies whether to write the header to output.
|
int |
hashCode() |
Boolean |
isMultiline()
A Boolean value that specifies whether a single record can span multiple lines.
|
Boolean |
isOptimizePerformance()
A Boolean value that specifies whether to use the advanced SIMD CSV reader along with Apache Arrow based columnar
memory formats.
|
Boolean |
isRecurse()
If set to true, recursively reads files in all subdirectories under the specified paths.
|
Boolean |
isSkipFirst()
A Boolean value that specifies whether to skip the first data line.
|
Boolean |
isWithHeader()
A Boolean value that specifies whether to treat the first line as a header.
|
Boolean |
isWriteHeader()
A Boolean value that specifies whether to write the header to output.
|
void |
marshall(ProtocolMarshaller protocolMarshaller)
Marshalls this structured data using the given
ProtocolMarshaller . |
void |
setAdditionalOptions(S3DirectSourceAdditionalOptions additionalOptions)
Specifies additional connection options.
|
void |
setCompressionType(String compressionType)
Specifies how the data is compressed.
|
void |
setEscaper(String escaper)
Specifies a character to use for escaping.
|
void |
setExclusions(Collection<String> exclusions)
A string containing a JSON list of Unix-style glob patterns to exclude.
|
void |
setGroupFiles(String groupFiles)
Grouping files is turned on by default when the input contains more than 50,000 files.
|
void |
setGroupSize(String groupSize)
The target group size in bytes.
|
void |
setMaxBand(Integer maxBand)
This option controls the duration in milliseconds after which the s3 listing is likely to be consistent.
|
void |
setMaxFilesInBand(Integer maxFilesInBand)
This option specifies the maximum number of files to save from the last maxBand seconds.
|
void |
setMultiline(Boolean multiline)
A Boolean value that specifies whether a single record can span multiple lines.
|
void |
setName(String name)
The name of the data store.
|
void |
setOptimizePerformance(Boolean optimizePerformance)
A Boolean value that specifies whether to use the advanced SIMD CSV reader along with Apache Arrow based columnar
memory formats.
|
void |
setOutputSchemas(Collection<GlueSchema> outputSchemas)
Specifies the data schema for the S3 CSV source.
|
void |
setPaths(Collection<String> paths)
A list of the Amazon S3 paths to read from.
|
void |
setQuoteChar(String quoteChar)
Specifies the character to use for quoting.
|
void |
setRecurse(Boolean recurse)
If set to true, recursively reads files in all subdirectories under the specified paths.
|
void |
setSeparator(String separator)
Specifies the delimiter character.
|
void |
setSkipFirst(Boolean skipFirst)
A Boolean value that specifies whether to skip the first data line.
|
void |
setWithHeader(Boolean withHeader)
A Boolean value that specifies whether to treat the first line as a header.
|
void |
setWriteHeader(Boolean writeHeader)
A Boolean value that specifies whether to write the header to output.
|
String |
toString()
Returns a string representation of this object.
|
S3CsvSource |
withAdditionalOptions(S3DirectSourceAdditionalOptions additionalOptions)
Specifies additional connection options.
|
S3CsvSource |
withCompressionType(CompressionType compressionType)
Specifies how the data is compressed.
|
S3CsvSource |
withCompressionType(String compressionType)
Specifies how the data is compressed.
|
S3CsvSource |
withEscaper(String escaper)
Specifies a character to use for escaping.
|
S3CsvSource |
withExclusions(Collection<String> exclusions)
A string containing a JSON list of Unix-style glob patterns to exclude.
|
S3CsvSource |
withExclusions(String... exclusions)
A string containing a JSON list of Unix-style glob patterns to exclude.
|
S3CsvSource |
withGroupFiles(String groupFiles)
Grouping files is turned on by default when the input contains more than 50,000 files.
|
S3CsvSource |
withGroupSize(String groupSize)
The target group size in bytes.
|
S3CsvSource |
withMaxBand(Integer maxBand)
This option controls the duration in milliseconds after which the s3 listing is likely to be consistent.
|
S3CsvSource |
withMaxFilesInBand(Integer maxFilesInBand)
This option specifies the maximum number of files to save from the last maxBand seconds.
|
S3CsvSource |
withMultiline(Boolean multiline)
A Boolean value that specifies whether a single record can span multiple lines.
|
S3CsvSource |
withName(String name)
The name of the data store.
|
S3CsvSource |
withOptimizePerformance(Boolean optimizePerformance)
A Boolean value that specifies whether to use the advanced SIMD CSV reader along with Apache Arrow based columnar
memory formats.
|
S3CsvSource |
withOutputSchemas(Collection<GlueSchema> outputSchemas)
Specifies the data schema for the S3 CSV source.
|
S3CsvSource |
withOutputSchemas(GlueSchema... outputSchemas)
Specifies the data schema for the S3 CSV source.
|
S3CsvSource |
withPaths(Collection<String> paths)
A list of the Amazon S3 paths to read from.
|
S3CsvSource |
withPaths(String... paths)
A list of the Amazon S3 paths to read from.
|
S3CsvSource |
withQuoteChar(QuoteChar quoteChar)
Specifies the character to use for quoting.
|
S3CsvSource |
withQuoteChar(String quoteChar)
Specifies the character to use for quoting.
|
S3CsvSource |
withRecurse(Boolean recurse)
If set to true, recursively reads files in all subdirectories under the specified paths.
|
S3CsvSource |
withSeparator(Separator separator)
Specifies the delimiter character.
|
S3CsvSource |
withSeparator(String separator)
Specifies the delimiter character.
|
S3CsvSource |
withSkipFirst(Boolean skipFirst)
A Boolean value that specifies whether to skip the first data line.
|
S3CsvSource |
withWithHeader(Boolean withHeader)
A Boolean value that specifies whether to treat the first line as a header.
|
S3CsvSource |
withWriteHeader(Boolean writeHeader)
A Boolean value that specifies whether to write the header to output.
|
public void setName(String name)
The name of the data store.
name
- The name of the data store.public String getName()
The name of the data store.
public S3CsvSource withName(String name)
The name of the data store.
name
- The name of the data store.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 S3CsvSource 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 S3CsvSource 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 void setCompressionType(String compressionType)
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"
).
compressionType
- 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"
).CompressionType
public String getCompressionType()
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"
).CompressionType
public S3CsvSource withCompressionType(String compressionType)
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"
).
compressionType
- 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"
).CompressionType
public S3CsvSource withCompressionType(CompressionType compressionType)
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"
).
compressionType
- 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"
).CompressionType
public List<String> getExclusions()
A string containing a JSON list of Unix-style glob patterns to exclude. For example, "[\"**.pdf\"]" excludes all PDF files.
public void setExclusions(Collection<String> exclusions)
A string containing a JSON list of Unix-style glob patterns to exclude. For example, "[\"**.pdf\"]" excludes all PDF files.
exclusions
- A string containing a JSON list of Unix-style glob patterns to exclude. For example, "[\"**.pdf\"]"
excludes all PDF files.public S3CsvSource withExclusions(String... exclusions)
A string containing a JSON list of Unix-style glob patterns to exclude. For example, "[\"**.pdf\"]" excludes all PDF files.
NOTE: This method appends the values to the existing list (if any). Use
setExclusions(java.util.Collection)
or withExclusions(java.util.Collection)
if you want to
override the existing values.
exclusions
- A string containing a JSON list of Unix-style glob patterns to exclude. For example, "[\"**.pdf\"]"
excludes all PDF files.public S3CsvSource withExclusions(Collection<String> exclusions)
A string containing a JSON list of Unix-style glob patterns to exclude. For example, "[\"**.pdf\"]" excludes all PDF files.
exclusions
- A string containing a JSON list of Unix-style glob patterns to exclude. For example, "[\"**.pdf\"]"
excludes all PDF files.public void setGroupSize(String groupSize)
The target group size in bytes. The default is computed based on the input data size and the size of your
cluster. When there are fewer than 50,000 input files, "groupFiles"
must be set to
"inPartition"
for this to take effect.
groupSize
- The target group size in bytes. The default is computed based on the input data size and the size of your
cluster. When there are fewer than 50,000 input files, "groupFiles"
must be set to
"inPartition"
for this to take effect.public String getGroupSize()
The target group size in bytes. The default is computed based on the input data size and the size of your
cluster. When there are fewer than 50,000 input files, "groupFiles"
must be set to
"inPartition"
for this to take effect.
"groupFiles"
must be set to
"inPartition"
for this to take effect.public S3CsvSource withGroupSize(String groupSize)
The target group size in bytes. The default is computed based on the input data size and the size of your
cluster. When there are fewer than 50,000 input files, "groupFiles"
must be set to
"inPartition"
for this to take effect.
groupSize
- The target group size in bytes. The default is computed based on the input data size and the size of your
cluster. When there are fewer than 50,000 input files, "groupFiles"
must be set to
"inPartition"
for this to take effect.public void setGroupFiles(String groupFiles)
Grouping files is turned on by default when the input contains more than 50,000 files. To turn on grouping with
fewer than 50,000 files, set this parameter to "inPartition". To disable grouping when there are more than 50,000
files, set this parameter to "none"
.
groupFiles
- Grouping files is turned on by default when the input contains more than 50,000 files. To turn on grouping
with fewer than 50,000 files, set this parameter to "inPartition". To disable grouping when there are more
than 50,000 files, set this parameter to "none"
.public String getGroupFiles()
Grouping files is turned on by default when the input contains more than 50,000 files. To turn on grouping with
fewer than 50,000 files, set this parameter to "inPartition". To disable grouping when there are more than 50,000
files, set this parameter to "none"
.
"none"
.public S3CsvSource withGroupFiles(String groupFiles)
Grouping files is turned on by default when the input contains more than 50,000 files. To turn on grouping with
fewer than 50,000 files, set this parameter to "inPartition". To disable grouping when there are more than 50,000
files, set this parameter to "none"
.
groupFiles
- Grouping files is turned on by default when the input contains more than 50,000 files. To turn on grouping
with fewer than 50,000 files, set this parameter to "inPartition". To disable grouping when there are more
than 50,000 files, set this parameter to "none"
.public void setRecurse(Boolean recurse)
If set to true, recursively reads files in all subdirectories under the specified paths.
recurse
- If set to true, recursively reads files in all subdirectories under the specified paths.public Boolean getRecurse()
If set to true, recursively reads files in all subdirectories under the specified paths.
public S3CsvSource withRecurse(Boolean recurse)
If set to true, recursively reads files in all subdirectories under the specified paths.
recurse
- If set to true, recursively reads files in all subdirectories under the specified paths.public Boolean isRecurse()
If set to true, recursively reads files in all subdirectories under the specified paths.
public void setMaxBand(Integer maxBand)
This option controls the duration in milliseconds after which the s3 listing is likely to be consistent. Files with modification timestamps falling within the last maxBand milliseconds are tracked specially when using JobBookmarks to account for Amazon S3 eventual consistency. Most users don't need to set this option. The default is 900000 milliseconds, or 15 minutes.
maxBand
- This option controls the duration in milliseconds after which the s3 listing is likely to be consistent.
Files with modification timestamps falling within the last maxBand milliseconds are tracked specially when
using JobBookmarks to account for Amazon S3 eventual consistency. Most users don't need to set this
option. The default is 900000 milliseconds, or 15 minutes.public Integer getMaxBand()
This option controls the duration in milliseconds after which the s3 listing is likely to be consistent. Files with modification timestamps falling within the last maxBand milliseconds are tracked specially when using JobBookmarks to account for Amazon S3 eventual consistency. Most users don't need to set this option. The default is 900000 milliseconds, or 15 minutes.
public S3CsvSource withMaxBand(Integer maxBand)
This option controls the duration in milliseconds after which the s3 listing is likely to be consistent. Files with modification timestamps falling within the last maxBand milliseconds are tracked specially when using JobBookmarks to account for Amazon S3 eventual consistency. Most users don't need to set this option. The default is 900000 milliseconds, or 15 minutes.
maxBand
- This option controls the duration in milliseconds after which the s3 listing is likely to be consistent.
Files with modification timestamps falling within the last maxBand milliseconds are tracked specially when
using JobBookmarks to account for Amazon S3 eventual consistency. Most users don't need to set this
option. The default is 900000 milliseconds, or 15 minutes.public void setMaxFilesInBand(Integer maxFilesInBand)
This option specifies the maximum number of files to save from the last maxBand seconds. If this number is exceeded, extra files are skipped and only processed in the next job run.
maxFilesInBand
- This option specifies the maximum number of files to save from the last maxBand seconds. If this number is
exceeded, extra files are skipped and only processed in the next job run.public Integer getMaxFilesInBand()
This option specifies the maximum number of files to save from the last maxBand seconds. If this number is exceeded, extra files are skipped and only processed in the next job run.
public S3CsvSource withMaxFilesInBand(Integer maxFilesInBand)
This option specifies the maximum number of files to save from the last maxBand seconds. If this number is exceeded, extra files are skipped and only processed in the next job run.
maxFilesInBand
- This option specifies the maximum number of files to save from the last maxBand seconds. If this number is
exceeded, extra files are skipped and only processed in the next job run.public void setAdditionalOptions(S3DirectSourceAdditionalOptions additionalOptions)
Specifies additional connection options.
additionalOptions
- Specifies additional connection options.public S3DirectSourceAdditionalOptions getAdditionalOptions()
Specifies additional connection options.
public S3CsvSource withAdditionalOptions(S3DirectSourceAdditionalOptions additionalOptions)
Specifies additional connection options.
additionalOptions
- Specifies additional connection options.public void setSeparator(String separator)
Specifies the delimiter character. The default is a comma: ",", but any other character can be specified.
separator
- Specifies the delimiter character. The default is a comma: ",", but any other character can be specified.Separator
public String getSeparator()
Specifies the delimiter character. The default is a comma: ",", but any other character can be specified.
Separator
public S3CsvSource withSeparator(String separator)
Specifies the delimiter character. The default is a comma: ",", but any other character can be specified.
separator
- Specifies the delimiter character. The default is a comma: ",", but any other character can be specified.Separator
public S3CsvSource withSeparator(Separator separator)
Specifies the delimiter character. The default is a comma: ",", but any other character can be specified.
separator
- Specifies the delimiter character. The default is a comma: ",", but any other character can be specified.Separator
public void setEscaper(String escaper)
Specifies a character to use for escaping. This option is used only when reading CSV files. The default value is
none
. If enabled, the character which immediately follows is used as-is, except for a small set of
well-known escapes (\n
, \r
, \t
, and \0
).
escaper
- Specifies a character to use for escaping. This option is used only when reading CSV files. The default
value is none
. If enabled, the character which immediately follows is used as-is, except for
a small set of well-known escapes (\n
, \r
, \t
, and \0
).public String getEscaper()
Specifies a character to use for escaping. This option is used only when reading CSV files. The default value is
none
. If enabled, the character which immediately follows is used as-is, except for a small set of
well-known escapes (\n
, \r
, \t
, and \0
).
none
. If enabled, the character which immediately follows is used as-is, except for
a small set of well-known escapes (\n
, \r
, \t
, and \0
).public S3CsvSource withEscaper(String escaper)
Specifies a character to use for escaping. This option is used only when reading CSV files. The default value is
none
. If enabled, the character which immediately follows is used as-is, except for a small set of
well-known escapes (\n
, \r
, \t
, and \0
).
escaper
- Specifies a character to use for escaping. This option is used only when reading CSV files. The default
value is none
. If enabled, the character which immediately follows is used as-is, except for
a small set of well-known escapes (\n
, \r
, \t
, and \0
).public void setQuoteChar(String quoteChar)
Specifies the character to use for quoting. The default is a double quote: '"'
. Set this to
-1
to turn off quoting entirely.
quoteChar
- Specifies the character to use for quoting. The default is a double quote: '"'
. Set this to
-1
to turn off quoting entirely.QuoteChar
public String getQuoteChar()
Specifies the character to use for quoting. The default is a double quote: '"'
. Set this to
-1
to turn off quoting entirely.
'"'
. Set this to
-1
to turn off quoting entirely.QuoteChar
public S3CsvSource withQuoteChar(String quoteChar)
Specifies the character to use for quoting. The default is a double quote: '"'
. Set this to
-1
to turn off quoting entirely.
quoteChar
- Specifies the character to use for quoting. The default is a double quote: '"'
. Set this to
-1
to turn off quoting entirely.QuoteChar
public S3CsvSource withQuoteChar(QuoteChar quoteChar)
Specifies the character to use for quoting. The default is a double quote: '"'
. Set this to
-1
to turn off quoting entirely.
quoteChar
- Specifies the character to use for quoting. The default is a double quote: '"'
. Set this to
-1
to turn off quoting entirely.QuoteChar
public void setMultiline(Boolean multiline)
A Boolean value that specifies whether a single record can span multiple lines. This can occur when a field
contains a quoted new-line character. You must set this option to True if any record spans multiple lines. The
default value is False
, which allows for more aggressive file-splitting during parsing.
multiline
- A Boolean value that specifies whether a single record can span multiple lines. This can occur when a
field contains a quoted new-line character. You must set this option to True if any record spans multiple
lines. The default value is False
, which allows for more aggressive file-splitting during
parsing.public Boolean getMultiline()
A Boolean value that specifies whether a single record can span multiple lines. This can occur when a field
contains a quoted new-line character. You must set this option to True if any record spans multiple lines. The
default value is False
, which allows for more aggressive file-splitting during parsing.
False
, which allows for more aggressive file-splitting during
parsing.public S3CsvSource withMultiline(Boolean multiline)
A Boolean value that specifies whether a single record can span multiple lines. This can occur when a field
contains a quoted new-line character. You must set this option to True if any record spans multiple lines. The
default value is False
, which allows for more aggressive file-splitting during parsing.
multiline
- A Boolean value that specifies whether a single record can span multiple lines. This can occur when a
field contains a quoted new-line character. You must set this option to True if any record spans multiple
lines. The default value is False
, which allows for more aggressive file-splitting during
parsing.public Boolean isMultiline()
A Boolean value that specifies whether a single record can span multiple lines. This can occur when a field
contains a quoted new-line character. You must set this option to True if any record spans multiple lines. The
default value is False
, which allows for more aggressive file-splitting during parsing.
False
, which allows for more aggressive file-splitting during
parsing.public void setWithHeader(Boolean withHeader)
A Boolean value that specifies whether to treat the first line as a header. The default value is
False
.
withHeader
- A Boolean value that specifies whether to treat the first line as a header. The default value is
False
.public Boolean getWithHeader()
A Boolean value that specifies whether to treat the first line as a header. The default value is
False
.
False
.public S3CsvSource withWithHeader(Boolean withHeader)
A Boolean value that specifies whether to treat the first line as a header. The default value is
False
.
withHeader
- A Boolean value that specifies whether to treat the first line as a header. The default value is
False
.public Boolean isWithHeader()
A Boolean value that specifies whether to treat the first line as a header. The default value is
False
.
False
.public void setWriteHeader(Boolean writeHeader)
A Boolean value that specifies whether to write the header to output. The default value is True
.
writeHeader
- A Boolean value that specifies whether to write the header to output. The default value is
True
.public Boolean getWriteHeader()
A Boolean value that specifies whether to write the header to output. The default value is True
.
True
.public S3CsvSource withWriteHeader(Boolean writeHeader)
A Boolean value that specifies whether to write the header to output. The default value is True
.
writeHeader
- A Boolean value that specifies whether to write the header to output. The default value is
True
.public Boolean isWriteHeader()
A Boolean value that specifies whether to write the header to output. The default value is True
.
True
.public void setSkipFirst(Boolean skipFirst)
A Boolean value that specifies whether to skip the first data line. The default value is False
.
skipFirst
- A Boolean value that specifies whether to skip the first data line. The default value is
False
.public Boolean getSkipFirst()
A Boolean value that specifies whether to skip the first data line. The default value is False
.
False
.public S3CsvSource withSkipFirst(Boolean skipFirst)
A Boolean value that specifies whether to skip the first data line. The default value is False
.
skipFirst
- A Boolean value that specifies whether to skip the first data line. The default value is
False
.public Boolean isSkipFirst()
A Boolean value that specifies whether to skip the first data line. The default value is False
.
False
.public void setOptimizePerformance(Boolean optimizePerformance)
A Boolean value that specifies whether to use the advanced SIMD CSV reader along with Apache Arrow based columnar memory formats. Only available in Glue version 3.0.
optimizePerformance
- A Boolean value that specifies whether to use the advanced SIMD CSV reader along with Apache Arrow based
columnar memory formats. Only available in Glue version 3.0.public Boolean getOptimizePerformance()
A Boolean value that specifies whether to use the advanced SIMD CSV reader along with Apache Arrow based columnar memory formats. Only available in Glue version 3.0.
public S3CsvSource withOptimizePerformance(Boolean optimizePerformance)
A Boolean value that specifies whether to use the advanced SIMD CSV reader along with Apache Arrow based columnar memory formats. Only available in Glue version 3.0.
optimizePerformance
- A Boolean value that specifies whether to use the advanced SIMD CSV reader along with Apache Arrow based
columnar memory formats. Only available in Glue version 3.0.public Boolean isOptimizePerformance()
A Boolean value that specifies whether to use the advanced SIMD CSV reader along with Apache Arrow based columnar memory formats. Only available in Glue version 3.0.
public List<GlueSchema> getOutputSchemas()
Specifies the data schema for the S3 CSV source.
public void setOutputSchemas(Collection<GlueSchema> outputSchemas)
Specifies the data schema for the S3 CSV source.
outputSchemas
- Specifies the data schema for the S3 CSV source.public S3CsvSource withOutputSchemas(GlueSchema... outputSchemas)
Specifies the data schema for the S3 CSV 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 S3 CSV source.public S3CsvSource withOutputSchemas(Collection<GlueSchema> outputSchemas)
Specifies the data schema for the S3 CSV source.
outputSchemas
- Specifies the data schema for the S3 CSV source.public String toString()
toString
in class Object
Object.toString()
public S3CsvSource clone()
public void marshall(ProtocolMarshaller protocolMarshaller)
StructuredPojo
ProtocolMarshaller
.marshall
in interface StructuredPojo
protocolMarshaller
- Implementation of ProtocolMarshaller
used to marshall this object's data.