@Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class CatalogKafkaSource extends Object implements Serializable, Cloneable, StructuredPojo
Specifies an Apache Kafka data store in the Data Catalog.
Constructor and Description |
---|
CatalogKafkaSource() |
Modifier and Type | Method and Description |
---|---|
CatalogKafkaSource |
clone() |
boolean |
equals(Object obj) |
String |
getDatabase()
The name of the database to read from.
|
StreamingDataPreviewOptions |
getDataPreviewOptions()
Specifies options related to data preview for viewing a sample of your data.
|
Boolean |
getDetectSchema()
Whether to automatically determine the schema from the incoming data.
|
String |
getName()
The name of the data store.
|
KafkaStreamingSourceOptions |
getStreamingOptions()
Specifies the streaming options.
|
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)
Specifies options related to data preview for viewing a sample of your data.
|
void |
setDetectSchema(Boolean detectSchema)
Whether to automatically determine the schema from the incoming data.
|
void |
setName(String name)
The name of the data store.
|
void |
setStreamingOptions(KafkaStreamingSourceOptions streamingOptions)
Specifies the streaming options.
|
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.
|
CatalogKafkaSource |
withDatabase(String database)
The name of the database to read from.
|
CatalogKafkaSource |
withDataPreviewOptions(StreamingDataPreviewOptions dataPreviewOptions)
Specifies options related to data preview for viewing a sample of your data.
|
CatalogKafkaSource |
withDetectSchema(Boolean detectSchema)
Whether to automatically determine the schema from the incoming data.
|
CatalogKafkaSource |
withName(String name)
The name of the data store.
|
CatalogKafkaSource |
withStreamingOptions(KafkaStreamingSourceOptions streamingOptions)
Specifies the streaming options.
|
CatalogKafkaSource |
withTable(String table)
The name of the table in the database to read from.
|
CatalogKafkaSource |
withWindowSize(Integer windowSize)
The amount of time to spend processing each micro batch.
|
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 CatalogKafkaSource withName(String name)
The name of the data store.
name
- The name of the data store.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 CatalogKafkaSource 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 CatalogKafkaSource 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 CatalogKafkaSource 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 CatalogKafkaSource withDatabase(String database)
The name of the database to read from.
database
- The name of the database to read from.public void setStreamingOptions(KafkaStreamingSourceOptions streamingOptions)
Specifies the streaming options.
streamingOptions
- Specifies the streaming options.public KafkaStreamingSourceOptions getStreamingOptions()
Specifies the streaming options.
public CatalogKafkaSource withStreamingOptions(KafkaStreamingSourceOptions streamingOptions)
Specifies the streaming options.
streamingOptions
- Specifies the streaming options.public void setDataPreviewOptions(StreamingDataPreviewOptions dataPreviewOptions)
Specifies options related to data preview for viewing a sample of your data.
dataPreviewOptions
- Specifies options related to data preview for viewing a sample of your data.public StreamingDataPreviewOptions getDataPreviewOptions()
Specifies options related to data preview for viewing a sample of your data.
public CatalogKafkaSource withDataPreviewOptions(StreamingDataPreviewOptions dataPreviewOptions)
Specifies options related to data preview for viewing a sample of your data.
dataPreviewOptions
- Specifies options related to data preview for viewing a sample of your data.public String toString()
toString
in class Object
Object.toString()
public CatalogKafkaSource clone()
public void marshall(ProtocolMarshaller protocolMarshaller)
StructuredPojo
ProtocolMarshaller
.marshall
in interface StructuredPojo
protocolMarshaller
- Implementation of ProtocolMarshaller
used to marshall this object's data.