A C D E F G I M N O P R S T V W

A

add(DatumStatusCounter) - Method in class org.apache.streams.core.DatumStatusCounter

Deprecated.

addErrorToMetadata(StreamsDatum, Throwable, Class<? extends StreamsOperation>) - Static method in class org.apache.streams.core.util.DatumUtils

Adds an error occurred during a StreamsOperation step to the StreamsDatum's metadata.

addStreamsPersistWriter(String, StreamsPersistWriter, int, String...) - Method in interface org.apache.streams.core.StreamBuilder

Add a StreamsPersistWriter to the data processing stream.

addStreamsProcessor(String, StreamsProcessor, int, String...) - Method in interface org.apache.streams.core.StreamBuilder

Add a StreamsProcessor to the data processing stream.

C

cleanUp() - Method in interface org.apache.streams.core.StreamsOperation

No guarantee that this method will ever be called.

cloneDatum(StreamsDatum) - Static method in class org.apache.streams.core.util.DatumUtils

D

DatumStatus - Enum in org.apache.streams.core

DatumStatusCountable - Interface in org.apache.streams.core

Deprecated.

DatumStatusCounter - Class in org.apache.streams.core

Deprecated.

DatumStatusCounter() - Constructor for class org.apache.streams.core.DatumStatusCounter

Deprecated.

DatumUtils - Class in org.apache.streams.core.util

Provides common utilities for managing and manipulating StreamsDatums

DatumUtils() - Constructor for class org.apache.streams.core.util.DatumUtils

document - Variable in class org.apache.streams.core.StreamsDatum

E

equals(Object) - Method in class org.apache.streams.core.StreamsDatum

F

filter(StreamsDatum) - Method in interface org.apache.streams.core.StreamsFilter

G

getAttempted() - Method in class org.apache.streams.core.DatumStatusCounter

Deprecated.

getCounter() - Method in class org.apache.streams.core.StreamsResultSet

getDatumStatusCounter() - Method in interface org.apache.streams.core.DatumStatusCountable

Deprecated.

getDocument() - Method in class org.apache.streams.core.StreamsDatum

getEmitted() - Method in class org.apache.streams.core.DatumStatusCounter

Deprecated.

getFail() - Method in class org.apache.streams.core.DatumStatusCounter

Deprecated.

getId() - Method in class org.apache.streams.core.StreamsDatum

getId() - Method in interface org.apache.streams.core.StreamsOperation

Each operation must publish an identifier.

getMetadata() - Method in class org.apache.streams.core.StreamsDatum

getPartial() - Method in class org.apache.streams.core.DatumStatusCounter

Deprecated.

getProcessorInputQueue() - Method in interface org.apache.streams.core.StreamsFilter

getProcessorOutputQueue() - Method in interface org.apache.streams.core.StreamsFilter

getQueue() - Method in class org.apache.streams.core.StreamsResultSet

getSequenceid() - Method in class org.apache.streams.core.StreamsDatum

getState() - Method in class org.apache.streams.core.StreamHandler

getStreamsConfiguration() - Method in interface org.apache.streams.core.StreamBuilder

getSuccess() - Method in class org.apache.streams.core.DatumStatusCounter

Deprecated.

getTimestamp() - Method in class org.apache.streams.core.StreamsDatum

I

incrementAttempt() - Method in class org.apache.streams.core.DatumStatusCounter

Deprecated.

incrementAttempt(int) - Method in class org.apache.streams.core.DatumStatusCounter

Deprecated.

incrementStatus(DatumStatus) - Method in class org.apache.streams.core.DatumStatusCounter

Deprecated.

incrementStatus(DatumStatus, int) - Method in class org.apache.streams.core.DatumStatusCounter

Deprecated.

isRunning() - Method in interface org.apache.streams.core.StreamsProvider

Flag to indicate whether the provider is producing data

iterator() - Method in class org.apache.streams.core.StreamsResultSet

M

metadata - Variable in class org.apache.streams.core.StreamsDatum

N

newPerpetualStream(String, StreamsProvider) - Method in interface org.apache.streams.core.StreamBuilder

Add a StreamsProvider to the data processing stream.

newReadCurrentStream(String, StreamsProvider) - Method in interface org.apache.streams.core.StreamBuilder

Add a StreamsProvider to the data processing stream.

newReadNewStream(String, StreamsProvider, BigInteger) - Method in interface org.apache.streams.core.StreamBuilder

Add a StreamsProvider to the data processing stream.

newReadRangeStream(String, StreamsProvider, DateTime, DateTime) - Method in interface org.apache.streams.core.StreamBuilder

Add a StreamsProvider to the data processing stream.

O

org.apache.streams.core - package org.apache.streams.core

org.apache.streams.core.util - package org.apache.streams.core.util

P

prepare(Object) - Method in interface org.apache.streams.core.StreamsOperation

This method will be called after initialization/serialization.

process(StreamsDatum) - Method in interface org.apache.streams.core.StreamsProcessor

Process/Analyze the StreamsDatum and return the the StreamsDatums that will passed to every down stream operation that reads from this processor.

R

readAll() - Method in interface org.apache.streams.core.StreamsPersistReader

readCurrent() - Method in interface org.apache.streams.core.StreamsProvider

Read the current items available from the provider

