@Generated(value="org.jsonschema2pojo") public class TwitterPostsPipelineConfiguration extends FlinkStreamingConfiguration implements Serializable
Constructor and Description |
---|
TwitterPostsPipelineConfiguration() |
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) |
getCheckpointIntervalMs, getCheckpointTimeoutMs, getParallel, getRestartAttempts, getRestartDelayMs, setCheckpointIntervalMs, setCheckpointTimeoutMs, setParallel, setRestartAttempts, setRestartDelayMs, withCheckpointIntervalMs, withCheckpointTimeoutMs, withParallel, withRestartAttempts, withRestartDelayMs
getLocal, getTest, setLocal, setTest, withLocal, withTest
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
@BeanProperty(value="twitter") public org.apache.streams.twitter.TwitterTimelineProviderConfiguration getTwitter()
@BeanProperty(value="twitter") public void setTwitter(org.apache.streams.twitter.TwitterTimelineProviderConfiguration twitter)
twitter
- The twitterpublic TwitterPostsPipelineConfiguration withTwitter(org.apache.streams.twitter.TwitterTimelineProviderConfiguration twitter)
@BeanProperty(value="source") public org.apache.streams.hdfs.HdfsReaderConfiguration getSource()
@BeanProperty(value="source") public void setSource(org.apache.streams.hdfs.HdfsReaderConfiguration source)
source
- The sourcepublic TwitterPostsPipelineConfiguration withSource(org.apache.streams.hdfs.HdfsReaderConfiguration source)
@BeanProperty(value="destination") public org.apache.streams.hdfs.HdfsWriterConfiguration getDestination()
@BeanProperty(value="destination") public void setDestination(org.apache.streams.hdfs.HdfsWriterConfiguration destination)
destination
- The destinationpublic TwitterPostsPipelineConfiguration withDestination(org.apache.streams.hdfs.HdfsWriterConfiguration destination)
@BeanProperty(value="providerWaitMs") public Long getProviderWaitMs()
getProviderWaitMs
in class FlinkStreamingConfiguration
@BeanProperty(value="providerWaitMs") public void setProviderWaitMs(Long providerWaitMs)
setProviderWaitMs
in class FlinkStreamingConfiguration
providerWaitMs
- The providerWaitMspublic TwitterPostsPipelineConfiguration withProviderWaitMs(Long providerWaitMs)
withProviderWaitMs
in class FlinkStreamingConfiguration
public String toString()
toString
in class FlinkStreamingConfiguration
@BeanProperty(name="*") public Map<String,Object> getAdditionalProperties()
getAdditionalProperties
in class FlinkStreamingConfiguration
@BeanProperty(name="*") public void setAdditionalProperty(String name, Object value)
setAdditionalProperty
in class FlinkStreamingConfiguration
public TwitterPostsPipelineConfiguration withAdditionalProperty(String name, Object value)
withAdditionalProperty
in class FlinkStreamingConfiguration
public int hashCode()
hashCode
in class FlinkStreamingConfiguration
public boolean equals(Object other)
equals
in class FlinkStreamingConfiguration
Copyright © 2017 The Apache Software Foundation. All rights reserved.