Package | Description |
---|---|
org.apache.streams.local.builders | |
org.apache.streams.local.tasks |
Modifier and Type | Method and Description |
---|---|
StreamsTask |
StreamComponent.createConnectedTask(int timeout)
Creates a
StreamsTask that is running a clone of this component whose
inbound and outbound queues are appropriately connected to the parent and child nodes. |
Modifier and Type | Method and Description |
---|---|
List<StreamsTask> |
StreamComponent.getStreamsTasks() |
Modifier and Type | Method and Description |
---|---|
protected void |
LocalStreamBuilder.forceShutdown(Map<String,List<StreamsTask>> streamsTasks) |
protected void |
LocalStreamBuilder.setupComponentTasks(Map<String,List<StreamsTask>> streamsTasks) |
protected void |
LocalStreamBuilder.shutdown(Map<String,List<StreamsTask>> streamsTasks) |
Modifier and Type | Class and Description |
---|---|
class |
BaseStreamsTask
BaseStreamsTask is the primary abstract StreamsTask.
|
class |
StreamsMergeTask
Deprecated.
|
class |
StreamsPersistWriterTask |
class |
StreamsProcessorTask |
class |
StreamsProviderTask |
Copyright © 2018 The Apache Software Foundation. All rights reserved.