Provides classes and interfaces to add custom operators to StreamBase applications.
Interface Summary Interface Description IResourceReader Operator.ConfigurationAccessorProvides access to configuration information for use by operators and adapters, available from the server's configuration file. Operator.RuntimeEnvironmentThis interface is used to gain access to StreamBase Server information and facilities. Operator.SharedObjectA SharedObject is an object that can be shared between Operators within a Container. Operator.SharedObjectManagerThe manager for SharedObjects within a container. ParameterizableInterface for the objects that hold the user-configurable parameters for Java Operators when they appear in StreamBase Studio. PreparedQueryA query that has been prepared against a table. RowConsumerInterface for consumers of table rows. TableAccessorA handle for accessing a table.
Class Summary Class Description AggregateWindowrepresent a Heap-based aggregate window (For backward compat, we can't call this HeapAggregateWindow, hence have to settle with AggregateWindow) BaseAggregateWindowAbstract base class for all custom java aggregate functions. OperatorAbstract base class for User code that is used as a Java Operator or an embedded Adapter in a StreamBase application. Operator.ArtifactPropertiesFor 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.
Operator.OperatorStatesThe set of runtime states that an Operator can be in. Operator.SuspendBehaviorStatesSuspend behavior defines how an Operator handles tuples when it is suspended; meaning when it is in the
PortCountsA record type to describe the number of input and output ports an operator has. TransactionalMemoryAggregateWindowA transactional memory aggregate window
Enum Summary Enum Description Operator.IconKindAn enumeration for the different kinds of icons that StreamBase Studio may request when displaying Operators and Adapters. Operator.LogLevel Operator.SharedObject.StateThe state of the SharedObject StorageMethodData storage method TransactionIsolationLevelThis describes the server's transaction isolation level (only meaningful for com.streambase.sb.operator.StorageMethod.TRANSACTIONAL_MEMORY)
Exception Summary Exception Description AlreadyRegisteredException DbConnectTypecheckException ParameterInterpretationExceptionParameter interpretation exception ResourceNotFoundExceptionThrown when an operator tries to get a resource by name, but no such resource exists. SqlTypecheckException TypecheckExceptionMay be thrown when an error occurs during an Operator's typecheck() method.