DirectKafkaSource (AWS SDK for Java

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

All Implemented Interfaces:: StructuredPojo, Serializable, Cloneable

@Generated(value="com.amazonaws:aws-java-sdk-code-generator")
public class DirectKafkaSource
extends Object
implements Serializable, Cloneable, StructuredPojo

Specifies an Apache Kafka data store.

See Also:: AWS API Documentation, Serialized Form

Constructor Summary

Constructors
Constructor and Description

DirectKafkaSource()

Constructors
Constructor and Description
`DirectKafkaSource()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`DirectKafkaSource`	`clone()`
`boolean`	`equals(Object obj)`
`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.
`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`	`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`	`setWindowSize(Integer windowSize)` The amount of time to spend processing each micro batch.
`String`	`toString()` Returns a string representation of this object.
`DirectKafkaSource`	`withDataPreviewOptions(StreamingDataPreviewOptions dataPreviewOptions)` Specifies options related to data preview for viewing a sample of your data.
`DirectKafkaSource`	`withDetectSchema(Boolean detectSchema)` Whether to automatically determine the schema from the incoming data.
`DirectKafkaSource`	`withName(String name)` The name of the data store.
`DirectKafkaSource`	`withStreamingOptions(KafkaStreamingSourceOptions streamingOptions)` Specifies the streaming options.
`DirectKafkaSource`	`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
  - DirectKafkaSource
```
public DirectKafkaSource()
```
- 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 DirectKafkaSource 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.
  - 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 DirectKafkaSource 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.
  - 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 DirectKafkaSource 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 DirectKafkaSource 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.
  - 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 DirectKafkaSource 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 DirectKafkaSource 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.780

Class DirectKafkaSource

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

DirectKafkaSource

Method Detail

setName

getName

withName

setStreamingOptions

getStreamingOptions

withStreamingOptions

setWindowSize

getWindowSize

withWindowSize

setDetectSchema

getDetectSchema

withDetectSchema

isDetectSchema

setDataPreviewOptions

getDataPreviewOptions

withDataPreviewOptions

toString

equals

hashCode

clone

marshall