org.apache.streams.example

Class TwitterUserstreamElasticsearchConfiguration

java.lang.Object

org.apache.streams.config.StreamsConfiguration

org.apache.streams.local.LocalRuntimeConfiguration

org.apache.streams.example.TwitterUserstreamElasticsearchConfiguration

All Implemented Interfaces:

Serializable

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TwitterUserstreamElasticsearchConfiguration()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object other)
ElasticsearchWriterConfiguration	getElasticsearch() (Required)
TwitterStreamConfiguration	getTwitter() (Required)
int	hashCode()
void	setElasticsearch(ElasticsearchWriterConfiguration elasticsearch) (Required)
void	setTwitter(TwitterStreamConfiguration twitter) (Required)
String	toString()
TwitterUserstreamElasticsearchConfiguration	withElasticsearch(ElasticsearchWriterConfiguration elasticsearch)
TwitterUserstreamElasticsearchConfiguration	withTwitter(TwitterStreamConfiguration 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

TwitterUserstreamElasticsearchConfiguration

public TwitterUserstreamElasticsearchConfiguration()

Method Detail

getTwitter

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

(Required)

Returns:

The twitter

setTwitter

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

(Required)

Parameters:

twitter - The twitter

withTwitter

public TwitterUserstreamElasticsearchConfiguration withTwitter(TwitterStreamConfiguration 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 TwitterUserstreamElasticsearchConfiguration 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