public class StreamComponent extends Object implements Serializable
StreamsOperation
, the StreamsOperations it is connected
to and the necessary metadata to construct a data stream.Constructor and Description |
---|
StreamComponent(String id,
StreamsPersistWriter writer,
BlockingQueue<StreamsDatum> inQueue,
int numTasks,
org.apache.streams.config.StreamsConfiguration streamConfig) |
StreamComponent(String id,
StreamsProcessor processor,
BlockingQueue<StreamsDatum> inQueue,
int numTasks,
org.apache.streams.config.StreamsConfiguration streamConfig) |
StreamComponent(String id,
StreamsProvider provider,
BigInteger sequence,
org.apache.streams.config.StreamsConfiguration streamConfig) |
StreamComponent(String id,
StreamsProvider provider,
boolean perpetual,
org.apache.streams.config.StreamsConfiguration streamConfig) |
StreamComponent(String id,
StreamsProvider provider,
org.joda.time.DateTime start,
org.joda.time.DateTime end,
org.apache.streams.config.StreamsConfiguration streamConfig) |
Modifier and Type | Method and Description |
---|---|
void |
addInboundQueue(StreamComponent component)
Add a component that supplies data through the inbound queue.
|
void |
addOutBoundQueue(StreamComponent component,
BlockingQueue<StreamsDatum> queue)
Add an outbound queue for this component.
|
StreamsTask |
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. |
boolean |
equals(Object o) |
Collection<StreamComponent> |
getDownStreamComponents()
The components that are immediately downstream of this component (aka child nodes)
|
String |
getId()
The unique of this component
|
BlockingQueue<StreamsDatum> |
getInBoundQueue()
The inbound queue for this component
|
int |
getNumTasks()
The number of tasks this to run this component
|
protected StreamsOperation |
getOperation() |
List<StreamsTask> |
getStreamsTasks() |
Collection<StreamComponent> |
getUpStreamComponents()
The components that are immediately upstream of this component (aka parent nodes)
|
int |
hashCode() |
protected boolean |
isOperationCountable()
Deprecated.
|
public StreamComponent(String id, StreamsProvider provider, boolean perpetual, org.apache.streams.config.StreamsConfiguration streamConfig)
id
- provider
- public StreamComponent(String id, StreamsProvider provider, org.joda.time.DateTime start, org.joda.time.DateTime end, org.apache.streams.config.StreamsConfiguration streamConfig)
id
- provider
- start
- end
- public StreamComponent(String id, StreamsProvider provider, BigInteger sequence, org.apache.streams.config.StreamsConfiguration streamConfig)
id
- provider
- sequence
- public StreamComponent(String id, StreamsProcessor processor, BlockingQueue<StreamsDatum> inQueue, int numTasks, org.apache.streams.config.StreamsConfiguration streamConfig)
id
- processor
- inQueue
- numTasks
- public StreamComponent(String id, StreamsPersistWriter writer, BlockingQueue<StreamsDatum> inQueue, int numTasks, org.apache.streams.config.StreamsConfiguration streamConfig)
id
- writer
- inQueue
- numTasks
- public void addOutBoundQueue(StreamComponent component, BlockingQueue<StreamsDatum> queue)
component
- the component that this supplying their inbound queuequeue
- the queue to to put post processed/provided datums onpublic void addInboundQueue(StreamComponent component)
component
- that supplies data through the inbound queuepublic Collection<StreamComponent> getDownStreamComponents()
public Collection<StreamComponent> getUpStreamComponents()
public BlockingQueue<StreamsDatum> getInBoundQueue()
public int getNumTasks()
public StreamsTask createConnectedTask(int timeout)
StreamsTask
that is running a clone of this component whose
inbound and outbound queues are appropriately connected to the parent and child nodes.timeout
- The timeout to use in milliseconds for any tasks that support configurable timeoutpublic List<StreamsTask> getStreamsTasks()
public String getId()
protected StreamsOperation getOperation()
@Deprecated protected boolean isOperationCountable()
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.