@Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class CatalogKinesisSource extends Object implements Serializable, Cloneable, StructuredPojo
Specifies a Kinesis data source in the Glue Data Catalog.
Constructor and Description |
---|
CatalogKinesisSource() |
Modifier and Type | Method and Description |
---|---|
CatalogKinesisSource |
clone() |
boolean |
equals(Object obj) |
String |
getDatabase()
The name of the database to read from.
|
StreamingDataPreviewOptions |
getDataPreviewOptions()
Additional options for data preview.
|
Boolean |
getDetectSchema()
Whether to automatically determine the schema from the incoming data.
|
String |
getName()
The name of the data source.
|
KinesisStreamingSourceOptions |
getStreamingOptions()
Additional options for the Kinesis streaming data source.
|
String |
getTable()
The name of the table in the database to read from.
|
Integer |
getWindowSize()
The amount of time to spend processing each micro batch.
|
int |
hashCode() |
Boolean |
isDetectSchema()
Whether to automatically determine the schema from the incoming data.
|
void |
marshall(ProtocolMarshaller protocolMarshaller)
Marshalls this structured data using the given
ProtocolMarshaller . |
void |
setDatabase(String database)
The name of the database to read from.
|
void |
setDataPreviewOptions(StreamingDataPreviewOptions dataPreviewOptions)
Additional options for data preview.
|
void |
setDetectSchema(Boolean detectSchema)
Whether to automatically determine the schema from the incoming data.
|
void |
setName(String name)
The name of the data source.
|
void |
setStreamingOptions(KinesisStreamingSourceOptions streamingOptions)
Additional options for the Kinesis streaming data source.
|
void |
setTable(String table)
The name of the table in the database to read from.
|
void |
setWindowSize(Integer windowSize)
The amount of time to spend processing each micro batch.
|
String |
toString()
Returns a string representation of this object.
|
CatalogKinesisSource |
withDatabase(String database)
The name of the database to read from.
|
CatalogKinesisSource |
withDataPreviewOptions(StreamingDataPreviewOptions dataPreviewOptions)
Additional options for data preview.
|
CatalogKinesisSource |
withDetectSchema(Boolean detectSchema)
Whether to automatically determine the schema from the incoming data.
|
CatalogKinesisSource |
withName(String name)
The name of the data source.
|
CatalogKinesisSource |
withStreamingOptions(KinesisStreamingSourceOptions streamingOptions)
Additional options for the Kinesis streaming data source.
|
CatalogKinesisSource |
withTable(String table)
The name of the table in the database to read from.
|
CatalogKinesisSource |
withWindowSize(Integer windowSize)
The amount of time to spend processing each micro batch.
|
public void setName(String name)
The name of the data source.
name
- The name of the data source.public String getName()
The name of the data source.
public CatalogKinesisSource withName(String name)
The name of the data source.
name
- The name of the data source.public void setWindowSize(Integer windowSize)
The amount of time to spend processing each micro batch.
windowSize
- The amount of time to spend processing each micro batch.public Integer getWindowSize()
The amount of time to spend processing each micro batch.
public CatalogKinesisSource withWindowSize(Integer windowSize)
The amount of time to spend processing each micro batch.
windowSize
- The amount of time to spend processing each micro batch.public void setDetectSchema(Boolean detectSchema)
Whether to automatically determine the schema from the incoming data.
detectSchema
- Whether to automatically determine the schema from the incoming data.public Boolean getDetectSchema()
Whether to automatically determine the schema from the incoming data.
public CatalogKinesisSource withDetectSchema(Boolean detectSchema)
Whether to automatically determine the schema from the incoming data.
detectSchema
- Whether to automatically determine the schema from the incoming data.public Boolean isDetectSchema()
Whether to automatically determine the schema from the incoming data.
public void setTable(String table)
The name of the table in the database to read from.
table
- The name of the table in the database to read from.public String getTable()
The name of the table in the database to read from.
public CatalogKinesisSource withTable(String table)
The name of the table in the database to read from.
table
- The name of the table in the database to read from.public void setDatabase(String database)
The name of the database to read from.
database
- The name of the database to read from.public String getDatabase()
The name of the database to read from.
public CatalogKinesisSource withDatabase(String database)
The name of the database to read from.
database
- The name of the database to read from.public void setStreamingOptions(KinesisStreamingSourceOptions streamingOptions)
Additional options for the Kinesis streaming data source.
streamingOptions
- Additional options for the Kinesis streaming data source.public KinesisStreamingSourceOptions getStreamingOptions()
Additional options for the Kinesis streaming data source.
public CatalogKinesisSource withStreamingOptions(KinesisStreamingSourceOptions streamingOptions)
Additional options for the Kinesis streaming data source.
streamingOptions
- Additional options for the Kinesis streaming data source.public void setDataPreviewOptions(StreamingDataPreviewOptions dataPreviewOptions)
Additional options for data preview.
dataPreviewOptions
- Additional options for data preview.public StreamingDataPreviewOptions getDataPreviewOptions()
Additional options for data preview.
public CatalogKinesisSource withDataPreviewOptions(StreamingDataPreviewOptions dataPreviewOptions)
Additional options for data preview.
dataPreviewOptions
- Additional options for data preview.public String toString()
toString
in class Object
Object.toString()
public CatalogKinesisSource clone()
public void marshall(ProtocolMarshaller protocolMarshaller)
StructuredPojo
ProtocolMarshaller
.marshall
in interface StructuredPojo
protocolMarshaller
- Implementation of ProtocolMarshaller
used to marshall this object's data.