org.apache.streams.examples.flink.twitter

Class TwitterSpritzerPipelineConfiguration

java.lang.Object

org.apache.streams.config.StreamsConfiguration

org.apache.streams.flink.StreamsFlinkConfiguration

org.apache.streams.flink.FlinkStreamingConfiguration

org.apache.streams.examples.flink.twitter.TwitterSpritzerPipelineConfiguration

All Implemented Interfaces:

Serializable

@Generated(value="org.jsonschema2pojo")
public class TwitterSpritzerPipelineConfiguration
extends FlinkStreamingConfiguration
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TwitterSpritzerPipelineConfiguration()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object other)
Map<String,Object>	getAdditionalProperties()
org.apache.streams.hdfs.HdfsWriterConfiguration	getDestination()
Long	getProviderWaitMs()
org.apache.streams.hdfs.HdfsReaderConfiguration	getSource()
org.apache.streams.twitter.TwitterStreamConfiguration	getTwitter()
int	hashCode()
void	setAdditionalProperty(String name, Object value)
void	setDestination(org.apache.streams.hdfs.HdfsWriterConfiguration destination)
void	setProviderWaitMs(Long providerWaitMs)
void	setSource(org.apache.streams.hdfs.HdfsReaderConfiguration source)
void	setTwitter(org.apache.streams.twitter.TwitterStreamConfiguration twitter)
String	toString()
TwitterSpritzerPipelineConfiguration	withAdditionalProperty(String name, Object value)
TwitterSpritzerPipelineConfiguration	withDestination(org.apache.streams.hdfs.HdfsWriterConfiguration destination)
TwitterSpritzerPipelineConfiguration	withProviderWaitMs(Long providerWaitMs)
TwitterSpritzerPipelineConfiguration	withSource(org.apache.streams.hdfs.HdfsReaderConfiguration source)
TwitterSpritzerPipelineConfiguration	withTwitter(org.apache.streams.twitter.TwitterStreamConfiguration twitter)

Methods inherited from class org.apache.streams.flink.FlinkStreamingConfiguration

getCheckpointIntervalMs, getCheckpointTimeoutMs, getParallel, getRestartAttempts, getRestartDelayMs, setCheckpointIntervalMs, setCheckpointTimeoutMs, setParallel, setRestartAttempts, setRestartDelayMs, withCheckpointIntervalMs, withCheckpointTimeoutMs, withParallel, withRestartAttempts, withRestartDelayMs

Methods inherited from class org.apache.streams.flink.StreamsFlinkConfiguration

getLocal, getTest, setLocal, setTest, withLocal, withTest

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

TwitterSpritzerPipelineConfiguration

public TwitterSpritzerPipelineConfiguration()

Method Detail

getTwitter

@BeanProperty(value="twitter")
public org.apache.streams.twitter.TwitterStreamConfiguration getTwitter()

Returns:

The twitter

setTwitter

@BeanProperty(value="twitter")
public void setTwitter(org.apache.streams.twitter.TwitterStreamConfiguration twitter)

Parameters:

twitter - The twitter

withTwitter

public TwitterSpritzerPipelineConfiguration withTwitter(org.apache.streams.twitter.TwitterStreamConfiguration twitter)

getSource

@BeanProperty(value="source")
public org.apache.streams.hdfs.HdfsReaderConfiguration getSource()

Returns:

The source

setSource

@BeanProperty(value="source")
public void setSource(org.apache.streams.hdfs.HdfsReaderConfiguration source)

Parameters:

source - The source

withSource

public TwitterSpritzerPipelineConfiguration withSource(org.apache.streams.hdfs.HdfsReaderConfiguration source)

getDestination

@BeanProperty(value="destination")
public org.apache.streams.hdfs.HdfsWriterConfiguration getDestination()

Returns:

The destination

setDestination

@BeanProperty(value="destination")
public void setDestination(org.apache.streams.hdfs.HdfsWriterConfiguration destination)

Parameters:

destination - The destination

withDestination

public TwitterSpritzerPipelineConfiguration withDestination(org.apache.streams.hdfs.HdfsWriterConfiguration destination)

getProviderWaitMs

@BeanProperty(value="providerWaitMs")
public Long getProviderWaitMs()

Overrides:

getProviderWaitMs in class FlinkStreamingConfiguration

Returns:

The providerWaitMs

setProviderWaitMs

@BeanProperty(value="providerWaitMs")
public void setProviderWaitMs(Long providerWaitMs)

Overrides:

setProviderWaitMs in class FlinkStreamingConfiguration

Parameters:

providerWaitMs - The providerWaitMs

withProviderWaitMs

public TwitterSpritzerPipelineConfiguration withProviderWaitMs(Long providerWaitMs)

Overrides:

withProviderWaitMs in class FlinkStreamingConfiguration

toString

public String toString()

Overrides:

toString in class FlinkStreamingConfiguration

getAdditionalProperties

@BeanProperty(name="*")
public Map<String,Object> getAdditionalProperties()

Overrides:

getAdditionalProperties in class FlinkStreamingConfiguration

setAdditionalProperty

@BeanProperty(name="*")
public void setAdditionalProperty(String name,
                                                          Object value)

Overrides:

setAdditionalProperty in class FlinkStreamingConfiguration

withAdditionalProperty

public TwitterSpritzerPipelineConfiguration withAdditionalProperty(String name,
                                                                   Object value)

Overrides:

withAdditionalProperty in class FlinkStreamingConfiguration

hashCode

public int hashCode()

Overrides:

hashCode in class FlinkStreamingConfiguration

equals

public boolean equals(Object other)

Overrides:

equals in class FlinkStreamingConfiguration