org.apache.streams.config

Class StreamsConfiguration

java.lang.Object

org.apache.streams.config.StreamsConfiguration

All Implemented Interfaces:

Serializable

@Generated(value="org.jsonschema2pojo")
public class StreamsConfiguration
extends Object
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StreamsConfiguration()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object other)
Long	getBatchFrequencyMs() Frequency of messaging between components
Long	getBatchSize() Default max batch size for batch-based persist readers and writers
String	getIdentifier() Name of streams pipeline
Long	getParallelism() Default parallelism for processors
Long	getProviderTimeoutMs() Kill the stream if all providers supply nothing for this long.
Long	getProviderWaitMs() Wait this long before beginning polling providers.
Long	getQueueSize() Size of inter-component buffers
Long	getShutdownCheckDelay() Initial delay before checking for shutdown
Long	getShutdownCheckInterval() Recurring delay between checking for shutdown
Long	getStartedAt() Timestamp of beginning of stream execution
int	hashCode()
void	setBatchFrequencyMs(Long batchFrequencyMs) Frequency of messaging between components
void	setBatchSize(Long batchSize) Default max batch size for batch-based persist readers and writers
void	setIdentifier(String identifier) Name of streams pipeline
void	setParallelism(Long parallelism) Default parallelism for processors
void	setProviderTimeoutMs(Long providerTimeoutMs) Kill the stream if all providers supply nothing for this long.
void	setProviderWaitMs(Long providerWaitMs) Wait this long before beginning polling providers.
void	setQueueSize(Long queueSize) Size of inter-component buffers
void	setShutdownCheckDelay(Long shutdownCheckDelay) Initial delay before checking for shutdown
void	setShutdownCheckInterval(Long shutdownCheckInterval) Recurring delay between checking for shutdown
void	setStartedAt(Long startedAt) Timestamp of beginning of stream execution
String	toString()
StreamsConfiguration	withBatchFrequencyMs(Long batchFrequencyMs)
StreamsConfiguration	withBatchSize(Long batchSize)
StreamsConfiguration	withIdentifier(String identifier)
StreamsConfiguration	withParallelism(Long parallelism)
StreamsConfiguration	withProviderTimeoutMs(Long providerTimeoutMs)
StreamsConfiguration	withProviderWaitMs(Long providerWaitMs)
StreamsConfiguration	withQueueSize(Long queueSize)
StreamsConfiguration	withShutdownCheckDelay(Long shutdownCheckDelay)
StreamsConfiguration	withShutdownCheckInterval(Long shutdownCheckInterval)
StreamsConfiguration	withStartedAt(Long startedAt)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamsConfiguration

public StreamsConfiguration()

Method Detail

getBatchFrequencyMs

@BeanProperty(value="batchFrequencyMs")
public Long getBatchFrequencyMs()

Frequency of messaging between components

Returns:

The batchFrequencyMs

setBatchFrequencyMs

@BeanProperty(value="batchFrequencyMs")
public void setBatchFrequencyMs(Long batchFrequencyMs)

Frequency of messaging between components

Parameters:

batchFrequencyMs - The batchFrequencyMs

withBatchFrequencyMs

public StreamsConfiguration withBatchFrequencyMs(Long batchFrequencyMs)

getBatchSize

@BeanProperty(value="batchSize")
public Long getBatchSize()

Default max batch size for batch-based persist readers and writers

Returns:

The batchSize

setBatchSize

@BeanProperty(value="batchSize")
public void setBatchSize(Long batchSize)

Default max batch size for batch-based persist readers and writers

Parameters:

batchSize - The batchSize

withBatchSize

public StreamsConfiguration withBatchSize(Long batchSize)

getIdentifier

@BeanProperty(value="identifier")
public String getIdentifier()

Name of streams pipeline

Returns:

The identifier

setIdentifier

@BeanProperty(value="identifier")
public void setIdentifier(String identifier)

Name of streams pipeline

Parameters:

identifier - The identifier

withIdentifier

public StreamsConfiguration withIdentifier(String identifier)

getParallelism

@BeanProperty(value="parallelism")
public Long getParallelism()

Default parallelism for processors

Returns:

The parallelism

setParallelism

@BeanProperty(value="parallelism")
public void setParallelism(Long parallelism)

Default parallelism for processors

Parameters:

parallelism - The parallelism

withParallelism

public StreamsConfiguration withParallelism(Long parallelism)

getProviderTimeoutMs

@BeanProperty(value="providerTimeoutMs")
public Long getProviderTimeoutMs()

Kill the stream if all providers supply nothing for this long.

Returns:

The providerTimeoutMs

setProviderTimeoutMs

@BeanProperty(value="providerTimeoutMs")
public void setProviderTimeoutMs(Long providerTimeoutMs)

Kill the stream if all providers supply nothing for this long.

Parameters:

providerTimeoutMs - The providerTimeoutMs

withProviderTimeoutMs

public StreamsConfiguration withProviderTimeoutMs(Long providerTimeoutMs)

getProviderWaitMs

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

Wait this long before beginning polling providers.

Returns:

The providerWaitMs

setProviderWaitMs

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

Wait this long before beginning polling providers.

Parameters:

providerWaitMs - The providerWaitMs

withProviderWaitMs

public StreamsConfiguration withProviderWaitMs(Long providerWaitMs)

getQueueSize

@BeanProperty(value="queueSize")
public Long getQueueSize()

Size of inter-component buffers

Returns:

The queueSize

setQueueSize

@BeanProperty(value="queueSize")
public void setQueueSize(Long queueSize)

Size of inter-component buffers

Parameters:

queueSize - The queueSize

withQueueSize

public StreamsConfiguration withQueueSize(Long queueSize)

getShutdownCheckDelay

@BeanProperty(value="shutdownCheckDelay")
public Long getShutdownCheckDelay()

Initial delay before checking for shutdown

Returns:

The shutdownCheckDelay

setShutdownCheckDelay

@BeanProperty(value="shutdownCheckDelay")
public void setShutdownCheckDelay(Long shutdownCheckDelay)

Initial delay before checking for shutdown

Parameters:

shutdownCheckDelay - The shutdownCheckDelay

withShutdownCheckDelay

public StreamsConfiguration withShutdownCheckDelay(Long shutdownCheckDelay)

getShutdownCheckInterval

@BeanProperty(value="shutdownCheckInterval")
public Long getShutdownCheckInterval()

Recurring delay between checking for shutdown

Returns:

The shutdownCheckInterval

setShutdownCheckInterval

@BeanProperty(value="shutdownCheckInterval")
public void setShutdownCheckInterval(Long shutdownCheckInterval)

Recurring delay between checking for shutdown

Parameters:

shutdownCheckInterval - The shutdownCheckInterval

withShutdownCheckInterval

public StreamsConfiguration withShutdownCheckInterval(Long shutdownCheckInterval)

getStartedAt

@BeanProperty(value="startedAt")
public Long getStartedAt()

Timestamp of beginning of stream execution

Returns:

The startedAt

setStartedAt

@BeanProperty(value="startedAt")
public void setStartedAt(Long startedAt)

Timestamp of beginning of stream execution

Parameters:

startedAt - The startedAt

withStartedAt

public StreamsConfiguration withStartedAt(Long startedAt)

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object other)

Overrides:

equals in class Object