Package | Description |
---|---|
org.apache.streams.core | |
org.apache.streams.core.util |
Modifier and Type | Method and Description |
---|---|
Queue<StreamsDatum> |
StreamsResultSet.getQueue() |
Iterator<StreamsDatum> |
StreamsResultSet.iterator() |
List<StreamsDatum> |
StreamsProcessor.process(StreamsDatum entry)
Process/Analyze the
StreamsDatum and return the the StreamsDatums that will
passed to every down stream operation that reads from this processor. |
Modifier and Type | Method and Description |
---|---|
List<StreamsDatum> |
StreamsProcessor.process(StreamsDatum entry)
Process/Analyze the
StreamsDatum and return the the StreamsDatums that will
passed to every down stream operation that reads from this processor. |
void |
StreamsPersistWriter.write(StreamsDatum entry)
Persist the StreamsDatum to the corresponding data store.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamsResultSet.setQueue(Queue<StreamsDatum> queue) |
Constructor and Description |
---|
StreamsResultSet(Queue<StreamsDatum> queue) |
Modifier and Type | Method and Description |
---|---|
static StreamsDatum |
DatumUtils.cloneDatum(StreamsDatum datum) |
Modifier and Type | Method and Description |
---|---|
static void |
DatumUtils.addErrorToMetadata(StreamsDatum datum,
Throwable throwable,
Class<? extends StreamsOperation> operationClass)
Adds an error occurred during a StreamsOperation step to the StreamsDatum's metadata.
|
static StreamsDatum |
DatumUtils.cloneDatum(StreamsDatum datum) |
Copyright © 2017 The Apache Software Foundation. All rights reserved.