org.apache.streams.example

Class TwitterHistoryElasticsearchConfiguration

java.lang.Object

org.apache.streams.config.StreamsConfiguration

org.apache.streams.local.LocalRuntimeConfiguration

org.apache.streams.example.TwitterHistoryElasticsearchConfiguration

All Implemented Interfaces:

Serializable

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TwitterHistoryElasticsearchConfiguration()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object other)
ElasticsearchWriterConfiguration	getElasticsearch() (Required)
TwitterTimelineProviderConfiguration	getTwitter() (Required)
int	hashCode()
void	setElasticsearch(ElasticsearchWriterConfiguration elasticsearch) (Required)
void	setTwitter(TwitterTimelineProviderConfiguration twitter) (Required)
String	toString()
TwitterHistoryElasticsearchConfiguration	withElasticsearch(ElasticsearchWriterConfiguration elasticsearch)
TwitterHistoryElasticsearchConfiguration	withTwitter(TwitterTimelineProviderConfiguration twitter)

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

TwitterHistoryElasticsearchConfiguration

public TwitterHistoryElasticsearchConfiguration()

Method Detail

getTwitter

@BeanProperty(value="twitter")
public TwitterTimelineProviderConfiguration getTwitter()

(Required)

Returns:

The twitter

setTwitter

@BeanProperty(value="twitter")
public void setTwitter(TwitterTimelineProviderConfiguration twitter)

(Required)

Parameters:

twitter - The twitter

withTwitter

public TwitterHistoryElasticsearchConfiguration withTwitter(TwitterTimelineProviderConfiguration twitter)

getElasticsearch

@BeanProperty(value="elasticsearch")
public ElasticsearchWriterConfiguration getElasticsearch()

(Required)

Returns:

The elasticsearch

setElasticsearch

@BeanProperty(value="elasticsearch")
public void setElasticsearch(ElasticsearchWriterConfiguration elasticsearch)

(Required)

Parameters:

elasticsearch - The elasticsearch

withElasticsearch

public TwitterHistoryElasticsearchConfiguration withElasticsearch(ElasticsearchWriterConfiguration elasticsearch)

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