Map<K,V> providers
Map<K,V> components
LocalRuntimeConfiguration streamConfig
Map<K,V> futures
ExecutorService executor
ExecutorService monitor
int totalTasks
int monitorTasks
LocalStreamProcessMonitorThread monitorThread
Map<K,V> tasks
Thread shutdownHook
BroadcastMonitorThread broadcastMonitor
int maxQueueCapacity
String streamIdentifier
org.joda.time.DateTime startedAt
boolean useDeprecatedMonitors
String id
Set<E> inBound
Map<K,V> outBound
BlockingQueue<E> inQueue
StreamsProvider provider
StreamsProcessor processor
StreamsPersistWriter writer
org.joda.time.DateTime[] dateRange
BigInteger sequence
int numTasks
boolean perpetual
List<E> tasks
org.apache.streams.config.StreamsConfiguration streamConfig
Copyright © 2017 The Apache Software Foundation. All rights reserved.