A B C D E F G H I J K L M N O P Q R S T U V W X Y 

A

AbstractExpression<T extends Serializable> - Class in stream.expressions.version2
 
AbstractExpression(String) - Constructor for class stream.expressions.version2.AbstractExpression
 
AbstractExpression.ContextExpressionResolver - Class in stream.expressions.version2
 
AbstractExpression.ContextExpressionResolver(String) - Constructor for class stream.expressions.version2.AbstractExpression.ContextExpressionResolver
 
AbstractExpression.DataExpressionResolver - Class in stream.expressions.version2
 
AbstractExpression.DataExpressionResolver(String) - Constructor for class stream.expressions.version2.AbstractExpression.DataExpressionResolver
 
AbstractExpression.ExpressionResolver - Class in stream.expressions.version2
 
AbstractExpression.ExpressionResolver(String) - Constructor for class stream.expressions.version2.AbstractExpression.ExpressionResolver
 
AbstractExpression.StaticNullExpressionResolver - Class in stream.expressions.version2
 
AbstractExpression.StaticNullExpressionResolver(String) - Constructor for class stream.expressions.version2.AbstractExpression.StaticNullExpressionResolver
 
AbstractExpression.StaticStringExpressionResolver - Class in stream.expressions.version2
 
AbstractExpression.StaticStringExpressionResolver(String) - Constructor for class stream.expressions.version2.AbstractExpression.StaticStringExpressionResolver
 
AbstractProcessor - Class in stream
This class implements some basic methods of the StatefulProcessor interface and can serve as basis for custom processor implementations.
AbstractProcessor() - Constructor for class stream.AbstractProcessor
 
AbstractQueue - Class in stream.io
 
AbstractQueue() - Constructor for class stream.io.AbstractQueue
 
AbstractSplit - Class in stream.flow
 
AbstractSplit() - Constructor for class stream.flow.AbstractSplit
 
AbstractStream - Class in stream.io
 
AbstractStream(SourceURL) - Constructor for class stream.io.AbstractStream
 
AbstractStream(InputStream) - Constructor for class stream.io.AbstractStream
 
AbstractStream() - Constructor for class stream.io.AbstractStream
 
activate() - Method in interface stream.io.active.ActiveDataStream
 
ActiveDataStream - Interface in stream.io.active
 
add(Map<String, Double>) - Method in class stream.data.Statistics
Adds the given statistics vector to this instance.
add(Statistics) - Method in class stream.data.Statistics
 
add(String, Double) - Method in class stream.data.Statistics
 
add(Condition, Sink) - Method in interface stream.flow.Split
Adds a new sink with a given condition to the split.
add(Condition, Sink) - Method in class stream.flow.SplitByCondition
 
add(Condition, Sink) - Method in class stream.flow.SplitByRandom
 
add(Processor) - Method in interface stream.Process
 
add(Processor) - Method in class stream.ProcessorList
 
add(int, Processor) - Method in class stream.ProcessorList
 
add(T) - Method in class stream.util.MultiSet
 
addAll(Collection<? extends T>) - Method in class stream.util.MultiSet
 
addArray(String, Class<?>, int) - Method in class stream.data.AssertTypes.ExpectedDataTypes
 
addChild(TreeNode) - Method in interface stream.data.TreeNode
Adds a child to this node.
addContainer(String, NamingService) - Method in interface stream.service.NamingService
 
addProcessor(Processor) - Method in class stream.ProcessorList
Deprecated.
use ProcessorList.getProcessors() to obtain the processor list and add new processors to that list.
addProcessor(int, Processor) - Method in class stream.ProcessorList
Deprecated.
use ProcessorList.getProcessors() to obtain the processor list and add new processors to that list.
addStream(String, Stream) - Method in interface stream.io.multi.MultiDataStream
 
addType(String, Class<?>) - Method in class stream.data.AssertTypes.ExpectedDataTypes
 
addUUIDAttributes(Document, String) - Static method in class stream.util.XMLUtils
Add random UUIDs to all elements of a document.
addUUIDAttributes(Element, String) - Static method in class stream.util.XMLUtils
This method generates a new random UUID and attaches it in a new attribute to the element.
addVariables(Map<String, String>) - Method in class stream.expressions.MacroExpander
 
advance(byte) - Method in class stream.data.SequenceID
 
AndCondition - Class in stream.expressions.version2
 
AndCondition(Expression<Boolean>, Expression<Boolean>) - Constructor for class stream.expressions.version2.AndCondition
 
annotation - Variable in class stream.data.Conventions.Key
 
ANNOTATION_PREFIX - Static variable in interface stream.Data
Attributes starting with an '@' character are regarded as annotations, i.e. referring to data transformation parameters (normalization,...)
asBigInteger() - Method in class stream.data.SequenceID
 
asMillis() - Method in class stream.util.Time
 
asMinutes() - Method in class stream.util.Time
 
asSeconds() - Method in class stream.util.Time
 
AssertionService - Interface in stream.service
 
AssertTypes - Class in stream.data
 
AssertTypes() - Constructor for class stream.data.AssertTypes
 
AssertTypes.ExpectedDataTypes - Class in stream.data
 
AssertTypes.ExpectedDataTypes() - Constructor for class stream.data.AssertTypes.ExpectedDataTypes
 
available() - Method in class stream.io.FifoInputStream
 
available() - Method in class stream.io.SequentialFileInputStream
 

B

Barrel - Interface in stream.io
A barrel is any class that can receive data items, store them for a limited amount of time and provide these data items as a source.
basicSizes - Static variable in class stream.util.SizeOf
 
batch - Variable in class stream.flow.Emitter
 
batchCount - Variable in class stream.flow.Emitter
 
batchSize - Variable in class stream.flow.Emitter
 
BinaryOperator - Class in stream.expressions
This class provides an abstract binary operator that is provided with two operands (one serializable, one string).
BinaryOperator(String) - Constructor for class stream.expressions.BinaryOperator
 
BinaryOperator(String, String...) - Constructor for class stream.expressions.BinaryOperator
 
BlockingQueue - Class in stream.io
The default implementation of a blocking queue of data items.
BlockingQueue() - Constructor for class stream.io.BlockingQueue
Creates a LinkedBlockingQueue with a capacity of Integer.MAX_VALUE.
BlockingQueue(int) - Constructor for class stream.io.BlockingQueue
Creates a LinkedBlockingQueue with the given (fixed) capacity.
BodyContent - Class in stream.annotations
This class simply represents text that is provided by the XML body content.
BodyContent(String) - Constructor for class stream.annotations.BodyContent
 
BooleanOperator - Enum in stream.expressions
 
BYTE - Static variable in class stream.util.parser.ByteSizeParser
 
ByteSize - Class in stream.util
 
ByteSize(Integer) - Constructor for class stream.util.ByteSize
 
ByteSize(String) - Constructor for class stream.util.ByteSize
 
ByteSizeParser - Class in stream.util.parser
 
ByteSizeParser() - Constructor for class stream.util.parser.ByteSizeParser
 

C

capacity - Variable in class stream.io.AbstractQueue
 
capacity() - Method in class stream.io.BlockingQueue
 
capacity() - Method in class stream.io.Hub
 
capacity() - Method in interface stream.io.QueueService
This method returns the number if items that can be stored in this queue at maximum.
check(Data) - Method in class stream.data.AssertTypes.ExpectedDataTypes
 
checkType(String, Data) - Method in class stream.data.AssertTypes.ExpectedDataTypes
 
checkValues(String, Serializable, Serializable) - Method in class stream.data.AssertTypes.ExpectedDataTypes
 
children() - Method in interface stream.data.TreeNode
Returns the collection child nodes of this node.
clear() - Method in class stream.data.DataArrayImpl
 
clear() - Method in interface stream.io.Barrel
This method removes all elements currently stored in this barrel and returns the number of elements discarded.
clear() - Method in class stream.io.BlockingQueue
 
clear() - Method in class stream.io.Hub
 
clear() - Method in class stream.io.OrderedQueue
 
clear() - Method in class stream.util.MultiSet
 
clone(Data) - Method in class stream.data.DataFactory
 
clone(Serializable) - Method in interface stream.io.Serializer
Creates a clone of the given object by serializing and de-serializing it.
clone(Serializable) - Method in class stream.util.JavaSerializer
 
close() - Method in class stream.flow.SplitByCondition
 
close() - Method in class stream.flow.SplitByRandom
 
close() - Method in class stream.io.AbstractStream
 
close() - Method in class stream.io.BlockingQueue
 
close() - Method in class stream.io.FifoInputStream
 
close() - Method in class stream.io.Hub
 
close() - Method in class stream.io.OrderedQueue
 
close() - Method in interface stream.io.QueueService
 
close() - Method in interface stream.io.Sink
This method is called by the stream runtime environment as the process container is shut down.
close() - Method in interface stream.io.Source
This method is called by the stream runtime environment as the process container is shut down.
close() - Method in class stream.urls.SSLConnection
This method closes the socket of this connection (if the socket is connected).
closed - Variable in class stream.io.BlockingQueue
 
closed - Variable in class stream.io.OrderedQueue
 
Collect - Class in stream.flow
This processor simply collects a number of items, returning null until the number is reached.
Collect() - Constructor for class stream.flow.Collect
 
compareTo(SequenceID) - Method in class stream.data.SequenceID
 
condition - Variable in class stream.ConditionedProcessor
The expression to check before processing an event
Condition - Class in stream.expressions
This class provides a string-constructor implementation for the Expression interface.
Condition(String) - Constructor for class stream.expressions.Condition
Creates a new boolean expression from the given string.
Condition - Class in stream.expressions.version2
 
Condition(String) - Constructor for class stream.expressions.version2.Condition
 
condition - Variable in class stream.expressions.version2.ConditionedProcessor
The expression to check before processing an event
condition - Variable in class stream.flow.If
 
condition - Variable in class stream.flow.SplitByCondition.RoutingEntry
 
ConditionBeginsWith - Class in stream.expressions
Instances of this class check all values for the given variable if they start with a pre-defined substring.
ConditionBeginsWith() - Constructor for class stream.expressions.ConditionBeginsWith
 
ConditionContains - Class in stream.expressions
This condition checks for equality.
ConditionContains() - Constructor for class stream.expressions.ConditionContains
 
ConditionedProcessor - Class in stream
This class is a processor that will process items only, if a given condition matches.
ConditionedProcessor() - Constructor for class stream.ConditionedProcessor
 
