org.apache.streams.local

Class LocalRuntimeConfiguration

java.lang.Object

org.apache.streams.config.StreamsConfiguration

org.apache.streams.local.LocalRuntimeConfiguration

All Implemented Interfaces:

Serializable

@Generated(value="org.jsonschema2pojo")
public class LocalRuntimeConfiguration
extends org.apache.streams.config.StreamsConfiguration
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
LocalRuntimeConfiguration()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object other)
Long	getExecutorShutdownPauseMs() Duration of pause before shutting down
Long	getExecutorShutdownWaitMs() Duration of wait for shut down
Long	getMaxQueueCapacity() Max Queue Capacity
Long	getMonitorShutdownPauseMs() Duration of pause before shutting down
Long	getMonitorShutdownWaitMs() Duration of wait for shut down
Long	getShutdownPauseMs() Duration of pause before shutting down
Long	getTaskTimeoutMs() Max duration to allow tasks to terminate
int	hashCode()
void	setExecutorShutdownPauseMs(Long executorShutdownPauseMs) Duration of pause before shutting down
void	setExecutorShutdownWaitMs(Long executorShutdownWaitMs) Duration of wait for shut down
void	setMaxQueueCapacity(Long maxQueueCapacity) Max Queue Capacity
void	setMonitorShutdownPauseMs(Long monitorShutdownPauseMs) Duration of pause before shutting down
void	setMonitorShutdownWaitMs(Long monitorShutdownWaitMs) Duration of wait for shut down
void	setShutdownPauseMs(Long shutdownPauseMs) Duration of pause before shutting down
void	setTaskTimeoutMs(Long taskTimeoutMs) Max duration to allow tasks to terminate
String	toString()
LocalRuntimeConfiguration	withExecutorShutdownPauseMs(Long executorShutdownPauseMs)
LocalRuntimeConfiguration	withExecutorShutdownWaitMs(Long executorShutdownWaitMs)
LocalRuntimeConfiguration	withMaxQueueCapacity(Long maxQueueCapacity)
LocalRuntimeConfiguration	withMonitorShutdownPauseMs(Long monitorShutdownPauseMs)
LocalRuntimeConfiguration	withMonitorShutdownWaitMs(Long monitorShutdownWaitMs)
LocalRuntimeConfiguration	withShutdownPauseMs(Long shutdownPauseMs)
LocalRuntimeConfiguration	withTaskTimeoutMs(Long taskTimeoutMs)

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

LocalRuntimeConfiguration

public LocalRuntimeConfiguration()

Method Detail

getMaxQueueCapacity

@BeanProperty(value="maxQueueCapacity")
public Long getMaxQueueCapacity()

Max Queue Capacity

Returns:

The maxQueueCapacity

setMaxQueueCapacity

@BeanProperty(value="maxQueueCapacity")
public void setMaxQueueCapacity(Long maxQueueCapacity)

Max Queue Capacity

Parameters:

maxQueueCapacity - The maxQueueCapacity

withMaxQueueCapacity

public LocalRuntimeConfiguration withMaxQueueCapacity(Long maxQueueCapacity)

getExecutorShutdownPauseMs

@BeanProperty(value="executorShutdownPauseMs")
public Long getExecutorShutdownPauseMs()

Duration of pause before shutting down

Returns:

The executorShutdownPauseMs

setExecutorShutdownPauseMs

@BeanProperty(value="executorShutdownPauseMs")
public void setExecutorShutdownPauseMs(Long executorShutdownPauseMs)

Duration of pause before shutting down

Parameters:

executorShutdownPauseMs - The executorShutdownPauseMs

withExecutorShutdownPauseMs

public LocalRuntimeConfiguration withExecutorShutdownPauseMs(Long executorShutdownPauseMs)

getMonitorShutdownPauseMs

@BeanProperty(value="monitorShutdownPauseMs")
public Long getMonitorShutdownPauseMs()

Duration of pause before shutting down

Returns:

The monitorShutdownPauseMs

setMonitorShutdownPauseMs

@BeanProperty(value="monitorShutdownPauseMs")
public void setMonitorShutdownPauseMs(Long monitorShutdownPauseMs)

Duration of pause before shutting down

Parameters:

monitorShutdownPauseMs - The monitorShutdownPauseMs

withMonitorShutdownPauseMs

public LocalRuntimeConfiguration withMonitorShutdownPauseMs(Long monitorShutdownPauseMs)

getExecutorShutdownWaitMs

@BeanProperty(value="executorShutdownWaitMs")
public Long getExecutorShutdownWaitMs()

Duration of wait for shut down

Returns:

The executorShutdownWaitMs

setExecutorShutdownWaitMs

@BeanProperty(value="executorShutdownWaitMs")
public void setExecutorShutdownWaitMs(Long executorShutdownWaitMs)

Duration of wait for shut down

Parameters:

executorShutdownWaitMs - The executorShutdownWaitMs

withExecutorShutdownWaitMs

public LocalRuntimeConfiguration withExecutorShutdownWaitMs(Long executorShutdownWaitMs)

getMonitorShutdownWaitMs

@BeanProperty(value="monitorShutdownWaitMs")
public Long getMonitorShutdownWaitMs()

Duration of wait for shut down

Returns:

The monitorShutdownWaitMs

setMonitorShutdownWaitMs

@BeanProperty(value="monitorShutdownWaitMs")
public void setMonitorShutdownWaitMs(Long monitorShutdownWaitMs)

Duration of wait for shut down

Parameters:

monitorShutdownWaitMs - The monitorShutdownWaitMs

withMonitorShutdownWaitMs

public LocalRuntimeConfiguration withMonitorShutdownWaitMs(Long monitorShutdownWaitMs)

getShutdownPauseMs

@BeanProperty(value="shutdownPauseMs")
public Long getShutdownPauseMs()

Duration of pause before shutting down

Returns:

The shutdownPauseMs

setShutdownPauseMs

@BeanProperty(value="shutdownPauseMs")
public void setShutdownPauseMs(Long shutdownPauseMs)

Duration of pause before shutting down

Parameters:

shutdownPauseMs - The shutdownPauseMs

withShutdownPauseMs

public LocalRuntimeConfiguration withShutdownPauseMs(Long shutdownPauseMs)

getTaskTimeoutMs

@BeanProperty(value="taskTimeoutMs")
public Long getTaskTimeoutMs()

Max duration to allow tasks to terminate

Returns:

The taskTimeoutMs

setTaskTimeoutMs

@BeanProperty(value="taskTimeoutMs")
public void setTaskTimeoutMs(Long taskTimeoutMs)

Max duration to allow tasks to terminate

Parameters:

taskTimeoutMs - The taskTimeoutMs

withTaskTimeoutMs

public LocalRuntimeConfiguration withTaskTimeoutMs(Long taskTimeoutMs)

toString

public String toString()

Overrides:

toString in class org.apache.streams.config.StreamsConfiguration

hashCode

public int hashCode()

Overrides:

hashCode in class org.apache.streams.config.StreamsConfiguration

equals

public boolean equals(Object other)

Overrides:

equals in class org.apache.streams.config.StreamsConfiguration