C D E G H M O R S T W

C

ComponentConfiguration - Class in org.apache.streams.config

ComponentConfiguration() - Constructor for class org.apache.streams.config.ComponentConfiguration

ComponentConfigurator<T extends Serializable> - Class in org.apache.streams.config

ComponentConfigurator supplies serializable configuration beans derived from a specified typesafe path or object.

ComponentConfigurator(Class<T>) - Constructor for class org.apache.streams.config.ComponentConfigurator

config - Static variable in class org.apache.streams.config.StreamsConfigurator

D

detectConfiguration(Config) - Method in class org.apache.streams.config.ComponentConfigurator

resolve a serializable configuration pojo from a given typesafe config object.

detectConfiguration(String) - Method in class org.apache.streams.config.ComponentConfigurator

resolve a serializable configuration pojo from a portion of the JVM config object.

detectConfiguration(Config, String) - Method in class org.apache.streams.config.ComponentConfigurator

resolve a serializable configuration pojo from a portion of a given typesafe config object.

detectConfiguration() - Static method in class org.apache.streams.config.StreamsConfigurator

detectConfiguration(Config) - Static method in class org.apache.streams.config.StreamsConfigurator

E

equals(Object) - Method in class org.apache.streams.config.ComponentConfiguration

equals(Object) - Method in class org.apache.streams.config.StreamsConfiguration

G

getAdditionalProperties() - Method in class org.apache.streams.config.ComponentConfiguration

getAdditionalProperties() - Method in class org.apache.streams.config.StreamsConfiguration

getBatchFrequencyMs() - Method in class org.apache.streams.config.StreamsConfiguration

Frequency of messaging between components

getBatchSize() - Method in class org.apache.streams.config.StreamsConfiguration

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

getConfig() - Static method in class org.apache.streams.config.StreamsConfigurator

getIdentifier() - Method in class org.apache.streams.config.StreamsConfiguration

Name of streams pipeline

getInClasses() - Method in class org.apache.streams.config.ComponentConfiguration

getOutClasses() - Method in class org.apache.streams.config.ComponentConfiguration

getParallelism() - Method in class org.apache.streams.config.StreamsConfiguration

Default parallelism for processors

getProviderTimeoutMs() - Method in class org.apache.streams.config.StreamsConfiguration

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

getQueueSize() - Method in class org.apache.streams.config.StreamsConfiguration

Size of inter-component buffers

getShutdownCheckDelay() - Method in class org.apache.streams.config.StreamsConfiguration

Initial delay before checking for shutdown

getShutdownCheckInterval() - Method in class org.apache.streams.config.StreamsConfiguration

Recurring delay between checking for shutdown

getStartedAt() - Method in class org.apache.streams.config.StreamsConfiguration

Timestamp of beginning of stream execution

H

hashCode() - Method in class org.apache.streams.config.ComponentConfiguration

hashCode() - Method in class org.apache.streams.config.StreamsConfiguration

M

mergeConfigurations(Config, Config) - Static method in class org.apache.streams.config.StreamsConfigurator

O

org.apache.streams.config - package org.apache.streams.config

R

resolveConfig(String) - Static method in class org.apache.streams.config.StreamsConfigurator

S

setAdditionalProperty(String, Object) - Method in class org.apache.streams.config.ComponentConfiguration

setAdditionalProperty(String, Object) - Method in class org.apache.streams.config.StreamsConfiguration

setBatchFrequencyMs(Long) - Method in class org.apache.streams.config.StreamsConfiguration

Frequency of messaging between components

setBatchSize(Long) - Method in class org.apache.streams.config.StreamsConfiguration

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

setIdentifier(String) - Method in class org.apache.streams.config.StreamsConfiguration

Name of streams pipeline

setInClasses(List<String>) - Method in class org.apache.streams.config.ComponentConfiguration

setOutClasses(List<String>) - Method in class org.apache.streams.config.ComponentConfiguration

setParallelism(Long) - Method in class org.apache.streams.config.StreamsConfiguration

Default parallelism for processors

setProviderTimeoutMs(Long) - Method in class org.apache.streams.config.StreamsConfiguration

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

setQueueSize(Long) - Method in class org.apache.streams.config.StreamsConfiguration

Size of inter-component buffers

setShutdownCheckDelay(Long) - Method in class org.apache.streams.config.StreamsConfiguration

Initial delay before checking for shutdown

setShutdownCheckInterval(Long) - Method in class org.apache.streams.config.StreamsConfiguration

Recurring delay between checking for shutdown

setStartedAt(Long) - Method in class org.apache.streams.config.StreamsConfiguration

Timestamp of beginning of stream execution

StreamsConfiguration - Class in org.apache.streams.config

StreamsConfiguration() - Constructor for class org.apache.streams.config.StreamsConfiguration

StreamsConfigurator - Class in org.apache.streams.config

StreamsConfigurator supplies the entire typesafe tree to runtimes and modules.

StreamsConfigurator() - Constructor for class org.apache.streams.config.StreamsConfigurator

T

toString() - Method in class org.apache.streams.config.ComponentConfiguration

toString() - Method in class org.apache.streams.config.StreamsConfiguration

W

withAdditionalProperty(String, Object) - Method in class org.apache.streams.config.ComponentConfiguration

withAdditionalProperty(String, Object) - Method in class org.apache.streams.config.StreamsConfiguration

withBatchFrequencyMs(Long) - Method in class org.apache.streams.config.StreamsConfiguration

withBatchSize(Long) - Method in class org.apache.streams.config.StreamsConfiguration

withIdentifier(String) - Method in class org.apache.streams.config.StreamsConfiguration

withInClasses(List<String>) - Method in class org.apache.streams.config.ComponentConfiguration

withOutClasses(List<String>) - Method in class org.apache.streams.config.ComponentConfiguration

withParallelism(Long) - Method in class org.apache.streams.config.StreamsConfiguration

withProviderTimeoutMs(Long) - Method in class org.apache.streams.config.StreamsConfiguration

withQueueSize(Long) - Method in class org.apache.streams.config.StreamsConfiguration

withShutdownCheckDelay(Long) - Method in class org.apache.streams.config.StreamsConfiguration

withShutdownCheckInterval(Long) - Method in class org.apache.streams.config.StreamsConfiguration

withStartedAt(Long) - Method in class org.apache.streams.config.StreamsConfiguration

C D E G H M O R S T W