ConditionedProcessor - Class in stream.expressions.version2
This class is a processor that will process items only, if a given condition matches.
ConditionedProcessor() - Constructor for class stream.expressions.version2.ConditionedProcessor
 
ConditionEndsWith - Class in stream.expressions
This condition checks for equality.
ConditionEndsWith(String, String) - Constructor for class stream.expressions.ConditionEndsWith
 
ConditionFactory - Class in stream.expressions.version2
 
ConditionFactory() - Constructor for class stream.expressions.version2.ConditionFactory
 
ConditionPM - Class in stream.expressions
 
ConditionPM() - Constructor for class stream.expressions.ConditionPM
 
Configurable - Interface in stream
The Configurable interface allows having xml elements in additon to xml attributes.
configure(Element) - Method in interface stream.Configurable
This method is called with the DOM element that was used to create the instance implementing this interface.
connect() - Method in class stream.urls.Connection
This opens the connection and returns the input stream for the connection.
connect() - Method in class stream.urls.FIFOConnection
 
connect() - Method in class stream.urls.FilesConnection
 
connect() - Method in class stream.urls.SSLConnection
 
connect - Variable in class stream.urls.TcpConnection
 
connect() - Method in class stream.urls.TcpConnection
 
Connection - Class in stream.urls
This class provides an abstract connection to some data source.
Connection(SourceURL) - Constructor for class stream.urls.Connection
 
CONTAINER_CONTEXT_NAME - Static variable in interface stream.Context
This constant defines the name of the container context, i.e. when referring to elements as %{container.element-name}.
contains(Object) - Method in class stream.util.MultiSet
 
containsAll(Collection<?>) - Method in class stream.util.MultiSet
 
containsKey(Object) - Method in class stream.data.DataArrayImpl
 
containsValue(Object) - Method in class stream.data.DataArrayImpl
 
context - Variable in class stream.AbstractProcessor
The process context provided at initialization time.
Context - Interface in stream
This interface defines a general context.
Conventions - Class in stream.data
This class implements utility functions for dealing with Key conventions.
Conventions() - Constructor for class stream.data.Conventions
 
Conventions.Key - Class in stream.data
This class represents a Key element, i.e. a string that *might* have a special annotation.
copy(Data) - Static method in class stream.data.DataFactory
 
copy(URL, OutputStream) - Static method in class stream.util.URLUtilities
 
copy(InputStream, OutputStream) - Static method in class stream.util.URLUtilities
 
copy(URL, File) - Static method in class stream.util.URLUtilities
 
count - Variable in class stream.io.AbstractStream
 
count(T) - Method in class stream.util.MultiSet
 
create() - Static method in class stream.data.DataFactory
This method will create a new Data item.
create(Map<String, Serializable>) - Static method in class stream.data.DataFactory
This method will create a new Data item and will add the contents of the specified item to the newly created item.
create(String) - Method in class stream.expressions.version2.ConditionFactory
 
create(String) - Method in class stream.util.parser.ParserGenerator
 
createCopy() - Method in interface stream.Data
 
createCopy() - Method in class stream.data.DataArrayImpl
 
createCopy() - Method in class stream.data.DataImpl
 
createDataItem() - Method in class stream.data.DataFactory
This method will create a new Data item.
createDataItem(Map<String, Serializable>) - Method in class stream.data.DataFactory
This method will create a new Data item and will add the contents of the specified item to the newly created item.
createDocument(Element, String) - Static method in class stream.util.XMLUtils
 
createDocumentXML(Element, String) - Static method in class stream.util.XMLUtils
 
createIDs(InputStream, String) - Static method in class stream.util.XMLUtils
This method parses an XML document from an input-stream and adds random UUIDs to all elements of that document.
createKey(String) - Static method in class stream.data.Conventions
Creates a key from the specified string.
createKey(String, String) - Static method in class stream.data.Conventions
Creates a new key from the specified annotation and the given name.
createServiceInfo(String, Service) - Static method in class stream.service.ServiceInfo
 
createServiceInfo(String, Class<? extends Service>) - Static method in class stream.service.ServiceInfo
 

D

Data - Interface in stream
This interface defines a single data item.
data - Variable in class stream.util.MultiData
 
DATA_CONTEXT_NAME - Static variable in interface stream.Context
This constant defines the name of the data item context, i.e. when accessing attributes in a data item using the expression language.
DATA_END - Variable in class stream.expressions.version2.AbstractExpression
 
DATA_START - Variable in class stream.expressions.version2.AbstractExpression
 
DataArrayImpl - Class in stream.data
DataArrayImpl() - Constructor for class stream.data.DataArrayImpl
 
DataArrayImpl.Pair - Class in stream.data
 
DataArrayImpl.Pair(String, Serializable) - Constructor for class stream.data.DataArrayImpl.Pair
 
dataArrived(Data) - Method in interface stream.data.DataListener
Deprecated.
 
dataArrived(Data) - Method in interface stream.io.DataStreamListener
 
DataFactory - Class in stream.data
This factory class is used to create instances of the data item class.
DataFactory() - Constructor for class stream.data.DataFactory
 
DataImpl - Class in stream.data
This class is the default implementation of the Data item.
DataImpl() - Constructor for class stream.data.DataImpl
Creation of Data items should be done with DataFactory.create()
DataImpl(Map<String, Serializable>) - Constructor for class stream.data.DataImpl
Deprecated.
Creation of Data items should be done with DataFactory.create()
DataListener - Interface in stream.data
Deprecated. 
DataStreamListener - Interface in stream.io
 
DataUtils - Class in stream.data
This class provides some static convenience methods for accessing data items.
DataUtils() - Constructor for class stream.data.DataUtils
 
DAY - Static variable in class stream.util.parser.TimeParser
 
DAY_MS - Static variable in class stream.util.parser.TimeFormat
 
defaultDataFactory - Static variable in class stream.data.DataFactory
 
Delay - Class in stream.flow
A simple processor that artificially delays the data processing by a specified amount of time.
Delay() - Constructor for class stream.flow.Delay
 
Dequeue - Class in stream.flow
 
Dequeue() - Constructor for class stream.flow.Dequeue
 
Description - Annotation Type in stream.annotations
This annotation can be used to specify documentation settings for the annotated data processor implementation.
disconnect() - Method in class stream.urls.Connection
This disconnects from the source (if previously connected) and releases all resources aquired.
disconnect() - Method in class stream.urls.FIFOConnection
 
disconnect() - Method in class stream.urls.FilesConnection
 
disconnect() - Method in class stream.urls.SSLConnection
 
disconnect() - Method in class stream.urls.TcpConnection
 
divideBy(String) - Method in class stream.data.Statistics
 
divideBy(Double) - Method in class stream.data.Statistics
 
DoubleExpression - Class in stream.expressions.version2
 
DoubleExpression(String) - Constructor for class stream.expressions.version2.DoubleExpression
 

E

embedded - Variable in class stream.script.Script
 
emit(Data[]) - Method in class stream.flow.Emitter
 
emit(Data) - Method in class stream.flow.Emitter
 
Emitter - Class in stream.flow
 
Emitter() - Constructor for class stream.flow.Emitter
 
EmptyCondition - Class in stream.expressions.version2
 
EmptyCondition(String) - Constructor for class stream.expressions.version2.EmptyCondition
 
END_OF_STREAM - Static variable in interface stream.Data
 
endOfLine() - Method in class stream.expressions.ExpressionReader
 
Enqueue - Class in stream.flow
 
Enqueue() - Constructor for class stream.flow.Enqueue
 
enqueue(Data) - Method in class stream.io.BlockingQueue
 
enqueue(Data) - Method in class stream.io.Hub
 
enqueue(Data) - Method in interface stream.io.QueueService
This method will insert the given element into the queue.
entrySet() - Method in class stream.data.DataArrayImpl
 
EQ - Static variable in class stream.expressions.Operator
 
equals(Object) - Method in class stream.data.SequenceID
 
EqualsDoubleCondition - Class in stream.expressions.version2
 
EqualsDoubleCondition(Expression<Double>, Expression<Double>) - Constructor for class stream.expressions.version2.EqualsDoubleCondition
 
EqualsNullCondition - Class in stream.expressions.version2
EqualsNullCondition(Expression<Serializable>) - Constructor for class stream.expressions.version2.EqualsNullCondition
 
EqualsNullCondition(String, Expression<Serializable>) - Constructor for class stream.expressions.version2.EqualsNullCondition
 
EqualsRXCondition - Class in stream.expressions.version2
 
EqualsRXCondition(Expression<String>, Expression<String>) - Constructor for class stream.expressions.version2.EqualsRXCondition
 
EqualsStringCondition - Class in stream.expressions.version2
 
EqualsStringCondition(Expression<String>, Expression<String>) - Constructor for class stream.expressions.version2.EqualsStringCondition
 
eval(Object, Object) - Method in class stream.expressions.BinaryOperator
 
eval(Object, Object) - Method in class stream.expressions.ConditionBeginsWith
 
eval(Object, Object) - Method in class stream.expressions.ConditionContains
 
eval(Object, Object) - Method in class stream.expressions.ConditionEndsWith
 
eval(Object, Object) - Method in class stream.expressions.ConditionPM
 
Every - Class in stream.flow
 
Every() - Constructor for class stream.flow.Every
 
execute() - Method in interface stream.Process
 
exp - Variable in class stream.expressions.version2.EqualsNullCondition
 
exp - Variable in class stream.expressions.version2.NotEqualsNullCondition
 
expand(ExpressionList) - Static method in class stream.expressions.ExpressionCompiler
 
expand(String, Context, Data) - Static method in class stream.expressions.ExpressionResolver
 
expand(String) - Method in class stream.expressions.MacroExpander
 
expand(String, Map<String, ?>) - Static method in class stream.expressions.MacroExpander
 
Expression - Interface in stream.expressions
This interface defines a simple or complex filter expression.
expression - Variable in class stream.expressions.version2.AbstractExpression
 
Expression<T extends Serializable> - Interface in stream.expressions.version2
 
ExpressionCompiler - Class in stream.expressions
 
ExpressionCompiler() - Constructor for class stream.expressions.ExpressionCompiler
 
ExpressionException - Exception in stream.expressions
 
ExpressionException(String) - Constructor for exception stream.expressions.ExpressionException
 
ExpressionList - Class in stream.expressions
Implements a complex expression which ORs or ANDs multiple single filter expressions into one.
ExpressionList(BooleanOperator, Collection<Expression>) - Constructor for class stream.expressions.ExpressionList
 
