Package com.streambase.sb.operator
package com.streambase.sb.operator
Provides classes and interfaces to add custom operators to Streaming applications.
-
ClassDescriptionrepresent a Heap-based aggregate window (For backward compat, we can't call this HeapAggregateWindow, hence have to settle with AggregateWindow)Abstract base class for all custom java aggregate functions.A class supporting input to output tuple data transferA class to perform additional tuple initialization from input to outputAbstract base class for User code that is used as a Java Operator or an embedded Adapter in a StreamBase application.For operators supporting Artifacts, this class is used to communicate properties about them during development in Studio, and is reported to the operator immediately prior to
Operator.typecheck()
along with all other setters.Provides access to configuration information for use by operators and adapters, available from the server's configuration file.An enumeration for the different kinds of icons that StreamBase Studio may request when displaying Operators and Adapters.Included values are, in decreasing order of chattiness:Operator.LogLevel.ALL
,Operator.LogLevel.TRACE
,Operator.LogLevel.DEBUG
,Operator.LogLevel.INFO
,Operator.LogLevel.WARN
,Operator.LogLevel.ERROR
,Operator.LogLevel.OFF
.The set of runtime states that an Operator can be in.This interface is used to gain access to StreamBase Server information and facilities.A SharedObject is an object that can be shared between Operators within a Container.The state of the SharedObjectThe manager for SharedObjects within a container.Suspend behavior defines how an Operator handles tuples when it is suspended; meaning when it is in theSUSPENDED
state.Parameter interpretation exceptionInterface for the objects that hold the user-configurable parameters for Java Operators when they appear in StreamBase Studio.A record type to describe the number of input and output ports an operator has.A query that has been prepared against a table.Thrown when an operator tries to get a resource by name, but no such resource exists.Interface for consumers of table rows.Data storage methodA handle for accessing a table.A transactional memory aggregate windowThis describes the server's transaction isolation level (only meaningful for com.streambase.sb.operator.StorageMethod.TRANSACTIONAL_MEMORY)May be thrown when an error occurs during an Operator's typecheck() method.