org.apache.streams.example

Class ElasticsearchReindexConfiguration

java.lang.Object

org.apache.streams.config.StreamsConfiguration

org.apache.streams.local.LocalRuntimeConfiguration

org.apache.streams.example.ElasticsearchReindexConfiguration

All Implemented Interfaces:

Serializable

@Generated(value="org.jsonschema2pojo")
public class ElasticsearchReindexConfiguration
extends LocalRuntimeConfiguration
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ElasticsearchReindexConfiguration()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object other)
ElasticsearchWriterConfiguration	getDestination() (Required)
ElasticsearchReaderConfiguration	getSource() (Required)
int	hashCode()
void	setDestination(ElasticsearchWriterConfiguration destination) (Required)
void	setSource(ElasticsearchReaderConfiguration source) (Required)
String	toString()
ElasticsearchReindexConfiguration	withDestination(ElasticsearchWriterConfiguration destination)
ElasticsearchReindexConfiguration	withSource(ElasticsearchReaderConfiguration source)

Methods inherited from class org.apache.streams.local.LocalRuntimeConfiguration

getExecutorShutdownPauseMs, getExecutorShutdownWaitMs, getMaxQueueCapacity, getMonitorShutdownPauseMs, getMonitorShutdownWaitMs, getShutdownPauseMs, getTaskTimeoutMs, setExecutorShutdownPauseMs, setExecutorShutdownWaitMs, setMaxQueueCapacity, setMonitorShutdownPauseMs, setMonitorShutdownWaitMs, setShutdownPauseMs, setTaskTimeoutMs, withExecutorShutdownPauseMs, withExecutorShutdownWaitMs, withMaxQueueCapacity, withMonitorShutdownPauseMs, withMonitorShutdownWaitMs, withShutdownPauseMs, withTaskTimeoutMs

Methods inherited from class org.apache.streams.config.StreamsConfiguration

getBatchFrequencyMs, getBatchSize, getIdentifier, getParallelism, getProviderTimeoutMs, getProviderWaitMs, getQueueSize, getShutdownCheckDelay, getShutdownCheckInterval, getStartedAt, setBatchFrequencyMs, setBatchSize, setIdentifier, setParallelism, setProviderTimeoutMs, setProviderWaitMs, setQueueSize, setShutdownCheckDelay, setShutdownCheckInterval, setStartedAt, withBatchFrequencyMs, withBatchSize, withIdentifier, withParallelism, withProviderTimeoutMs, withProviderWaitMs, withQueueSize, withShutdownCheckDelay, withShutdownCheckInterval, withStartedAt

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ElasticsearchReindexConfiguration

public ElasticsearchReindexConfiguration()

Method Detail

getSource

@BeanProperty(value="source")
public ElasticsearchReaderConfiguration getSource()

(Required)

Returns:

The source

setSource

@BeanProperty(value="source")
public void setSource(ElasticsearchReaderConfiguration source)

(Required)

Parameters:

source - The source

withSource

public ElasticsearchReindexConfiguration withSource(ElasticsearchReaderConfiguration source)

getDestination

@BeanProperty(value="destination")
public ElasticsearchWriterConfiguration getDestination()

(Required)

Returns:

The destination

setDestination

@BeanProperty(value="destination")
public void setDestination(ElasticsearchWriterConfiguration destination)

(Required)

Parameters:

destination - The destination

withDestination

public ElasticsearchReindexConfiguration withDestination(ElasticsearchWriterConfiguration destination)

toString

public String toString()

Overrides:

toString in class LocalRuntimeConfiguration

hashCode

public int hashCode()

Overrides:

hashCode in class LocalRuntimeConfiguration

equals

public boolean equals(Object other)

Overrides:

equals in class LocalRuntimeConfiguration