readNew(BigInteger) - Method in interface org.apache.streams.core.StreamsPersistReader

readNew(BigInteger) - Method in interface org.apache.streams.core.StreamsProvider

TODO: Define how this operates or eliminate

readRange(DateTime, DateTime) - Method in interface org.apache.streams.core.StreamsPersistReader

readRange(DateTime, DateTime) - Method in interface org.apache.streams.core.StreamsProvider

TODO: Define how this operates or eliminate

S

sequenceid - Variable in class org.apache.streams.core.StreamsDatum

setCounter(DatumStatusCounter) - Method in class org.apache.streams.core.StreamsResultSet

setDocument(Object) - Method in class org.apache.streams.core.StreamsDatum

setId(String) - Method in class org.apache.streams.core.StreamsDatum

setMetadata(Map<String, Object>) - Method in class org.apache.streams.core.StreamsDatum

setProcessorInputQueue(Queue<StreamsDatum>) - Method in interface org.apache.streams.core.StreamsFilter

setProcessorOutputQueue(Queue<StreamsDatum>) - Method in interface org.apache.streams.core.StreamsFilter

setQueue(Queue<StreamsDatum>) - Method in class org.apache.streams.core.StreamsResultSet

setSequenceid(BigInteger) - Method in class org.apache.streams.core.StreamsDatum

setState(StreamState) - Method in class org.apache.streams.core.StreamHandler

setStreamsConfiguration(StreamsConfiguration) - Method in interface org.apache.streams.core.StreamBuilder

setTimestamp(DateTime) - Method in class org.apache.streams.core.StreamsDatum

size() - Method in class org.apache.streams.core.StreamsResultSet

start() - Method in interface org.apache.streams.core.StreamBuilder

Builds the stream, and starts it or submits it based on implementation.

start() - Method in interface org.apache.streams.core.StreamsFilter

startStream() - Method in interface org.apache.streams.core.StreamsProvider

Start the operation of the stream

stop() - Method in interface org.apache.streams.core.StreamBuilder

Stops the streams processing.

stop() - Method in interface org.apache.streams.core.StreamsFilter

StreamBuilder - Interface in org.apache.streams.core

Interface for building data streams.

StreamHandler - Class in org.apache.streams.core

Created by sblackmon on 1/6/14.

StreamHandler() - Constructor for class org.apache.streams.core.StreamHandler

StreamsDatum - Class in org.apache.streams.core

Created by sblackmon on 1/2/14.

StreamsDatum(Object) - Constructor for class org.apache.streams.core.StreamsDatum

StreamsDatum(Object, String) - Constructor for class org.apache.streams.core.StreamsDatum

StreamsDatum(Object, BigInteger) - Constructor for class org.apache.streams.core.StreamsDatum

StreamsDatum(Object, DateTime) - Constructor for class org.apache.streams.core.StreamsDatum

StreamsDatum(Object, DateTime, BigInteger) - Constructor for class org.apache.streams.core.StreamsDatum

StreamsDatum(Object, DateTime, Map<String, Object>) - Constructor for class org.apache.streams.core.StreamsDatum

StreamsDatum(Object, String, DateTime) - Constructor for class org.apache.streams.core.StreamsDatum

StreamsDatum(Object, String, Map<String, Object>) - Constructor for class org.apache.streams.core.StreamsDatum

StreamsDatum(Object, String, BigInteger, Map<String, Object>) - Constructor for class org.apache.streams.core.StreamsDatum

StreamsDatum(Object, String, BigInteger) - Constructor for class org.apache.streams.core.StreamsDatum

StreamsDatum(Object, String, DateTime, BigInteger) - Constructor for class org.apache.streams.core.StreamsDatum

StreamsDatum(Object, String, DateTime, BigInteger, Map<String, Object>) - Constructor for class org.apache.streams.core.StreamsDatum

StreamsFilter - Interface in org.apache.streams.core

Created by sblackmon on 12/13/13.

StreamsOperation - Interface in org.apache.streams.core

StreamsPersistReader - Interface in org.apache.streams.core

Currently a duplicate interface.

StreamsPersistWriter - Interface in org.apache.streams.core

Created by sblackmon on 12/13/13.

StreamsProcessor - Interface in org.apache.streams.core

Created by sblackmon on 12/13/13.

StreamsProvider - Interface in org.apache.streams.core

A StreamsProvider represents the entry point into the Streams pipeline.

StreamsResultSet - Class in org.apache.streams.core

StreamsResultSet(Queue<StreamsDatum>) - Constructor for class org.apache.streams.core.StreamsResultSet

StreamState - Enum in org.apache.streams.core

Created by sblackmon on 1/6/14.

T

timestamp - Variable in class org.apache.streams.core.StreamsDatum

toString() - Method in class org.apache.streams.core.DatumStatusCounter

Deprecated.

toString() - Method in class org.apache.streams.core.StreamsDatum

V

valueOf(String) - Static method in enum org.apache.streams.core.DatumStatus

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.streams.core.StreamState

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.streams.core.DatumStatus

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.streams.core.StreamState

Returns an array containing the constants of this enum type, in the order they are declared.

W

write(StreamsDatum) - Method in interface org.apache.streams.core.StreamsPersistWriter

Persist the StreamsDatum to the corresponding data store.

A C D E F G I M N O P R S T V W