ExpressionList(BooleanOperator, List<Match>) - Constructor for class stream.expressions.ExpressionList
 
ExpressionReader - Class in stream.expressions
 
ExpressionReader(String) - Constructor for class stream.expressions.ExpressionReader
 
ExpressionReader(String, Collection<String>) - Constructor for class stream.expressions.ExpressionReader
 
ExpressionReader(String, Collection<String>, Set<Operator>) - Constructor for class stream.expressions.ExpressionReader
 
ExpressionResolver - Class in stream.expressions
This class
ExpressionResolver() - Constructor for class stream.expressions.ExpressionResolver
 
ext - Variable in class stream.data.DataArrayImpl
 
extract(String[], Document) - Static method in class stream.util.XMLUtils
 
extract(String[], int, Element) - Static method in class stream.util.XMLUtils
 
extractName(String) - Static method in class stream.expressions.ExpressionResolver
 

F

FIFOConnection - Class in stream.urls
This class provides an implementation for fifo:// URLs.
FIFOConnection(SourceURL) - Constructor for class stream.urls.FIFOConnection
 
FifoInputStream - Class in stream.io
 
FifoInputStream(File) - Constructor for class stream.io.FifoInputStream
 
file - Variable in class stream.script.Script
 
FilesConnection - Class in stream.urls
 
FilesConnection(SourceURL) - Constructor for class stream.urls.FilesConnection
 
FileUtils - Class in stream.util
 
FileUtils() - Constructor for class stream.util.FileUtils
 
filter - Variable in class stream.flow.Emitter
 
filterAndEmit(Data) - Method in class stream.flow.Emitter
 
find(String, String) - Method in class stream.expressions.version2.ConditionFactory
 
findElementByUUID(Element, String, String) - Static method in class stream.util.XMLUtils
This method return an element referenced by a unique identifier.
findElementByUUID(Document, String, String) - Static method in class stream.util.XMLUtils
 
findElements(Document, XMLElementMatch) - Static method in class stream.util.XMLUtils
 
findUnits(String) - Static method in class stream.util.parser.ByteSizeParser
 
findUnits(String) - Static method in class stream.util.parser.TimeParser
 
finish() - Method in class stream.AbstractProcessor
 
finish() - Method in class stream.flow.Emitter
 
finish() - Method in class stream.flow.OnFinish
 
finish() - Method in class stream.ProcessorList
 
finish() - Method in interface stream.runtime.LifeCycle
This method is called at the end of the life cycle.
finish() - Method in interface stream.StatefulProcessor
This method is called when the last item of a stream has been processed.
firstChar(String) - Method in class stream.util.parser.MParser
 
ForEach - Class in stream.flow
This processor applies a list of nested processors to each item found in a collection of data items in some attribute of the current item.
ForEach() - Constructor for class stream.flow.ForEach
 
format(long) - Method in class stream.util.parser.TimeFormat
This method takes the given number of milliseconds, time, and creates a new String containing a description of the time by means of days, hours, minutes and seconds.

G

GB - Static variable in class stream.util.ByteSize
 
GDoubleCondition - Class in stream.expressions.version2
 
GDoubleCondition(Expression<Double>, Expression<Double>) - Constructor for class stream.expressions.version2.GDoubleCondition
 
GE - Static variable in class stream.expressions.Operator
This operators implements a 'greater than or equal' relation
GEDoubleCondition - Class in stream.expressions.version2
 
GEDoubleCondition(Expression<Double>, Expression<Double>) - Constructor for class stream.expressions.version2.GEDoubleCondition
 
GenericParser - Class in stream.util.parser
 
GenericParser(List<Token>) - Constructor for class stream.util.parser.GenericParser
 
GenericTurboParser - Class in stream.util.parser
 
GenericTurboParser(List<Token>) - Constructor for class stream.util.parser.GenericTurboParser
 
get(Object) - Method in class stream.data.DataArrayImpl
 
get(String, Map<String, ?>) - Method in class stream.expressions.MacroExpander
 
get(Context, Data) - Method in class stream.expressions.version2.AbstractExpression.ContextExpressionResolver
 
get(Context, Data) - Method in class stream.expressions.version2.AbstractExpression.DataExpressionResolver
 
get(Context, Data) - Method in class stream.expressions.version2.AbstractExpression.StaticNullExpressionResolver
 
get(Context, Data) - Method in class stream.expressions.version2.AbstractExpression.StaticStringExpressionResolver
 
get(Context, Data) - Method in class stream.expressions.version2.AndCondition
 
get(Context, Data) - Method in class stream.expressions.version2.DoubleExpression
 
get(Context, Data) - Method in class stream.expressions.version2.EmptyCondition
 
get(Context, Data) - Method in class stream.expressions.version2.EqualsDoubleCondition
 
get(Context, Data) - Method in class stream.expressions.version2.EqualsNullCondition
 
get(Context, Data) - Method in class stream.expressions.version2.EqualsRXCondition
 
get(Context, Data) - Method in class stream.expressions.version2.EqualsStringCondition
 
get(Context, Data) - Method in interface stream.expressions.version2.Expression
 
get(Context, Data) - Method in class stream.expressions.version2.GDoubleCondition
 
get(Context, Data) - Method in class stream.expressions.version2.GEDoubleCondition
 
get(Context, Data) - Method in class stream.expressions.version2.LDoubleCondition
 
get(Context, Data) - Method in class stream.expressions.version2.LEDoubleCondition
 
get(Context, Data) - Method in class stream.expressions.version2.NotEqualsDoubleCondition
 
get(Context, Data) - Method in class stream.expressions.version2.NotEqualsNullCondition
 
get(Context, Data) - Method in class stream.expressions.version2.NotEqualsRXCondition
 
get(Context, Data) - Method in class stream.expressions.version2.NotEqualsStringCondition
 
get(Context, Data) - Method in class stream.expressions.version2.OrCondition
 
get(Context, Data) - Method in class stream.expressions.version2.SerializableExpression
 
get(Context, Data) - Method in class stream.expressions.version2.StringExpression
 
get(String) - Method in interface stream.ProcessContext
Retrieves the given element from the process context.
get(Object) - Method in class stream.util.MultiData
 
get() - Method in class stream.util.MultiData
 
getAliases() - Method in class stream.expressions.Operator
 
getAndIncrement() - Method in class stream.data.SequenceID
 
getAssertionErrors() - Method in class stream.data.AssertTypes
 
getAssertionErrors() - Method in interface stream.service.AssertionService
 
getAssertions() - Method in class stream.data.AssertTypes
 
getAssertions() - Method in interface stream.service.AssertionService
 
getAttributes(Node) - Static method in class stream.util.XMLUtils
 
getBooleanOperators() - Method in class stream.expressions.ExpressionReader
 
getBytes() - Method in class stream.util.ByteSize
 
getByteSize() - Method in class stream.data.DataImpl
 
getByteSize() - Method in interface stream.Measurable
Returns the size of this object in bytes as double.
getCondition() - Method in class stream.ConditionedProcessor
 
getCondition() - Method in interface stream.expressions.HasCondition
The condition provided by this instance.
getCondition() - Method in class stream.expressions.version2.ConditionedProcessor
 
getCondition() - Method in class stream.flow.If
 
getConditions() - Method in interface stream.flow.Split
List the conditions registered at this split point.
getConditions() - Method in class stream.flow.SplitByCondition
 
getConditions() - Method in class stream.flow.SplitByRandom
 
getContent() - Method in class stream.annotations.BodyContent
 
getCount() - Method in class stream.flow.Collect
 
getDataItemsCreated() - Static method in class stream.data.DataFactory
 
getDefaults() - Method in class stream.util.parser.GenericParser
 
getDefaults() - Method in class stream.util.parser.GenericTurboParser
 
getDefaults() - Method in interface stream.util.parser.Parser
 
getElementByPath(Document, String[]) - Static method in class stream.util.XMLUtils
 
getElements() - Method in class stream.expressions.ExpressionList
 
getExpression() - Method in class stream.expressions.version2.AbstractExpression.ExpressionResolver
 
getExpression() - Method in class stream.expressions.version2.AbstractExpression
 
getExpression() - Method in interface stream.expressions.version2.Expression
 
getFile() - Method in class stream.io.SourceURL
 
getFile() - Method in class stream.script.Script
 
getFile() - Method in class stream.urls.InputStreamURL
 
getFirst() - Method in class stream.expressions.ExpressionList
 
getFrom() - Method in class stream.data.RenameKey
 
getFrom() - Method in class stream.flow.OnChange
 
getGigabyte() - Method in class stream.util.ByteSize
 
getHost() - Method in class stream.io.SourceURL
 
getHost() - Method in class stream.urls.InputStreamURL
 
getId() - Method in class stream.flow.AbstractSplit
 
getId() - Method in class stream.io.AbstractQueue
 
getId() - Method in class stream.io.AbstractStream
 
getId() - Method in class stream.io.Hub
 
getId() - Method in class stream.io.OrderedQueue
 
getId() - Method in interface stream.io.Sink
 
getId() - Method in interface stream.io.Source
 
getInput() - Method in interface stream.Process
The data source of this process.
getInputStream() - Method in class stream.io.AbstractStream
 
getInputStream() - Method in class stream.urls.SSLConnection
Returns the InputStream of the socket (if connected).
getInputStream() - Method in class stream.urls.TcpConnection
 
getInputString() - Method in class stream.expressions.ExpressionReader
 
getKey() - Method in class stream.data.DataArrayImpl.Pair
 
getKey() - Method in class stream.data.SetValue
 
getKey() - Method in class stream.data.Statistics
 
getKey() - Method in class stream.flow.Collect
 
getKey() - Method in class stream.flow.ForEach
 
getKey() - Method in class stream.flow.OnChange
 
getKeyManagerFactory() - Method in class stream.urls.SSLConnection
This method creates an uninitialized KeyManagerFactory.
getKeys(Data) - Static method in class stream.data.DataUtils
Returns the list of non-special, non-hidden keys of the given data item.
getKeys() - Method in class stream.data.RemoveKeys
 
getKeys() - Method in class stream.data.WithKeys
 
getKeys() - Method in class stream.flow.Emitter
 
getKilobyte() - Method in class stream.util.ByteSize
 
getLabel() - Method in interface stream.data.TreeNode
Returns the label value of the node.
getLimit() - Method in class stream.io.AbstractStream
 
