org.apache.streams.examples.flink.twitter

Class TwitterPostsPipelineConfiguration

java.lang.Object

org.apache.streams.config.StreamsConfiguration

org.apache.streams.flink.StreamsFlinkConfiguration

org.apache.streams.flink.FlinkStreamingConfiguration

org.apache.streams.examples.flink.twitter.TwitterPostsPipelineConfiguration

All Implemented Interfaces:

Serializable

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TwitterPostsPipelineConfiguration()

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.TwitterTimelineProviderConfiguration	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.TwitterTimelineProviderConfiguration twitter)
String	toString()
TwitterPostsPipelineConfiguration	withAdditionalProperty(String name, Object value)
TwitterPostsPipelineConfiguration	withDestination(org.apache.streams.hdfs.HdfsWriterConfiguration destination)
TwitterPostsPipelineConfiguration	withProviderWaitMs(Long providerWaitMs)
TwitterPostsPipelineConfiguration	withSource(org.apache.streams.hdfs.HdfsReaderConfiguration source)
TwitterPostsPipelineConfiguration	withTwitter(org.apache.streams.twitter.TwitterTimelineProviderConfiguration 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

TwitterPostsPipelineConfiguration

public TwitterPostsPipelineConfiguration()

Method Detail

getTwitter

public org.apache.streams.twitter.TwitterTimelineProviderConfiguration getTwitter()

Returns:

The twitter

setTwitter

public void setTwitter(org.apache.streams.twitter.TwitterTimelineProviderConfiguration twitter)

Parameters:

twitter - The twitter

withTwitter

public TwitterPostsPipelineConfiguration withTwitter(org.apache.streams.twitter.TwitterTimelineProviderConfiguration twitter)

getSource

public org.apache.streams.hdfs.HdfsReaderConfiguration getSource()

Returns:

The source

setSource

public void setSource(org.apache.streams.hdfs.HdfsReaderConfiguration source)

Parameters:

source - The source

withSource

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

getDestination

public org.apache.streams.hdfs.HdfsWriterConfiguration getDestination()

Returns:

The destination

setDestination

public void setDestination(org.apache.streams.hdfs.HdfsWriterConfiguration destination)

Parameters:

destination - The destination

withDestination

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

getProviderWaitMs

public Long getProviderWaitMs()

Overrides:

getProviderWaitMs in class FlinkStreamingConfiguration

Returns:

The providerWaitMs

setProviderWaitMs

public void setProviderWaitMs(Long providerWaitMs)

Overrides:

setProviderWaitMs in class FlinkStreamingConfiguration

Parameters:

providerWaitMs - The providerWaitMs

withProviderWaitMs

public TwitterPostsPipelineConfiguration withProviderWaitMs(Long providerWaitMs)

Overrides:

withProviderWaitMs in class FlinkStreamingConfiguration

toString

public String toString()

Overrides:

toString in class FlinkStreamingConfiguration

getAdditionalProperties

public Map<String,Object> getAdditionalProperties()

Overrides:

getAdditionalProperties in class FlinkStreamingConfiguration

setAdditionalProperty

public void setAdditionalProperty(String name,
                                  Object value)

Overrides:

setAdditionalProperty in class FlinkStreamingConfiguration

withAdditionalProperty

public TwitterPostsPipelineConfiguration 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