Package com.streambase.sb
package com.streambase.sb
Provides classes and interfaces fundamental to the Streaming Java API.
-
ClassDescriptionModule (aka application) validation exceptionThis class represents a StreamBase blob.Represents tasks (possibly to run in the future) that can be cancelled.Determines the method StreamBase will use to expose capture fields to client code or dequeuers.A class that captures the fields of tuples on the control stream relating to HA cluster notifications.Subclass of tuple that indicates a tuple has a compiled representation for better performance.Wraps
DataTypewith ancillary information about the type (where appropriate) that's needed to actually use the DataType.Capture typeFunction typeList typeTuple typeUseful constants describing entities in the system containerstatus of a container sent on the control stream as container eventsAn enumeration that represents the types that StreamBase supports.Validate types against registered typesDirect byte array view into dataAn enumeration that represents the kinds of entities that StreamBase supports.Represents a value of type StreamBase Function.Illegal function in projection exceptionJson string key constantsSignals that some feature has not yet been implemented.Signals that some feature is not supportedSeecom.streambase.sb.expr.op.CNowOpin the server code for details on using these valuesAn exception that is thrown when a field value is requested as a primitive (e.g., Tuple.getBoolean(), Tuple.getTimestamp()), but it is null.Output schema builderFor use denoting the ParseStyle for tuple/JSON processing.Parsing exceptionUse this annotation to mark static methods as "purely functional" methods for use in StreamBase expressions.Represents a StreamBase schema as a list ofSchema.Fields, and should be used to createTupleobjects.Information (name, type, and optionally size) about a field in a Schema.A placeholder interface to add a bit of type safety to the get/setTupleClassInfo methods.A schema mismatch happenedCoercion optionsOptions used when copying SchemasA SemanticValidationException that also stores the index of the schema that caused it, when we're computing merges of schemas.A schema providerSchemaUtil.SchemaTraversal<T extends Exception>a class that can be used to traverse all nested schemas in a schemaException to indicate validation failuresSemantic validation exceptionThe base class of all StreamBase non-runtime exceptions.A StreamBase wrapper for IllegalArgumentException for use by methods that want to throw IAE in a kind of cleaner fashion.An exception that contains a list of exceptionsThe base class of all StreamBase runtime exceptions.This class contains meta data about a stream.This interface defines a contract that enables users to provide custom implementations of time used by StreamBase server It must be implemented by all Time Service classes.This class represents a Streambase Timestamp.For use denoting timestamps objects between timestamp and interval types.Timetamp to string cacheAn class that represents a Tuple of StreamBase data.A default formatter that converts each type to String using Java default String conversions.An interface containing flags returned from certain setXXXX callsThis interface is not public API, and should not be implemented by users.A TupleCaptureTransformer represents a way of converting tuples with capture fields from inside the application to tuples without capture fields, with all of the fields stored in the capture expanded out to the same level as the capture field itself.A utility class which copies the fields from one tuple to another.Options for this TupleCopierTuple manipulation errorUtilities for dealing with tuples represented in JSON format.Options for serializing JSON.The Builder class which handles the setting of tuples from JSON Data.A class that holds information about how the fields in a particular schema are laid out in memory by TupleRep.DataType.Registry machinery for Tuple.serialize(), .getTupleLength()XML interpretation exceptionXML parsing error