getLimit() - Method in interface stream.io.Stream
 
getMegabyte() - Method in class stream.util.ByteSize
 
getMerge() - Method in class stream.data.WithKeys
 
getModel() - Method in interface stream.learner.ModelProvider
This method is implemented by classes providing any kind of model (prediction-model, ...).
getN() - Method in class stream.flow.Every
 
getName() - Method in class stream.data.Statistics
 
getName() - Method in interface stream.learner.Model
 
getName() - Method in interface stream.learner.PredictionService
Returns the name of the prediction (i.e. the name of the label attribute)
getName() - Method in class stream.service.ServiceInfo
 
getName() - Method in class stream.util.parser.Token
 
getOperator() - Method in class stream.expressions.ExpressionList
 
getOutput() - Method in interface stream.Process
 
getOutputStream() - Method in class stream.urls.SSLConnection
Returns the OutputStream of the socket (if connected).
getOutputStream() - Method in class stream.urls.TcpConnection
 
getParameters() - Method in class stream.io.SourceURL
 
getParameters() - Method in class stream.urls.InputStreamURL
 
getParent() - Method in interface stream.data.TreeNode
Returns the parent node of this node or null if this node is the root element.
getPassword() - Method in class stream.io.SourceURL
 
getPath() - Method in class stream.io.SourceURL
 
getPath() - Method in class stream.urls.InputStreamURL
 
getPattern() - Method in class stream.util.parser.Token
 
getPetabyte() - Method in class stream.util.ByteSize
 
getPort() - Method in class stream.io.SourceURL
 
getPort() - Method in class stream.urls.InputStreamURL
 
getPosition() - Method in class stream.expressions.ExpressionReader
 
getPrefix() - Method in class stream.io.AbstractStream
 
getProcessor() - Method in exception stream.ProcessorException
 
getProcessors() - Method in interface stream.Process
 
getProcessors() - Method in class stream.ProcessorList
Returns the list of processors executed by this class.
getProperties() - Method in interface stream.Process
 
getProtocol() - Method in class stream.io.SourceURL
 
getProtocol() - Method in class stream.urls.InputStreamURL
 
getQueue() - Method in class stream.flow.Dequeue
 
getQueues() - Method in class stream.flow.Redirect
 
getScope() - Method in class stream.data.SetValue
 
getScript() - Method in class stream.script.Script
 
getSequenceKey() - Method in class stream.io.AbstractStream
 
getService() - Method in class stream.service.Reset
 
getServiceInterfaces(Class<?>) - Static method in class stream.service.ServiceInfo
 
getServiceInterfaces(Service) - Static method in class stream.service.ServiceInfo
 
getServices() - Method in class stream.service.ServiceInfo
 
getSize() - Method in class stream.io.AbstractQueue
 
getSize() - Method in class stream.io.Hub
 
getSize() - Method in class stream.io.OrderedQueue
 
getSize() - Method in interface stream.io.Queue
Returns the maximum size of this queue implementation.
getSpecialKeys(Data) - Static method in class stream.data.DataUtils
Returns the set of special keys contained in the given data item.
getStreams() - Method in interface stream.io.multi.MultiDataStream
 
getSuccessor() - Method in class stream.io.OrderedStream.ID
 
getSupportedProtocols() - Method in class stream.urls.Connection
A list of supported protocol for the implementing class.
getSupportedProtocols() - Method in class stream.urls.FIFOConnection
 
getSupportedProtocols() - Method in class stream.urls.FilesConnection
 
getSupportedProtocols() - Method in class stream.urls.SSLConnection
 
getSupportedProtocols() - Method in class stream.urls.TcpConnection
 
getTime() - Method in class stream.flow.Delay
 
getTo() - Method in class stream.data.RenameKey
 
getTo() - Method in class stream.flow.OnChange
 
getTrustManagerFactory() - Method in class stream.urls.SSLConnection
This method creates an uninitialized TrustManagerFactory.
getTypes() - Method in class stream.data.AssertTypes
 
getUsername() - Method in class stream.io.SourceURL
 
getValue() - Method in class stream.data.DataArrayImpl.Pair
 
getValue() - Method in class stream.data.SetValue
 
getValue(int) - Method in interface stream.data.Vector
Returns the
getValue() - Method in class stream.util.parser.Token
 
getValues() - Method in interface stream.data.Vector
This method returns an array of values that has the same size as the index array returned by Vector.indexes().
GIGABYTE - Static variable in class stream.util.parser.ByteSizeParser
 
GT - Static variable in class stream.expressions.Operator
This operator implements a 'greater than' relation.

H

hasBooleanOperator() - Method in class stream.expressions.ExpressionReader
 
HasCondition - Interface in stream.expressions
This interface is provided by any implementation that can be queried for a condition.
hashCode() - Method in class stream.data.Conventions.Key
 
hasNext() - Method in class stream.io.SequentialFileInputStream
This method checks if there exists a next file in the sequence.
HIDDEN_PREFIX - Static variable in interface stream.Data
Deprecated. 
hide(String, Data) - Static method in class stream.data.DataUtils
Deprecated. 
hide(String) - Static method in class stream.data.DataUtils
Deprecated. 
host - Variable in class stream.urls.SSLConnection
 
host - Variable in class stream.urls.TcpConnection
 
HOUR - Static variable in class stream.util.parser.TimeParser
 
HOUR_MS - Static variable in class stream.util.parser.TimeFormat
 
Hub - Class in stream.io
A hub is simply a queue that dispatches incoming events to various listeners.
Hub() - Constructor for class stream.io.Hub
 
HubService - Interface in stream.io
 

I

id - Variable in class stream.io.AbstractQueue
 
id - Variable in class stream.io.AbstractStream
 
id - Variable in class stream.io.OrderedQueue
 
If - Class in stream.flow
 
If() - Constructor for class stream.flow.If
 
in - Variable in class stream.io.AbstractStream
 
increment() - Method in class stream.data.SequenceID
 
indexes() - Method in interface stream.data.Vector
This method returns a sorted array of vector indices.
indexOf(String) - Method in class stream.data.DataArrayImpl
 
init(ProcessContext) - Method in class stream.AbstractProcessor
 
init(ProcessContext) - Method in class stream.data.AssertTypes
 
init(ProcessContext) - Method in class stream.flow.Delay
 
init() - Method in class stream.flow.SplitByCondition
 
init() - Method in class stream.flow.SplitByRandom
 
init() - Method in class stream.io.AbstractStream
 
init() - Method in class stream.io.BlockingQueue
 
init() - Method in class stream.io.Hub
 
init() - Method in class stream.io.OrderedQueue
 
init() - Method in interface stream.io.Sink
Initialize the sink implementation.
init() - Method in interface stream.io.Source
This method will be called by the stream runtime at initialization time.
init(ProcessContext) - Method in class stream.ProcessorList
 
init(Context) - Method in interface stream.runtime.LifeCycle
Initializes this life cycle instance with the provided context.
init(ProcessContext) - Method in class stream.script.JavaScript
 
init(ProcessContext) - Method in class stream.script.JRuby
 
init(ProcessContext) - Method in interface stream.StatefulProcessor
This method is called at initialization time before any item is given to the processor.
inputStream - Variable in class stream.urls.FIFOConnection
 
InputStreamURL - Class in stream.urls
 
InputStreamURL(InputStream) - Constructor for class stream.urls.InputStreamURL
 
Internal - Annotation Type in stream.annotations
This annotation is used to mark a class as internal in the sense that it cannot instantiated by the ObjectFactory and be used in the XML definitions by the streams runtime environment.
isAnnotated(String) - Static method in class stream.data.Conventions
This method simply checks if a given string denotes an annotated string or not.
isAnnotation(String) - Static method in class stream.data.DataUtils
 
isBlank(String) - Static method in class stream.util.parser.MParser
 
isConnected() - Method in class stream.urls.SSLConnection
 
isDigit(String, int) - Static method in class stream.util.parser.ByteSizeParser
 
isDigit(String, int) - Static method in class stream.util.parser.TimeParser
 
isEmpty() - Method in class stream.data.DataArrayImpl
 
isEmpty() - Method in class stream.expressions.version2.Condition
 
isEmpty() - Method in class stream.expressions.version2.EmptyCondition
 
isEmpty() - Method in class stream.util.MultiData
 
isEmpty() - Method in class stream.util.MultiSet
 
isEmpty(String) - Static method in class stream.util.parser.MParser
 
isFeature(String) - Static method in class stream.data.DataUtils
 
isGzip() - Method in class stream.io.SourceURL
 
isHidden(String) - Static method in class stream.data.DataUtils
Deprecated. 
isHiddenOrSpecial(String) - Static method in class stream.data.DataUtils
 
isLeaf() - Method in interface stream.data.TreeNode
Checks whether this node is a leaf node, i.e. if it does not have any child nodes.
isMacroObject(String) - Static method in class stream.expressions.ExpressionResolver
 
isNegated() - Method in class stream.expressions.Operator
 
isNumeric(Object) - Method in class stream.expressions.BinaryOperator
 
isRegex() - Method in class stream.util.parser.Token
 
isSelected(String, String[]) - Static method in class stream.util.KeyFilter
 
isServiceImplementation(Class<?>) - Static method in class stream.service.ServiceInfo
This method checks whether the given class implements the Service interface.
isSpecial(String) - Static method in class stream.data.DataUtils
Checks if the given key is a special key.
isStrictParsing() - Method in class stream.expressions.ExpressionReader
 
isUnitChar(String, int) - Static method in class stream.util.parser.ByteSizeParser
 
isUnitChar(String, int) - Static method in class stream.util.parser.TimeParser
 
isVariable - Variable in class stream.util.parser.Token
 
isVariable() - Method in class stream.util.parser.Token
 
isVariableToken(String) - Method in class stream.util.parser.ParserGenerator
 
iterator() - Method in class stream.util.MultiSet
 

J

JavaScript - Class in stream.script
 
JavaScript() - Constructor for class stream.script.JavaScript
 
JavaSerializer - Class in stream.util
An implementation of the Serializer interface that uses the plain built-in Java serialization.
JavaSerializer() - Constructor for class stream.util.JavaSerializer
 
join(Collection<String>, String) - Static method in class stream.util.StringUtils
 
join(String[], String) - Static method in class stream.util.StringUtils
 
join(Collection<String>) - Static method in class stream.util.XMLUtils
 
