CatalogKafkaSource (AWS SDK for Java

java.lang.Object
- com.amazonaws.services.glue.model.CatalogKafkaSource

All Implemented Interfaces:

StructuredPojo, Serializable, Cloneable
```
@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.

See Also:

AWS API Documentation, Serialized Form

Constructor Summary

Constructors
Constructor and Description

CatalogKafkaSource()

Constructors
Constructor and Description
`CatalogKafkaSource()`

Method Summary

All Methods Instance Methods Concrete Methods
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.

Methods inherited from class java.lang.Object
getClass, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - CatalogKafkaSource
```
public CatalogKafkaSource()
```
- Method Detail
  - setName
```
public void setName(String name)
```
    The name of the data store.
    
    Parameters:
    
    name - The name of the data store.
  - getName
```
public String getName()
```
    The name of the data store.
    
    Returns:
    
    The name of the data store.
  - withName
```
public CatalogKafkaSource withName(String name)
```
    The name of the data store.
    
    Parameters:
    
    name - The name of the data store.
    
    Returns:
    
    Returns a reference to this object so that method calls can be chained together.
  - setWindowSize
```
public void setWindowSize(Integer windowSize)
```
    The amount of time to spend processing each micro batch.
    
    Parameters:
    
    windowSize - The amount of time to spend processing each micro batch.
  - getWindowSize
```
public Integer getWindowSize()
```
    The amount of time to spend processing each micro batch.
    
    Returns:
    
    The amount of time to spend processing each micro batch.
  - withWindowSize
```
public CatalogKafkaSource withWindowSize(Integer windowSize)
```
    The amount of time to spend processing each micro batch.
    
    Parameters:
    
    windowSize - The amount of time to spend processing each micro batch.
    
    Returns:
    
    Returns a reference to this object so that method calls can be chained together.
  - setDetectSchema
```
public void setDetectSchema(Boolean detectSchema)
```
    Whether to automatically determine the schema from the incoming data.
    
    Parameters:
    
    detectSchema - Whether to automatically determine the schema from the incoming data.
  - getDetectSchema
```
public Boolean getDetectSchema()
```
    Whether to automatically determine the schema from the incoming data.
    
    Returns:
    
    Whether to automatically determine the schema from the incoming data.
  - withDetectSchema
```
public CatalogKafkaSource withDetectSchema(Boolean detectSchema)
```
    Whether to automatically determine the schema from the incoming data.
    
    Parameters:
    
    detectSchema - Whether to automatically determine the schema from the incoming data.
    
    Returns:
    
    Returns a reference to this object so that method calls can be chained together.
  - isDetectSchema
```
public Boolean isDetectSchema()
```
    Whether to automatically determine the schema from the incoming data.
    
    Returns:
    
    Whether to automatically determine the schema from the incoming data.
  - setTable
```
public void setTable(String table)
```
    The name of the table in the database to read from.
    
    Parameters:
    
    table - The name of the table in the database to read from.
  - getTable
```
public String getTable()
```
    The name of the table in the database to read from.
    
    Returns:
    
    The name of the table in the database to read from.
  - withTable
```
public CatalogKafkaSource withTable(String table)
```
    The name of the table in the database to read from.
    
    Parameters:
    
    table - The name of the table in the database to read from.
    
    Returns:
    
    Returns a reference to this object so that method calls can be chained together.
  - setDatabase
```
public void setDatabase(String database)
```
    The name of the database to read from.
    
    Parameters:
    
    database - The name of the database to read from.
  - getDatabase
```
public String getDatabase()
```
    The name of the database to read from.
    
    Returns:
    
    The name of the database to read from.
  - withDatabase
```
public CatalogKafkaSource withDatabase(String database)
```
    The name of the database to read from.
    
    Parameters:
    
    database - The name of the database to read from.
    
    Returns:
    
    Returns a reference to this object so that method calls can be chained together.
  - setStreamingOptions
```
public void setStreamingOptions(KafkaStreamingSourceOptions streamingOptions)
```
    Specifies the streaming options.
    
    Parameters:
    
    streamingOptions - Specifies the streaming options.
  - getStreamingOptions
```
public KafkaStreamingSourceOptions getStreamingOptions()
```
    Specifies the streaming options.
    
    Returns:
    
    Specifies the streaming options.
  - withStreamingOptions
```
public CatalogKafkaSource withStreamingOptions(KafkaStreamingSourceOptions streamingOptions)
```
    Specifies the streaming options.
    
    Parameters:
    
    streamingOptions - Specifies the streaming options.
    
    Returns:
    
    Returns a reference to this object so that method calls can be chained together.
  - setDataPreviewOptions
```
public void setDataPreviewOptions(StreamingDataPreviewOptions dataPreviewOptions)
```
    Specifies options related to data preview for viewing a sample of your data.
    
    Parameters:
    
    dataPreviewOptions - Specifies options related to data preview for viewing a sample of your data.
  - getDataPreviewOptions
```
public StreamingDataPreviewOptions getDataPreviewOptions()
```
    Specifies options related to data preview for viewing a sample of your data.
    
    Returns:
    
    Specifies options related to data preview for viewing a sample of your data.
  - withDataPreviewOptions
```
public CatalogKafkaSource withDataPreviewOptions(StreamingDataPreviewOptions dataPreviewOptions)
```
    Specifies options related to data preview for viewing a sample of your data.
    
    Parameters:
    
    dataPreviewOptions - Specifies options related to data preview for viewing a sample of your data.
    
    Returns:
    
    Returns a reference to this object so that method calls can be chained together.
  - toString
```
public String toString()
```
    Returns a string representation of this object. This is useful for testing and debugging. Sensitive data will be redacted from this string using a placeholder value.
    
    Overrides:
    
    toString in class Object
    
    Returns:
    
    A string representation of this object.
    
    See Also:
    
    Object.toString()
  - equals
```
public boolean equals(Object obj)
```
    Overrides:
    
    equals in class Object
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class Object
  - clone
```
public CatalogKafkaSource clone()
```
    Overrides:
    
    clone in class Object
  - marshall
```
public void marshall(ProtocolMarshaller protocolMarshaller)
```
    Description copied from interface: StructuredPojo
    
    Marshalls this structured data using the given ProtocolMarshaller.
    
    Specified by:
    
    marshall in interface StructuredPojo
    
    Parameters:
    
    protocolMarshaller - Implementation of ProtocolMarshaller used to marshall this object's data.

AWS SDK for Java 1.x API Reference - 1.12.773

Class CatalogKafkaSource

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

CatalogKafkaSource

Method Detail

setName

getName

withName

setWindowSize

getWindowSize

withWindowSize

setDetectSchema

getDetectSchema

withDetectSchema

isDetectSchema

setTable

getTable

withTable

setDatabase

getDatabase

withDatabase

setStreamingOptions

getStreamingOptions

withStreamingOptions

setDataPreviewOptions

getDataPreviewOptions

withDataPreviewOptions

toString

equals

hashCode

clone

marshall