JRuby - Class in stream.script
 
JRuby() - Constructor for class stream.script.JRuby
 

K

KB - Static variable in class stream.util.ByteSize
 
KEY - Static variable in class stream.annotations.BodyContent
 
key - Variable in class stream.data.SetValue
 
key - Variable in class stream.expressions.version2.AbstractExpression.ExpressionResolver
 
key - Variable in class stream.expressions.version2.AbstractExpression
 
key - Variable in class stream.util.parser.MParser.Pair
 
KeyFilter - Class in stream.util
 
KeyFilter() - Constructor for class stream.util.KeyFilter
 
keys - Variable in class stream.data.DataArrayImpl
 
keys - Variable in class stream.flow.Emitter
 
keySet() - Method in class stream.data.DataArrayImpl
 
keySet() - Method in class stream.util.MultiData
 
KILOBYTE - Static variable in class stream.util.parser.ByteSizeParser
 

L

lastIndex - Variable in class stream.flow.SplitRoundRobin
 
LDoubleCondition - Class in stream.expressions.version2
 
LDoubleCondition(Expression<Double>, Expression<Double>) - Constructor for class stream.expressions.version2.LDoubleCondition
 
LE - Static variable in class stream.expressions.Operator
This operator implement a 'less than or equal' relation.
learn(Data) - Method in interface stream.learner.Learner
Starts or continues to train a model.
Learner<M extends Model> - Interface in stream.learner
This interface defines the learning step of a machine learning algorithm.
LEDoubleCondition - Class in stream.expressions.version2
 
LEDoubleCondition(Expression<Double>, Expression<Double>) - Constructor for class stream.expressions.version2.LEDoubleCondition
 
left - Variable in class stream.expressions.version2.OperatorCondition
 
length - Variable in class stream.util.parser.Token
 
level() - Method in class stream.io.BlockingQueue
 
level() - Method in class stream.io.Hub
 
level() - Method in interface stream.io.QueueService
This method will return the current fill-level of the queue.
LifeCycle - Interface in stream.runtime
The life cycle interface defines a general life cycle of elements within a context.
limit - Variable in class stream.io.AbstractStream
 
limit - Variable in class stream.io.OrderedQueue
 
list() - Method in interface stream.service.NamingService
This method returns a list of names, registered and the service interfaces for these names.
loadKeyStore(URL, char[]) - Method in class stream.urls.SSLConnection
 
loadKeyStore(SourceURL, char[]) - Method in class stream.urls.SSLConnection
 
loadScript() - Method in class stream.script.JavaScript
 
loadScript(InputStream) - Method in class stream.script.JavaScript
 
loadScript() - Method in class stream.script.JRuby
 
loadScript(InputStream) - Method in class stream.script.JRuby
 
loadScript() - Method in class stream.script.Script
 
loadScript(InputStream) - Method in class stream.script.Script
 
loadTrustStore(URL, char[]) - Method in class stream.urls.SSLConnection
 
loadTrustStore(SourceURL, char[]) - Method in class stream.urls.SSLConnection
 
lock - Variable in class stream.io.OrderedQueue
 
LONG_FORMAT - Static variable in class stream.util.parser.TimeFormat
 
lookup(String, Class<T>) - Method in interface stream.service.NamingService
The lookup method provides the lookup of a given reference within the Lookup service.
LT - Static variable in class stream.expressions.Operator
This operator implements a 'less than' relation.

M

MACRO_END - Static variable in class stream.expressions.ExpressionResolver
 
MACRO_START - Static variable in class stream.expressions.ExpressionResolver
 
MacroExpander - Class in stream.expressions
This class performs a simple macro-expansion based on a pattern string and a ModSecurity audit-log event.
MacroExpander() - Constructor for class stream.expressions.MacroExpander
 
MacroExpander(Map<String, ?>) - Constructor for class stream.expressions.MacroExpander
 
MacroExpander(Properties) - Constructor for class stream.expressions.MacroExpander
 
main(String[]) - Static method in class stream.io.SequentialFileInputStream
 
main(String[]) - Static method in class stream.util.parser.MParser
 
mark(int) - Method in class stream.io.FifoInputStream
 
markSupported() - Method in class stream.io.FifoInputStream
 
markSupported() - Method in class stream.io.SequentialFileInputStream
 
Match - Class in stream.expressions
 
Match(String, Operator, String) - Constructor for class stream.expressions.Match
 
matches(Data) - Method in class stream.ConditionedProcessor
 
matches(Context, Data) - Method in class stream.expressions.Condition
 
matches(String, String) - Method in class stream.expressions.ConditionPM
 
matches(Context, Data) - Method in interface stream.expressions.Expression
Matches the expression against the given event.
matches(Context, Data) - Method in class stream.expressions.ExpressionList
 
matches(Context, Data) - Method in class stream.expressions.Match
 
matches(Data) - Method in class stream.expressions.version2.ConditionedProcessor
 
matches(Data) - Method in class stream.flow.If
 
matches(Data) - Method in class stream.flow.OnChange
* There are 4 use cases: 1.
matches(String) - Method in class stream.util.WildcardPattern
 
matches(String, String) - Static method in class stream.util.WildcardPattern
 
matches(Element) - Method in interface stream.util.XMLElementMatch
 
matchesSequence(File) - Method in class stream.io.SequentialFileInputStream
 
max(Map<String, Double>) - Method in class stream.data.Statistics
 
max(Double, Double) - Method in class stream.data.Statistics
 
MB - Static variable in class stream.util.ByteSize
 
MD5 - Class in stream.util
This is a small helper-class that wraps around the java md5 message-digest and computes the md5 hex-string of a given input string.
MD5() - Constructor for class stream.util.MD5
 
md5(String) - Static method in class stream.util.MD5
This method will simply return the computed MD5 sum of the given input string.
md5(byte[]) - Static method in class stream.util.MD5
This method will simply return the computed MD5 sum of the given input data.
md5(Serializable) - Static method in class stream.util.MD5
 
Measurable - Interface in stream
This interface is implemented by all processors that provide a memory measurement in number of bytes.
MEGABYTE - Static variable in class stream.util.parser.ByteSizeParser
 
MILLISECOND - Static variable in class stream.util.parser.TimeParser
 
MIN_MS - Static variable in class stream.util.parser.TimeFormat
 
MINUTE - Static variable in class stream.util.parser.TimeParser
 
mkfifo(File) - Static method in class stream.util.FileUtils
 
Model - Interface in stream.learner
This interface defines the basic structure of a model.
ModelProvider<M extends Model> - Interface in stream.learner
This is a simple "service-level" interface that is implemented by processors/service-nodes that provide a model.
MONTH - Static variable in class stream.util.parser.TimeParser
 
MParser - Class in stream.util.parser
 
MParser() - Constructor for class stream.util.parser.MParser
 
MParser.Pair<K,V> - Class in stream.util.parser
 
MParser.Pair(K, V) - Constructor for class stream.util.parser.MParser.Pair
 
MultiData - Class in stream.util
 
MultiData(int) - Constructor for class stream.util.MultiData
 
MultiDataStream - Interface in stream.io.multi
 
MultiSet<T> - Class in stream.util
 
MultiSet() - Constructor for class stream.util.MultiSet
 

N

name - Variable in class stream.data.Conventions.Key
 
name - Variable in class stream.util.parser.Token
 
NamingService - Interface in stream.service
This interface provides a service registry.
NEQ - Static variable in class stream.expressions.Operator
 
newParser() - Method in class stream.util.parser.ParserGenerator
 
nextItem - Variable in class stream.io.OrderedQueue
 
nextOut - Variable in class stream.io.OrderedQueue
 
nextValue() - Method in class stream.data.SequenceID
 
NotEqualsDoubleCondition - Class in stream.expressions.version2
 
NotEqualsDoubleCondition(Expression<Double>, Expression<Double>) - Constructor for class stream.expressions.version2.NotEqualsDoubleCondition
 
NotEqualsNullCondition - Class in stream.expressions.version2
NotEqualsNullCondition(Expression<Serializable>) - Constructor for class stream.expressions.version2.NotEqualsNullCondition
 
NotEqualsNullCondition(String, Expression<Serializable>) - Constructor for class stream.expressions.version2.NotEqualsNullCondition
 
NotEqualsRXCondition - Class in stream.expressions.version2
 
NotEqualsRXCondition(Expression<String>, Expression<String>) - Constructor for class stream.expressions.version2.NotEqualsRXCondition
 
NotEqualsStringCondition - Class in stream.expressions.version2
 
NotEqualsStringCondition(Expression<String>, Expression<String>) - Constructor for class stream.expressions.version2.NotEqualsStringCondition
 
NRX - Static variable in class stream.expressions.Operator
This operator implements a match against a regular expression.

O

OnChange - Class in stream.flow
This class provides a processorList that will be processed under certain conditions.
OnChange() - Constructor for class stream.flow.OnChange
 
OnFinish - Class in stream.flow
 
OnFinish() - Constructor for class stream.flow.OnFinish
 
OnStart - Class in stream.flow
 
OnStart() - Constructor for class stream.flow.OnStart
 
op - Variable in class stream.expressions.version2.OperatorCondition
 
open() - Method in class stream.urls.SSLConnection
 
openNextFile() - Method in class stream.io.SequentialFileInputStream
This method closes the current file an opens the next file in the sequence.
openStream() - Method in class stream.io.SourceURL
 
openStream() - Method in class stream.urls.InputStreamURL
 
Operator - Class in stream.expressions
An enumeration of available operators.
Operator(String) - Constructor for class stream.expressions.Operator
 
Operator(String, String[]) - Constructor for class stream.expressions.Operator
 
Operator<I,O extends Serializable> - Interface in stream.expressions.version2
 
OperatorCondition<I extends Serializable> - Class in stream.expressions.version2
 
OperatorCondition(Expression<I>, Expression<I>, String) - Constructor for class stream.expressions.version2.OperatorCondition
 
OPERATORS - Static variable in class stream.expressions.Operator
 
OrCondition - Class in stream.expressions.version2
 
OrCondition(Expression<Boolean>, Expression<Boolean>) - Constructor for class stream.expressions.version2.OrCondition
 
OrderedQueue - Class in stream.io
An implementation of an ordered queue of data items.
OrderedQueue() - Constructor for class stream.io.OrderedQueue
 
OrderedStream - Interface in stream.io
 
OrderedStream.ID - Class in stream.io
 
OrderedStream.ID() - Constructor for class stream.io.OrderedStream.ID
 

P

PARAM_RECONNECT - Static variable in class stream.urls.TcpConnection
 
PARAM_RECONNECT_INTERVAL - Static variable in class stream.urls.TcpConnection
 
Parameter - Annotation Type in stream.annotations
This annotation can be used to annotate class methods and define them as parameter.
parse(String) - Static method in class stream.expressions.ExpressionCompiler
 
parse(String, Collection<String>) - Static method in class stream.expressions.ExpressionCompiler
 
parse(String) - Static method in class stream.expressions.ExpressionReader
 
parse(String) - Method in class stream.util.parser.GenericParser
 
parse(String) - Method in class stream.util.parser.GenericTurboParser
 
parse(String) - Method in interface stream.util.parser.Parser
 
parse(String) - Method in class stream.util.parser.ParserGenerator
 
parseByteSize(String) - Static method in class stream.util.parser.ByteSizeParser
 
parseDocument(String) - Static method in class stream.util.XMLUtils
 
parseDocument(File) - Static method in class stream.util.XMLUtils
 
parseDocument(InputStream) - Static method in class stream.util.XMLUtils
 
ParseException - Exception in stream.util.parser
 
ParseException() - Constructor for exception stream.util.parser.ParseException
 
ParseException(String) - Constructor for exception stream.util.parser.ParseException
 
parseGrammar(String) - Method in class stream.util.parser.ParserGenerator
 
parseIntoDataItem(Document, String[]) - Static method in class stream.util.XMLUtils
 
parseIntoDataItem(Element, Data, Stack<String>) - Static method in class stream.util.XMLUtils
 
Parser<E> - Interface in stream.util.parser
This interface defines a simple parser definition.
ParserGenerator - Class in stream.util.parser
 
ParserGenerator(String) - Constructor for class stream.util.parser.ParserGenerator
 
parseTime(String) - Static method in class stream.util.parser.TimeParser
 
parseValue(String) - Static method in class stream.data.SequenceID
 
pattern - Variable in class stream.util.parser.Token
 
perform(Document) - Method in class stream.util.XIncluder
 
PETABYTE - Static variable in class stream.util.parser.ByteSizeParser
 
PM - Static variable in class stream.expressions.Operator
 
poll() - Method in class stream.io.BlockingQueue
 
poll() - Method in class stream.io.Hub
 
poll() - Method in interface stream.io.QueueService
This method removes the head of the queue.
port - Variable in class stream.urls.SSLConnection
 
port - Variable in class stream.urls.TcpConnection
 
position() - Method in class stream.util.parser.MParser
 
predict(Data) - Method in interface stream.learner.PredictionService
Performs the prediction based on the current state of the implementing class (learning algorithm).
Prediction - Class in stream.learner
 
Prediction() - Constructor for class stream.learner.Prediction
 
PREDICTION_PREFIX - Static variable in interface stream.Data
Attributes that refer to predicted values, i.e. the class of an instance predicted by some learning/prediction-model are prefixed with this string.
PredictionService - Interface in stream.learner
A stream/online learning algorithm provides any-time prediction capabilities.
prefix - Variable in class stream.io.AbstractStream
 
prefix(String, int) - Method in class stream.util.parser.MParser
 
process(Data) - Method in class stream.ConditionedProcessor
 
process(Data) - Method in class stream.data.AssertTypes
 
process(Data) - Method in class stream.data.RemoveKeys
 
process(Data) - Method in class stream.data.WithKeys
 
process(Data) - Method in class stream.expressions.version2.ConditionedProcessor
 
process(Data) - Method in class stream.flow.Collect
 
process(Data) - Method in class stream.flow.Dequeue
 
process(Data) - Method in class stream.flow.Every
 
process(Data) - Method in class stream.flow.ForEach
 
process(Data) - Method in class stream.flow.If
 
process(Data) - Method in class stream.flow.OnFinish
 
process(Data) - Method in class stream.flow.OnStart
 
process(Data) - Method in class stream.flow.Skip
 
process(Data) - Method in interface stream.learner.Model
 
process(Data) - Method in class stream.learner.Prediction
 
Process - Interface in stream
This interface defines an abstract process.
process(Data) - Method in interface stream.Processor
This is the main method for processing items.
process(Data) - Method in class stream.ProcessorList
 
process(Data) - Method in class stream.script.JavaScript
 
process(Data) - Method in class stream.script.JRuby
 
process(Data) - Method in class stream.script.Script
 
PROCESS_CONTEXT_NAME - Static variable in interface stream.Context
This constant defines the name of the process context within the expression language, e.g. when using %{process.myVariable}.
ProcessContext - Interface in stream
The process context interface defines the context provided to processors by the executing process.
processMatchingData(Data) - Method in class stream.ConditionedProcessor
 
processMatchingData(Data) - Method in class stream.data.RenameKey
 
processMatchingData(Data) - Method in class stream.data.SetValue
 
processMatchingData(Data) - Method in class stream.expressions.version2.ConditionedProcessor
 
processMatchingData(Data) - Method in class stream.flow.Delay
 
processMatchingData(Data) - Method in class stream.flow.Emitter
 
processMatchingData(Data) - Method in class stream.flow.Redirect
 
processMatchingData(Data) - Method in class stream.flow.Skip
 
processMatchingData(Data) - Method in class stream.service.Reset
 
Processor - Interface in stream
A processor is a simple function that acts on a piece of data.
ProcessorException - Exception in stream
This class extends the RuntimeException and can be fired by processors while processing events.
ProcessorException() - Constructor for exception stream.ProcessorException
 
ProcessorException(String) - Constructor for exception stream.ProcessorException
 
ProcessorException(Processor, String) - Constructor for exception stream.ProcessorException
 
ProcessorList - Class in stream
This class implements a processor that contains nested processor elements.
ProcessorList() - Constructor for class stream.ProcessorList
 
processors - Variable in class stream.ProcessorList
 
PT - Static variable in class stream.util.ByteSize
 
put(String, Serializable) - Method in class stream.data.DataArrayImpl
 
put(String, Serializable) - Method in class stream.util.MultiData
 
putAll(Map<? extends String, ? extends Serializable>) - Method in class stream.data.DataArrayImpl
 

Q

queue - Variable in class stream.io.OrderedQueue
 
Queue - Interface in stream.io
This interface is the top-level definition of queues provided within the *streams* framework.
QueueService - Interface in stream.io
 
QuotedStringTokenizer - Class in stream.util.parser
This class implements a split-method which takes care of quoted strings, i.e. there will be no split within a char sequence that is surrounded by quotes (single or double quotes).
QuotedStringTokenizer() - Constructor for class stream.util.parser.QuotedStringTokenizer
 

R

r - Variable in class stream.expressions.version2.AbstractExpression
 
random - Variable in class stream.flow.SplitByRandom
 
read(String) - Static method in enum stream.expressions.BooleanOperator
 
read(String) - Static method in class stream.expressions.Operator
 
read() - Method in class stream.io.AbstractStream
 
read() - Method in class stream.io.BlockingQueue
 
read() - Method in class stream.io.FifoInputStream
 
read() - Method in class stream.io.Hub
 
read() - Method in class stream.io.OrderedQueue
 
read() - Method in class stream.io.SequentialFileInputStream
This read method is basically a read of the current open file.
read(InputStream) - Method in interface stream.io.Serializer
Reads (de-serializes) an object from the given input stream.
read() - Method in interface stream.io.Source
Returns the next datum from this stream.
read(InputStream) - Method in class stream.util.JavaSerializer
 
readBooleanOperator() - Method in class stream.expressions.ExpressionReader
 
readContent(URL) - Static method in class stream.util.URLUtilities
 
readContentOrEmpty(URL) - Static method in class stream.util.URLUtilities
 
readFilterExpression() - Method in class stream.expressions.ExpressionReader
 
readGrammar(String) - Static method in class stream.util.parser.ParserGenerator
 
readInteger(String) - Static method in class stream.util.parser.ByteSizeParser
 
readInteger(String) - Method in class stream.util.parser.MParser
 
readInteger(String) - Static method in class stream.util.parser.TimeParser
 
readNestedExpression() - Method in class stream.expressions.ExpressionReader
 
readNext() - Method in class stream.io.AbstractStream
 
readOperator() - Method in class stream.expressions.ExpressionReader
 
readQuotedString(char) - Method in class stream.expressions.ExpressionReader
 
readResponse(InputStream) - Static method in class stream.util.URLUtilities
 
readSimpleFilter() - Method in class stream.expressions.ExpressionReader
 
readToken(String) - Method in class stream.util.parser.MParser
 
readToken(String, char, char) - Method in class stream.util.parser.MParser
 
readToken(String, int) - Static method in class stream.util.parser.MParser
 
readToken(String, int, String) - Static method in class stream.util.parser.MParser
 
readToken(String, int, char, char) - Static method in class stream.util.parser.MParser
 
readTokenUntil(String, String) - Method in class stream.util.parser.MParser
 
readUnit(String) - Static method in class stream.util.parser.ByteSizeParser
 
readUnit(String) - Static method in class stream.util.parser.TimeParser
 
readValue() - Method in class stream.expressions.ExpressionReader
 
readVariable() - Method in class stream.expressions.ExpressionReader
 
Redirect - Class in stream.flow
 
Redirect() - Constructor for class stream.flow.Redirect
 
register(DataStreamListener) - Method in class stream.io.Hub
 
register(DataStreamListener) - Method in interface stream.io.HubService
 
register(String, Service) - Method in interface stream.service.NamingService
This method registers a given Service in the naming service.
registerAlias(Operator, String) - Static method in class stream.expressions.Operator
 
registerOperator(Operator) - Static method in class stream.expressions.Operator
 
remainder(String) - Method in class stream.util.parser.MParser
 
remainingCapacity() - Method in class stream.io.BlockingQueue
 
remove(Object) - Method in class stream.data.DataArrayImpl
 
remove(Processor) - Method in interface stream.Process
 
remove(Object) - Method in class stream.util.MultiData
 
remove(Object) - Method in class stream.util.MultiSet
 
removeAll(Collection<?>) - Method in class stream.util.MultiSet
 
RemoveKeys - Class in stream.data
This class implements a data-processor that removes a bunch of keys from each processed data item.
RemoveKeys() - Constructor for class stream.data.RemoveKeys
 
RemoveKeys(String[]) - Constructor for class stream.data.RemoveKeys
 
RenameKey - Class in stream.data
This processor simply renames a single key.
RenameKey(String, String) - Constructor for class stream.data.RenameKey
 
RenameKey() - Constructor for class stream.data.RenameKey
 
reset() - Method in class stream.data.AssertTypes
 
reset() - Method in class stream.flow.OnChange
 
reset() - Method in class stream.io.BlockingQueue
 
reset() - Method in class stream.io.FifoInputStream
 
reset() - Method in class stream.io.Hub
 
Reset - Class in stream.service
 
Reset() - Constructor for class stream.service.Reset
 
reset() - Method in interface stream.service.Service
 
reset() - Method in class stream.util.parser.MParser
 
resetState() - Method in class stream.AbstractProcessor
 
resetState() - Method in interface stream.StatefulProcessor
This method can be called from outside to reset the state of the processor to what can be regarded as the state after initialization.
resolve(String) - Method in interface stream.Context
This method can be used to look up a variable in the context.
resolve(String, Context, Data) - Static method in class stream.expressions.ExpressionResolver
 
resolve(String) - Method in class stream.flow.SplitByCondition.SplitContext
 
retainAll(Collection<?>) - Method in class stream.util.MultiSet
 
right - Variable in class stream.expressions.version2.OperatorCondition
 
RX - Static variable in class stream.expressions.Operator
This operator implements a match against a regular expression.

S

scope - Variable in class stream.data.SetValue
 
Script - Class in stream.script
 
Script(ScriptEngine) - Constructor for class stream.script.Script
 
Script() - Constructor for class stream.script.Script
 
scriptEngine - Variable in class stream.script.Script
 
SEC_MS - Static variable in class stream.util.parser.TimeFormat
 
SECOND - Static variable in class stream.util.parser.TimeParser
 
select(Data, String) - Static method in class stream.util.KeyFilter
 
select(Data, String[]) - Static method in class stream.util.KeyFilter
 
seqFileStream - Variable in class stream.urls.FilesConnection
 
seqId - Variable in class stream.io.AbstractStream
 
SequenceID - Class in stream.data
This class implements a sequence element which is internally represented as a chunk of bytes (byte[] array) with ascending significance.
SequenceID() - Constructor for class stream.data.SequenceID
 
SequenceID(int) - Constructor for class stream.data.SequenceID
 
SequenceID(byte[]) - Constructor for class stream.data.SequenceID
 
sequenceKey - Variable in class stream.io.AbstractStream
 
sequenceKey - Variable in class stream.io.OrderedQueue
 
SequentialFileInputStream - Class in stream.io
This class implements an input stream that will read from a sequence of files.
SequentialFileInputStream(File) - Constructor for class stream.io.SequentialFileInputStream
Creates a new SequentialInputStream, which will read the specified file and any subsequent files that match the file's name, possibly and a appended number, i.e. for the file /tmp/test.log the stream will read /tmp/test.log /tmp/test.log.1 /tmp/test.log.2 ...
SequentialFileInputStream(File, boolean) - Constructor for class stream.io.SequentialFileInputStream
This creates a SequentialInputStream which will remove any files that have completeley been read (i.e. they have been processed until EOF and another, newer file matching the pattern does exist).
SequentialFileInputStream(File, String, boolean) - Constructor for class stream.io.SequentialFileInputStream
 
SerializableExpression - Class in stream.expressions.version2
 
SerializableExpression(String) - Constructor for class stream.expressions.version2.SerializableExpression
 
Serializer - Interface in stream.io
This interface defines an abstract serializer that provides clone and serializing/deserializing of objects.
service - Variable in class stream.service.Reset
 
Service - Interface in stream.service
This interface defines an abstract service.
ServiceInfo - Class in stream.service
This is a simple class that provides information about a service.
set(String, String) - Method in class stream.expressions.MacroExpander
 
set(String, Object) - Method in interface stream.ProcessContext
This method stores the given element in the context, possibly overwriting any existing object of the same key.
setBooleanOperators(Set<BooleanOperator>) - Method in class stream.expressions.ExpressionReader
 
setCondition(String) - Method in class stream.ConditionedProcessor
 
setCondition(String) - Method in class stream.expressions.version2.ConditionedProcessor
 
setCondition(String) - Method in class stream.flow.If
 
setContent(String) - Method in class stream.annotations.BodyContent
 
setCount(Integer) - Method in class stream.flow.Collect
 
setDefaultDataFactory(DataFactory) - Static method in class stream.data.DataFactory
This method allows for providing a customer DataFactory to produce data items.
setDefaults(Map<String, String>) - Method in class stream.util.parser.GenericParser
 
setDefaults(Map<String, String>) - Method in class stream.util.parser.GenericTurboParser
 
setDefaults(Map<String, String>) - Method in interface stream.util.parser.Parser
 
setFile(File) - Method in class stream.script.Script
 
setFrom(String) - Method in class stream.data.RenameKey
 
setFrom(String) - Method in class stream.flow.OnChange
 
setId(String) - Method in class stream.flow.AbstractSplit
 
setId(String) - Method in class stream.io.AbstractQueue
 
setId(String) - Method in class stream.io.AbstractStream
 
setId(String) - Method in class stream.io.Hub
 
setId(String) - Method in class stream.io.OrderedQueue
 
setId(String) - Method in interface stream.io.Sink
 
setId(String) - Method in interface stream.io.Source
 
setInput(Source) - Method in interface stream.Process
The data source of this process.
setKey(String) - Method in class stream.data.SetValue
 
setKey(String) - Method in class stream.data.Statistics
 
setKey(String) - Method in class stream.flow.Collect
 
setKey(String) - Method in class stream.flow.ForEach
 
setKey(String) - Method in class stream.flow.OnChange
 
setKeys(String[]) - Method in class stream.data.RemoveKeys
 
setKeys(String[]) - Method in class stream.data.WithKeys
 
setKeys(String[]) - Method in class stream.flow.Emitter
 
setKeyStore(KeyStore, char[]) - Method in class stream.urls.SSLConnection
 
setLabel(String) - Method in interface stream.data.TreeNode
This method sets the label value for the node.
setLearner(PredictionService) - Method in class stream.learner.Prediction
 
setLimit(Long) - Method in class stream.io.AbstractStream
 
setLimit(Long) - Method in interface stream.io.Stream
 
setMerge(Boolean) - Method in class stream.data.WithKeys
 
setN(Long) - Method in class stream.flow.Every
 
setName(String) - Method in class stream.data.Statistics
 
setOutput(Sink) - Method in interface stream.Process
 
setPrefix(String) - Method in class stream.io.AbstractStream
 
setQueue(QueueService) - Method in class stream.flow.Dequeue
 
setQueue(Queue) - Method in class stream.flow.Enqueue
 
setQueue(QueueService) - Method in class stream.flow.Redirect
 
setQueues(Queue[]) - Method in class stream.flow.Enqueue
 
setQueues(QueueService[]) - Method in class stream.flow.Redirect
 
setScope(String[]) - Method in class stream.data.SetValue
 
setScript(BodyContent) - Method in class stream.script.Script
 
setSequenceKey(String) - Method in class stream.io.AbstractStream
 
setService(Service) - Method in class stream.service.Reset
 
setSink(Sink) - Method in class stream.flow.Emitter
 
setSinks(Sink[]) - Method in class stream.flow.Emitter
 
setSize(Integer) - Method in class stream.io.AbstractQueue
 
setSize(Integer) - Method in class stream.io.Hub
 
setSize(Integer) - Method in class stream.io.OrderedQueue
 
setSize(Integer) - Method in interface stream.io.Queue
The maximum size the implementation of this queue is able to hold.
setSkip(Boolean) - Method in class stream.flow.Emitter
 
setStrictParsing(boolean) - Method in class stream.expressions.ExpressionReader
 
setTime(String) - Method in class stream.flow.Delay
 
setTo(String) - Method in class stream.data.RenameKey
 
setTo(String) - Method in class stream.flow.OnChange
 
setTrustStore(KeyStore, char[]) - Method in class stream.urls.SSLConnection
 
setTypes(String[]) - Method in class stream.data.AssertTypes
 
setValue(Serializable) - Method in class stream.data.DataArrayImpl.Pair
 
SetValue - Class in stream.data
This class implements a processor to set a value within a data item.
SetValue() - Constructor for class stream.data.SetValue
 
setValue(String) - Method in class stream.data.SetValue
 
setValue(int, Double) - Method in interface stream.data.Vector
 
SHORT_FORMAT - Static variable in class stream.util.parser.TimeFormat
 
sink - Variable in class stream.flow.SplitByCondition.RoutingEntry
 
Sink - Interface in stream.io
This interface specifies a sink for data, i.e. any element that can receive data items (e.g.
sinks - Variable in class stream.flow.Emitter
 
sinks - Variable in class stream.flow.SplitByRandom
 
size() - Method in class stream.data.DataArrayImpl
 
size() - Method in class stream.expressions.ExpressionList
 
size() - Method in class stream.io.BlockingQueue
 
size - Variable in class stream.util.MultiData
 
size() - Method in class stream.util.MultiData
 
size() - Method in class stream.util.MultiSet
 
SizeOf - Class in stream.util
 
SizeOf() - Constructor for class stream.util.SizeOf
 
sizeOf(Object) - Static method in class stream.util.SizeOf
 
skip - Variable in class stream.flow.Emitter
 
Skip - Class in stream.flow
This class provides a data process that will skip (i.e. return null) all data items matching a given condition.
Skip() - Constructor for class stream.flow.Skip
 
skip(long) - Method in class stream.io.FifoInputStream
 
skip(int) - Method in class stream.util.parser.MParser
 
skipBlanks(String) - Method in class stream.util.parser.MParser
 
skipLength(String) - Method in class stream.util.parser.Token
 
skipWhiteSpace() - Method in class stream.expressions.ExpressionReader
 
socket - Variable in class stream.urls.SSLConnection
 
Source - Interface in stream.io
 
SourceURL - Class in stream.io
This URL encapsulates the definition of URLs for resources.
SourceURL() - Constructor for class stream.io.SourceURL
 
SourceURL(URL) - Constructor for class stream.io.SourceURL
 
SourceURL(String) - Constructor for class stream.io.SourceURL
 
SPECIAL_PREFIX - Static variable in interface stream.Data
attributes starting with this prefix are considered special and will not be regarded for training classifiers
Split - Interface in stream.flow
This interface defines an abstract split element.
split(String, String) - Static method in class stream.util.StringUtils
 
SplitByCondition - Class in stream.flow
 
SplitByCondition() - Constructor for class stream.flow.SplitByCondition
 
SplitByCondition.RoutingEntry - Class in stream.flow
 
SplitByCondition.RoutingEntry(Condition, Sink) - Constructor for class stream.flow.SplitByCondition.RoutingEntry
 
SplitByCondition.SplitContext - Class in stream.flow
 
SplitByCondition.SplitContext() - Constructor for class stream.flow.SplitByCondition.SplitContext
 
SplitByRandom - Class in stream.flow
A split-point that randomly distributes elements uniformly among the list of registered sink.
SplitByRandom() - Constructor for class stream.flow.SplitByRandom
 
splitRespectQuotes(String, char) - Static method in class stream.util.parser.QuotedStringTokenizer
 
SplitRoundRobin - Class in stream.flow
A split-point following a round-robin strategy.
SplitRoundRobin() - Constructor for class stream.flow.SplitRoundRobin
 
ssl - Variable in class stream.urls.SSLConnection
 
SSLConnection - Class in stream.urls
 
SSLConnection(SourceURL) - Constructor for class stream.urls.SSLConnection
 
startsWith(String) - Method in class stream.expressions.ExpressionReader
 
StatefulProcessor - Interface in stream
This interface is implemented by processors requiring a context.
Statistics - Class in stream.data
 
Statistics() - Constructor for class stream.data.Statistics
 
Statistics(String) - Constructor for class stream.data.Statistics
 
Statistics(Statistics) - Constructor for class stream.data.Statistics
 
stream - package stream
 
Stream - Interface in stream.io
A simple data stream interface, producing data items.
stream.annotations - package stream.annotations
 
stream.data - package stream.data
 
stream.expressions - package stream.expressions
 
stream.expressions.version2 - package stream.expressions.version2
 
stream.flow - package stream.flow
 
stream.io - package stream.io
 
stream.io.active - package stream.io.active
 
stream.io.multi - package stream.io.multi
 
stream.learner - package stream.learner
 
stream.runtime - package stream.runtime
 
stream.script - package stream.script
 
stream.service - package stream.service
 
stream.urls - package stream.urls
 
stream.util - package stream.util
 
stream.util.parser - package stream.util.parser
 
STRICT_PARSING - Static variable in class stream.expressions.ExpressionReader
 
StringExpression - Class in stream.expressions.version2
 
StringExpression(String) - Constructor for class stream.expressions.version2.StringExpression
 
StringUtils - Class in stream.util
A set of string utility functions.
StringUtils() - Constructor for class stream.util.StringUtils
 
strip(String) - Method in class stream.util.parser.GenericParser
 
stripMacroName(String) - Static method in class stream.util.parser.ParserGenerator
 
substitute(String, Map<String, ? extends Object>) - Method in class stream.expressions.MacroExpander
 
substract(Map<String, Double>) - Method in class stream.data.Statistics
 
SX - Static variable in class stream.expressions.Operator
This operator implements a simple wildcard-match where wildcards are either '*' (matching zero or more) and '?'

T

take() - Method in class stream.io.BlockingQueue
 
take() - Method in class stream.io.Hub
 
take() - Method in interface stream.io.QueueService
 
TB - Static variable in class stream.util.ByteSize
 
TcpConnection - Class in stream.urls
A simple implementation of the abstract Connection class that supports connecting to TCP network sockets.
TcpConnection(SourceURL) - Constructor for class stream.urls.TcpConnection
 
theScript - Variable in class stream.script.Script
 
Time - Class in stream.util
This is a very simple class that represents time.
Time(String) - Constructor for class stream.util.Time
 
Time(Long) - Constructor for class stream.util.Time
 
TimeFormat - Class in stream.util.parser
This class provides some utility functions useful to format elapsed time (usually given in milliseconds).
TimeFormat() - Constructor for class stream.util.parser.TimeFormat
 
TimeFormat(int) - Constructor for class stream.util.parser.TimeFormat
 
TimeParser - Class in stream.util.parser
 
TimeParser() - Constructor for class stream.util.parser.TimeParser
 
toArray() - Method in class stream.util.MultiSet
 
toArray(T[]) - Method in class stream.util.MultiSet
 
Token - Class in stream.util.parser
 
Token(String) - Constructor for class stream.util.parser.Token
 
toSerializableExpression() - Method in class stream.expressions.version2.AbstractExpression.ExpressionResolver
 
toSerializableExpression() - Method in class stream.expressions.version2.AbstractExpression
 
toSerializableExpression() - Method in interface stream.expressions.version2.Expression
 
toString() - Method in class stream.data.Conventions.Key
 
toString() - Method in class stream.data.SequenceID
 
toString() - Method in class stream.expressions.ExpressionList
 
toString() - Method in class stream.expressions.Match
 
toString() - Method in class stream.expressions.Operator
 
toString() - Method in class stream.expressions.version2.AbstractExpression.ContextExpressionResolver
 
toString() - Method in class stream.expressions.version2.AbstractExpression.DataExpressionResolver
 
toString() - Method in class stream.expressions.version2.AbstractExpression.StaticNullExpressionResolver
 
toString() - Method in class stream.expressions.version2.AbstractExpression.StaticStringExpressionResolver
 
toString() - Method in class stream.expressions.version2.AbstractExpression
 
toString() - Method in class stream.expressions.version2.EqualsNullCondition
 
toString() - Method in class stream.expressions.version2.NotEqualsNullCondition
 
toString() - Method in exception stream.ProcessorException
 
toString() - Method in class stream.service.ServiceInfo
 
toString() - Method in class stream.urls.TcpConnection
 
toString() - Method in class stream.util.Time
 
toString(Document) - Static method in class stream.util.XMLUtils
 
TreeNode - Interface in stream.data
This interface defines a simple tree node.
trim(String, String) - Static method in class stream.util.parser.MParser
 
type() - Method in class stream.expressions.version2.AbstractExpression.ExpressionResolver
 
type() - Method in class stream.expressions.version2.Condition
 
type() - Method in class stream.expressions.version2.DoubleExpression
 
type() - Method in class stream.expressions.version2.EqualsDoubleCondition
 
type() - Method in class stream.expressions.version2.EqualsRXCondition
 
type() - Method in class stream.expressions.version2.EqualsStringCondition
 
type() - Method in interface stream.expressions.version2.Expression
 
type() - Method in class stream.expressions.version2.GDoubleCondition
 
type() - Method in class stream.expressions.version2.GEDoubleCondition
 
type() - Method in class stream.expressions.version2.LDoubleCondition
 
type() - Method in class stream.expressions.version2.LEDoubleCondition
 
type() - Method in class stream.expressions.version2.NotEqualsDoubleCondition
 
type() - Method in class stream.expressions.version2.NotEqualsRXCondition
 
type() - Method in class stream.expressions.version2.NotEqualsStringCondition
 
type() - Method in class stream.expressions.version2.SerializableExpression
 
type() - Method in class stream.expressions.version2.StringExpression
 

U

unhide(String, Data) - Static method in class stream.data.DataUtils
Deprecated. 
unregister(DataStreamListener) - Method in class stream.io.Hub
 
unregister(DataStreamListener) - Method in interface stream.io.HubService
 
unregister(String) - Method in interface stream.service.NamingService
This method removed a service from the registry.
url - Variable in class stream.io.AbstractStream
 
URLUtilities - Class in stream.util
 
URLUtilities() - Constructor for class stream.util.URLUtilities
 
uuid() - Method in class stream.data.SequenceID
 
UUID_ATTRIBUTE - Static variable in class stream.util.XMLUtils
 

V

value() - Method in class stream.data.SequenceID
 
value - Variable in class stream.data.SetValue
 
value - Variable in class stream.util.parser.MParser.Pair
 
value - Variable in class stream.util.parser.Token
 
valueOf(String) - Static method in enum stream.expressions.BooleanOperator
Returns the enum constant of this type with the specified name.
values - Variable in class stream.data.DataArrayImpl
 
values() - Method in class stream.data.DataArrayImpl
 
values() - Static method in enum stream.expressions.BooleanOperator
Returns an array containing the constants of this enum type, in the order they are declared.
VAR_PREFIX - Static variable in class stream.expressions.MacroExpander
 
VAR_SUFFIX - Static variable in class stream.expressions.MacroExpander
 
Vector - Interface in stream.data
 

W

WEEK - Static variable in class stream.util.parser.TimeParser
 
WildcardPattern - Class in stream.util
 
WildcardPattern(String) - Constructor for class stream.util.WildcardPattern
 
WithKeys - Class in stream.data
 
WithKeys() - Constructor for class stream.data.WithKeys
 
write(Data) - Method in class stream.flow.SplitByCondition
 
write(Collection<Data>) - Method in class stream.flow.SplitByCondition
 
write(Data) - Method in class stream.flow.SplitByRandom
 
write(Collection<Data>) - Method in class stream.flow.SplitByRandom
 
write(Data) - Method in class stream.flow.SplitRoundRobin
 
write(Data) - Method in class stream.io.BlockingQueue
 
write(Collection<Data>) - Method in class stream.io.BlockingQueue
 
write(Data) - Method in class stream.io.Hub
 
write(Collection<Data>) - Method in class stream.io.Hub
 
write(Data) - Method in class stream.io.OrderedQueue
 
write(Collection<Data>) - Method in class stream.io.OrderedQueue
 
write(Serializable, OutputStream) - Method in interface stream.io.Serializer
Writes (serializes) an object into the given output stream.
write(Data) - Method in interface stream.io.Sink
Writes data into the instance represented by this sink within a transaction.
write(Collection<Data>) - Method in interface stream.io.Sink
Writes the collection of data items into the queue within a single transaction.
write(Serializable, OutputStream) - Method in class stream.util.JavaSerializer
 

X

XIncluder - Class in stream.util
 
XIncluder() - Constructor for class stream.util.XIncluder
 
XMLElementMatch - Interface in stream.util
 
XMLUtils - Class in stream.util
This class provides several utility methods for pre-processing an XML stream definition document.
XMLUtils() - Constructor for class stream.util.XMLUtils
 

Y

YEAR - Static variable in class stream.util.parser.TimeParser
 
YEAR_MS - Static variable in class stream.util.parser.TimeFormat
 
A B C D E F G H I J K L M N O P Q R S T U V W X Y 

Copyright © 2013. All Rights Reserved.