Uses of Class
com.streambase.sb.StreamBaseException
Packages that use StreamBaseException
Package
Description
Provides classes and interfaces fundamental to the LiveView Java API.
Provides classes and interfaces to add custom table providers for LiveView.
Provides classes and interfaces fundamental to the Streaming Java API.
Provides classes and interfaces to add custom adapters to Streaming applications.
Provides classes and interfaces used to communicate with a Streaming server.
Provides abstract classes to extend feedsim input sources.
Provides classes and interfaces to monitor the behavior of a running Streaming server.
Provides classes and interfaces to add custom operators to Streaming applications.
Provides classes and interfaces used to author Streaming Unit tests.
Provides classes and interfaces for interacting with the Artifact Management Server.
-
Uses of StreamBaseException in com.streambase.liveview.client
Subclasses of StreamBaseException in com.streambase.liveview.clientModifier and TypeClassDescriptionfinal class
Exception throws when the LiveView connection call is cancelled by the clientclass
An exception thrown by the LiveView Serverfinal class
Specific LiveViewException thrown when query syntax error occurs -
Uses of StreamBaseException in com.streambase.liveview.server.table.plugin
Methods in com.streambase.liveview.server.table.plugin that throw StreamBaseExceptionModifier and TypeMethodDescriptionTableProviderManager.compileLVConfs
(List<File> tableFiles, boolean buildYaml) void
TableProviderManager.createTable
(String name, com.streambase.liveview.config.model.lvconf.LiveviewConfiguration conf, boolean saveInProject) Does pre-checks, saves lvconf file and registers the table in defined state with the services layervoid
TableProviderManager.deleteTable
(com.streambase.liveview.server.table.CatalogedTable catalogedTable) void
TableProviderManager.dropTables
(List<String> tables) void
TableProviderManager.startTables
(List<String> tables) -
Uses of StreamBaseException in com.streambase.sb
Subclasses of StreamBaseException in com.streambase.sbModifier and TypeClassDescriptionclass
Module (aka application) validation exceptionclass
Signals that some feature has not yet been implemented.class
Signals that some feature is not supportedclass
An exception that is thrown when a field value is requested as a primitive (e.g., Tuple.getBoolean(), Tuple.getTimestamp()), but it is null.class
Parsing exceptionclass
A schema mismatch happenedstatic class
A SemanticValidationException that also stores the index of the schema that caused it, when we're computing merges of schemas.class
Exception to indicate validation failuresclass
Semantic validation exceptionclass
An exception that contains a list of exceptionsclass
Tuple manipulation errorclass
XML interpretation exceptionclass
XML parsing errorMethod parameters in com.streambase.sb with type arguments of type StreamBaseExceptionModifier and TypeMethodDescriptionstatic Schema
SchemaUtil.createSchema
(Element element, ByteOrder ord, SchemaUtil.SchemaProvider schemaProvider, List<StreamBaseException> errors) Create a schema from XMLMethods in com.streambase.sb that throw StreamBaseExceptionModifier and TypeMethodDescriptionvoid
Advances the service time by a certain number of time units in the future.void
TimeService.advanceTo
(long targetTimeMsec) Make the service advance to a specific time in the futureAbstractFunction.apply
(Object... args) BasicFunction.apply
(Tuple input) Applies the given arguments to this function and returns the output.Applies the given arguments to this function and returns the output.static Schema
SchemaUtil.createSchema
(String name, Schema definedHere, List<Schema> parentSchemas, com.streambase.sb.util.Location loc) Create a new schema with the given parent schemas and the given fields defined here.static Schema
SchemaUtil.createSchema
(String name, Schema definedHere, List<Schema> parentSchemas, com.streambase.sb.util.Location loc, List<StreamBaseException> storeExceptions) Create a new schema with the given parent schemas and the given fields defined here.static Schema
SchemaUtil.createSchema
(String name, Schema definedHere, List<String> parentSchemaNames, SchemaUtil.SchemaProvider provider, com.streambase.sb.util.Location loc, List<StreamBaseException> storeExceptions) Create a new schema with the given parent schema names and the given fields defined here.static Constants.ContainerState
Constants.ContainerState.decode
(int value) Decode an int value into the proper ContainerStatusstatic Constants.ContainerState
Decode a String value into the proper Container statusstatic String
TupleJSONUtil.fieldObjectToJsonString
(Schema.Field f, Object value, EnumSet<TupleJSONUtil.Options> options) static String
TupleJSONUtil.fieldObjectToJsonString
(Schema.Field f, Object value, EnumSet<TupleJSONUtil.Options> options, String timestampFormat) static Timestamp
Timestamp.fromString
(CharSequence dateString) Create a timestamp using the given stringstatic Timestamp
Timestamp.fromString
(String dateString) Create a timestamp using the given stringstatic Timestamp
Timestamp.fromString
(String dateString, com.streambase.sb.util.CSV.FormatInfo format) Create a timestamp using the given string and format.SchemaUtil.SchemaProvider.getSchemaByHash
(byte[] hash) request a schema by hashstatic Schema
Deprecated.static Schema
Create a new schemastatic Schema
Deprecated.please useSBUtils.newSchema(Element, ByteOrder)
static Schema
Create a new schemastatic StreamProperties
Create new stream properties from XML stringstatic StreamProperties
Create new stream properties from XML elementstatic com.fasterxml.jackson.databind.JsonNode
TupleJSONUtil.parseJSONString
(String json) Parse JSON string into a JSON objectHandles the processing of a JSON value into a tuple, replaces the deprecated setTupleFromJSON and setTuple methods in the API.static Tuple
TupleUtil.randomTuple
(Tuple tuple, int maxCount) Create a tuple which contains random valuesstatic Tuple
TupleUtil.randomTuple
(Tuple tuple, int maxCount, int flags) Create a tuple which contains random valuesstatic Tuple
Create a tuple which contains random valuesstatic Tuple
Create a tuple which contains random valuesstatic void
Deprecated.Use theTupleJSONUtil.SetTupleFromJSON
Builder and its .process() to handle this functionalitystatic void
Deprecated.Use theTupleJSONUtil.SetTupleFromJSON
Builder and its .process() to handle this functionalitystatic void
TupleJSONUtil.setTuple
(Tuple tuple, Object jsonObject, boolean strict, String timestampFormat, boolean numericTimestampsAsInterval) Deprecated.Use theTupleJSONUtil.SetTupleFromJSON
Builder and its .process() to handle this functionalitystatic void
TupleUtil.setTuple
(Tuple tuple, com.fasterxml.jackson.databind.JsonNode object) Set the fields of a tuple based on the contents of a JSON objectstatic void
TupleJSONUtil.setTupleFromJSON
(Tuple tuple, String JSONString) Deprecated.Use theTupleJSONUtil.SetTupleFromJSON
Builder and its .process() to handle this functionalitystatic void
TupleJSONUtil.setTupleFromJSON
(Tuple tuple, String JSONString, String timestampFormat) Deprecated.Use theTupleJSONUtil.SetTupleFromJSON
Builder and its .process() to handle this functionalitystatic void
TupleJSONUtil.setTupleFromJSON
(Tuple tuple, String JSONString, String timestampFormat, boolean numericTimestampsAsInterval) Deprecated.Use theTupleJSONUtil.SetTupleFromJSON
Builder and its .process() to handle this functionalitystatic void
TupleJSONUtil.setTupleFromJSONLoose
(Tuple tuple, String JSONString) Deprecated.Use theTupleJSONUtil.SetTupleFromJSON
Builder and its .process() to handle this functionalitystatic void
TupleJSONUtil.setTupleFromJSONLoose
(Tuple tuple, String JSONString, String timestampFormat) Deprecated.Use theTupleJSONUtil.SetTupleFromJSON
Builder and its .process() to handle this functionalitystatic void
TupleJSONUtil.setTupleFromJSONLoose
(Tuple tuple, String JSONString, String timestampFormat, boolean numericTimestampsAsInterval) Deprecated.Use theTupleJSONUtil.SetTupleFromJSON
Builder and its .process() to handle this functionalitystatic String
TupleJSONUtil.typeObjectToJsonString
(CompleteDataType cdt, Object value, EnumSet<TupleJSONUtil.Options> options) static String
TupleJSONUtil.typeObjectToJsonString
(CompleteDataType cdt, Object value, EnumSet<TupleJSONUtil.Options> options, String timestampFormat) Constructors in com.streambase.sb with parameters of type StreamBaseExceptionModifierConstructorDescriptionConstructorConstructors in com.streambase.sb that throw StreamBaseExceptionModifierConstructorDescriptionConstruct a Schema out of XML represented as a StringStreamProperties
(String xml) Create a StreamProperties from the given string representation of an XML documentStreamProperties
(Element element) Create a StreamProperties from the given XML document -
Uses of StreamBaseException in com.streambase.sb.adapter
Methods in com.streambase.sb.adapter that throw StreamBaseException -
Uses of StreamBaseException in com.streambase.sb.client
Subclasses of StreamBaseException in com.streambase.sb.clientModifier and TypeClassDescriptionclass
class
Exception thrown when a network error/problem occursclass
Exception thrown when a protocol error/problem occursclass
Exception thrown when URI parsing fails.Methods in com.streambase.sb.client that throw StreamBaseExceptionModifier and TypeMethodDescriptionString[]
StreamBaseAdminClient.addContainer
(String containerName, byte[] application, List<String> options) Add the given application to the given container in the StreamBase serverString[]
StreamBaseAdminClient.addContainer
(String containerName, File application, List<String> options) Add the given application to the given container in the StreamBase serverString[]
StreamBaseAdminClient.addContainer
(String containerName, String applicationText, List<String> options) Add the given application to the given container in the StreamBase serverString[]
XmlRpcAdmin.addContainer
(long timeoutMS, String containerName, byte[] application, List<String> containerStreamMappings) String[]
Deprecated.Replaced with application fragments and HOCON configurationString[]
Deprecated.Replaced with application fragments and HOCON configurationString[]
Deprecated.Replaced with application fragments and HOCON configurationString[]
boolean
XmlRpcAdmin.checkLicense
(long timeoutMS, String entityName) int
DequeueResult.checkStatus()
Check and return the status of this DequeueResult.protected static void
StreamBaseClient.checkValidStreamname
(String streamname) Validate stream nameStreamBaseAdminClient.clearEvalCache
(String containerName) Clear evaluation cacheXmlRpcAdmin.clearEvalCache
(long timeoutMS, String containerName) void
StreamBaseClient.close()
void
Flush all buffers and close the connection to the StreamBase server.DeMUXStreamBaseClient.dequeue()
DeMUXStreamBaseClient.dequeue
(long timeoutMS) StreamBaseClient.dequeue()
Dequeue a batch of tuples from a subscribed stream.StreamBaseClient.dequeue
(long timeoutMS) Dequeue a batch of tuples from a subscribed stream.Return an XML description of a StreamBase entityXmlRpcAdmin.describe
(long timeoutMS, String entityName) void
StreamBaseAdminClient.drain()
Drain a StreamBase Server Has no effect if the server is not runningvoid
Drain a container within a StreamBase Server Has no effect if the server is not runningvoid
XmlRpcAdmin.drain
(long timeoutMS, String containerName) void
StreamBaseClient.enableBuffering
(int bufferSize) Turn on buffering with a default WakeAndFlushBuffer thread set to 250msvoid
StreamBaseClient.enableBuffering
(int bufferSize, long flushIntervalMilliSeconds) Turn on buffering.void
StreamBaseClient.enqueue
(StreamProperties props, Tuple tuple) Enqueue a single Tuple onto a stream.void
StreamBaseClient.enqueue
(StreamProperties props, Collection<Tuple> tuples) Enqueue a collection of Tuples onto a stream.void
Enqueue a single Tuple onto a stream.void
StreamBaseClient.enqueue
(String stream, Collection<Tuple> tuples) Enqueue a collection of Tuples onto a stream.void
XmlRpcAdmin.enqueue
(long timeoutMS, StreamProperties props, Collection<String> tuples) void
StreamBaseAdminClient.fastForwardTime
(String msecs) Fast forward timevoid
XmlRpcAdmin.fastForwardTime
(long timeoutMS, Object msecs) void
StreamBaseClient.flushAllBuffers()
Flush any pending enqueue buffers.void
StreamBaseClient.flushBuffer
(StreamProperties props) Deprecated.useStreamBaseClient.flushAllBuffers()
to preserve inter-stream orderingvoid
StreamBaseClient.flushBuffer
(String stream_name) Deprecated.useStreamBaseClient.flushAllBuffers()
to preserve inter-stream orderingStreamBaseClient.getAllStreamProperties
(EntityType type) Return all the StreamProperties available.StreamBaseClient.getAllStreamProperties
(EntityType type, CaptureTransformStrategy strategy) Return all the StreamProperties availableXmlRpcAdmin.getByteOrder
(long timeoutMS) StreamBaseClient.getDynamicVariable
(String dynamicVariablePath) Get the given dynamic variableXmlRpcAdmin.getDynamicVariableField
(long timeoutMS, com.streambase.sb.util.Path dynvarPath) StreamBaseClient.getDynamicVariables
(String modulePath) Get a Tuple of all the dynamic variables on the given moduleXmlRpcAdmin.getDynamicVariables
(long timeoutMS, com.streambase.sb.util.Path modulePath) StreamBaseAdminClient.getEvalCacheContent
(String containerName) Get evaluation cache contentXmlRpcAdmin.getEvalCacheContent
(long timeoutMS, String containerName) StreamBaseAdminClient.getMapperCacheContent
(String containerName) Get mapper cache contentsXmlRpcAdmin.getMapperCacheContent
(long timeoutMS, String containerName) XmlRpcAdmin.getNamesForContainer
(long timeoutMS, int id) String[]
StreamBaseAdminClient.getOperatorProperties
(String operatorName) For the given Operator, return its set of properties and their values.String[]
XmlRpcAdmin.getOperatorProperties
(long timeoutMS, String operatorName) StreamBaseAdminClient.getOperatorProperty
(String operatorName, String propertyName) Return the value of the given property on the given Operator.StreamBaseClient.getSchemaByHash
(byte[] hash) Return the Schema object for the given hash valueXmlRpcAdmin.getSchemaByHash
(long timeoutMS, byte[] hash) StreamBaseClient.getSchemaByName
(String name) Return the Schema object for the given name.XmlRpcAdmin.getSchemaByName
(long timeoutMS, String schemaName) StreamBaseClient.getSchemaForStream
(String streamName) Return the schema of a stream.StreamBaseClient.getStreamProperties
(String streamName) Return the StreamProperties for the given stream nameStreamBaseClient.getStreamProperties
(String streamName, CaptureTransformStrategy strategy) Return the StreamProperties for the given stream nameXmlRpcAdmin.getStreamProperties
(long timeoutMS, String streamName) XmlRpcAdmin.getStreamProperties
(long timeoutMS, String streamName, CaptureTransformStrategy strategy) StreamBaseClient.getStreamPropertiesByHash
(byte[] hash) Return the StreamProperties for the given hash StreamProperties are cached locally in the client.StreamBaseClient.getStreamPropertiesByHash
(String hashHexString) Return the StreamProperties for the given hash StreamProperties are cached locally in the client.XmlRpcAdmin.getStreamPropertiesByHash
(long timeoutMS, byte[] hash) StreamBaseAdminClient.getTargetTime()
Get target timeXmlRpcAdmin.getTargetTime
(long timeoutMS) static SSLSocketFactory
SSLUtils.initSSL()
static SSLSocketFactory
String[]
XmlRpcAdmin.internalCommand
(long timeoutMS, String... args) String[]
StreamBaseAdminClient.killAllConnections()
Kill all of the connections on the serverString[]
XmlRpcAdmin.killAllConnections
(long timeoutMS) String[]
StreamBaseAdminClient.killConnection
(byte[] connectionId) Kill the connection with the given connectionIdString[]
XmlRpcAdmin.killConnection
(long timeoutMS, byte[] connectionId) String[]
StreamBaseAdminClient.listConnections
(StreamBaseAdminClient.ListConnectionArgument... args) Return an array of client connectionsString[]
XmlRpcAdmin.listConnections
(long timeoutMS, StreamBaseAdminClient.ListConnectionArgument... args) String[]
StreamBaseAdminClient.listEntities
(String entityType, int flags) Return an array of entity names for the given entity typeString[]
StreamBaseClient.listEntities
(EntityType entityType) Return an array of entity names for the given entity type.String[]
StreamBaseClient.listEntities
(EntityType entityType, int flags) Return an array of entity names for the given entity type and flags.String[]
StreamBaseClient.listEntities
(EntityType entityType, int flags, CaptureTransformStrategy strategy) Return an array of entity names for the given entity type and flags.String[]
StreamBaseClient.listEntities
(EntityType entityType, CaptureTransformStrategy strategy) Return an array of entity names for the given entity type.String[]
StreamBaseClient.listEntities
(String entityPath, int flags) Return an array of entity names for the given entity path.String[]
StreamBaseClient.listEntities
(String entityPath, int flags, CaptureTransformStrategy strategy) Return an array of entity names for the given entity path.String[]
XmlRpcAdmin.listEntities
(long timeoutMS, String entityType, int flags) Return an array of entity names for the given entity typeString[]
XmlRpcAdmin.listEntities
(long timeoutMS, String entityType, int flags, CaptureTransformStrategy strategy) static SSLContext
SSLUtils.makeClientSSLContext()
static SSLContext
SSLUtils.makeClientSSLContext
(boolean debug) static SSLContext
static com.streambase.sb.client.TupleIO
TupleIOFactory.makeTupleIO
(StreamBaseURI uri, ClientSettings settings) String[]
StreamBaseAdminClient.manageJdbcConnections
(List<String> args) Manage JDBC connections: count [name]Count the open JDBC connections to the named data source (or all data sources if ommitted) close [name]Close any open JDBC connections to the named data source (or all data sources if ommitted)String[]
void
XmlRpcAdmin.modifyApplication
(long timeoutMS, byte[] application) Modify the StreamBase Server with the given StreamBase application.String[]
StreamBaseAdminClient.modifyContainer
(String containerName, List<String> options) Modifies the given container.String[]
String[]
XmlRpcAdmin.operatorStatus
(long timeoutMS, String containerName) static String[]
XmlRpcAdmin.processListConnections
(CharSequence xmlListConnections) process the XML document that is the result of a LIST_CONNECTIONS callReturn rows from a Query Table or Materialized Window.Return rows from a Query Table or Materialized Window, applying an optional predicate to decide which rows are returned.String[]
StreamBaseAdminClient.removeContainer
(String containerName, String... args) Remove the given container in the StreamBase serverString[]
String[]
StreamBaseAdminClient.restartContainer
(String containerName) Restart a containerString[]
XmlRpcAdmin.restartContainer
(long timeoutMS, String containerName) void
StreamBaseAdminClient.restartOperators
(List<String> operatorNames) Restart the given Operators on the StreamBase server.void
DeMUXStreamBaseClient.resubscribe
(StreamProperties props, String logicalstream, String predicate) DeMUXStreamBaseClient.resubscribe
(String streamname, String logicalstream, String predicate) StreamBaseClient.resubscribe
(StreamProperties props, String logicalStream, String predicate) Resubscribe to a stream with a predicate.StreamBaseClient.resubscribe
(String streamname, String logicalstream, String predicate) Resubscribe to a stream with a predicate.void
Resume a container in a StreamBase servervoid
XmlRpcAdmin.resume
(long timeoutMS, String containerName) void
StreamBaseAdminClient.resumeOperators
(List<String> operatorNames) Resume the given Operators on the StreamBase servervoid
void
StreamBaseClient.setDynamicVariable
(String dynvarPath, Object value) Set the given dynamic variable to a new valuevoid
XmlRpcAdmin.setDynamicVariable
(long timeoutMS, com.streambase.sb.util.Path dynamicVariablePath, Object value) void
StreamBaseAdminClient.setOperatorProperty
(String operatorName, String propertyName, String value) On the given Operator, set the given property to the given value.void
XmlRpcAdmin.setOperatorProperty
(long timeoutMS, String operatorName, String propertyName, String value) void
StreamBaseClient.setQuiescentLimit
(long timeoutMS) If more then timeoutMS milliseconds elapse without receiving data or a heart beat from the server, the client will close.void
TupleConnection.setQuiescentLimit
(long timeoutMS) Set heartbeat timeout valuevoid
StreamBaseAdminClient.setRuntimeParam
(String paramName, String paramValue, String operator) Set a runtime parameter on one, or all, operators.void
StreamBaseAdminClient.shutdown()
Shutdown a StreamBase serverShutdown a container within a StreamBase serverXmlRpcAdmin.shutdown
(long timeoutMS, String containerName) void
StreamBaseAdminClient.shutdownOperators
(List<String> operatorNames) Shut down the given Operators on the StreamBase server.void
String[]
XmlRpcAdmin.status
(long timeoutMS, boolean verbose) DeMUXStreamBaseClient.subscribe
(StreamProperties props) DeMUXStreamBaseClient.subscribe
(StreamProperties props, String logicalstream, String predicate) DeMUXStreamBaseClient.subscribe
(String streamName, CaptureTransformStrategy strategy) DeMUXStreamBaseClient.subscribe
(String streamName, CaptureTransformStrategy strategy, String logicalstream, String predicate) DeMUXStreamBaseClient.subscribe
(String streamName, String logicalStream, String predicate, DeMUXStreamBaseClient.DequeueListener listener) This is the only subscribe operation that is supported by the DeMUXStreamBaseClientStreamBaseClient.subscribe
(StreamProperties props) Subscribe to a streamStreamBaseClient.subscribe
(StreamProperties props, String logicalStream, String predicate) Subscribe to a stream with a predicate.Subscribe to a streamStreamBaseClient.subscribe
(String streamName, CaptureTransformStrategy strategy) Subscribe to a streamStreamBaseClient.subscribe
(String streamName, CaptureTransformStrategy strategy, String logicalstream, String predicate) Subscribe to a stream with a predicate.Subscribe to a stream with a predicate.List
<?> XmlRpcAdmin.subscribe
(long timeoutMS, com.streambase.sb.client.SubscriptionEntry subscription) Subscribecom.streambase.sb.client.SubscriptionEntry
XmlRpcAdmin.subscribe
(long timeoutMS, com.streambase.sb.client.SubscriptionEntry subscription, List<com.streambase.sb.client.TupleConnections.StreamTupleConnection> connections) com.streambase.sb.client.SubscriptionEntry
TupleConnection.subscribeInternalControl
(long timeoutMS) Subscribe internal control streamvoid
Suspend (pause) a container or operator within a StreamBase Servervoid
XmlRpcAdmin.suspend
(long timeoutMS, String name) void
StreamBaseAdminClient.suspendOperators
(List<String> operatorNames) Suspend (pause) the given Operators on the StreamBase Servervoid
Typecheck (validate) the given StreamBase Application.Typecheck (validate) the given StreamBase Application.XmlRpcAdmin.typecheck
(long timeoutMS, String application, boolean full) void
DeMUXStreamBaseClient.unsubscribe
(StreamProperties logicalProps) void
DeMUXStreamBaseClient.unsubscribe
(String logicalStreamName) void
StreamBaseClient.unsubscribe
(StreamProperties logicalProps) Unsubscribe from the given stream name.void
StreamBaseClient.unsubscribe
(String logicalStreamName) Unsubscribe from the given stream name.void
XmlRpcAdmin.unsubscribe
(long timeoutMS, StreamProperties props, String logicalstream, List<com.streambase.sb.client.TupleConnections.StreamTupleConnection> connections) void
Unsubscribe a streamprotected void
StreamBaseClient.unsubscribeInternal
(StreamProperties logicalProps) Un-subscribe from streamConstructors in com.streambase.sb.client that throw StreamBaseExceptionModifierConstructorDescriptionDeMUXStreamBaseClient
(StreamBaseURI streamBaseURI) ConstructorConstructorDeMUXStreamBaseClient
(List<StreamBaseURI> uris, ClientSettings settings) ConstructorSSLSocketWrapper
(StreamBaseURI uri, ClientSettings settings) Create a StreamBaseAdminClient.Create a StreamBaseAdminClient, connecting to the server at the provided URI.Create a StreamBaseAdminClient.Create a StreamBaseAdminClient.StreamBaseAdminClient
(List<StreamBaseURI> uris, ClientSettings settings) Create a StreamBaseAdminClient.Create a StreamBaseClient.Create a StreamBaseClient, connecting to the server at the provided URIStreamBaseClient
(String uriStrings) Create a StreamBaseClient from one or more comma-separated URI stringsStreamBaseClient
(List<StreamBaseURI> uris) Create a StreamBaseClient, connecting to the servers at the provided URIs.StreamBaseClient
(List<StreamBaseURI> uris, ClientSettings settings) Create a StreamBaseClient, connecting to the servers at the provided URIs. -
Uses of StreamBaseException in com.streambase.sb.expr
Subclasses of StreamBaseException in com.streambase.sb.exprModifier and TypeClassDescriptionclass
com.streambase.sb.expr.ExprException
Semantic exception parsing an expression. -
Uses of StreamBaseException in com.streambase.sb.feedsim
Methods in com.streambase.sb.feedsim that throw StreamBaseException -
Uses of StreamBaseException in com.streambase.sb.monitor
Methods in com.streambase.sb.monitor that throw StreamBaseExceptionModifier and TypeMethodDescriptionstatic String
StatsUtil.getName
(StatsUtil.IdentityHelper helper, com.streambase.sb.monitor.StatTuplev3 st) Fetch the item name using the clientStatsUtil.IdentityHelper.getName
(com.streambase.sb.monitor.StatTuplev3 st) StatsUtil.IdentityHelper.getNameFromId
(long id) Stats Stream v3 only.StatsUtil.IdentityHelper.IdentityUpdater.getUpdateByContainerId
(int containerId) void
StreamBaseMonitor.run()
Read and process monitor snapshots from sbd.static String
StatsUtil.toName
(StatsUtil.IdentityHelper helper, long id) Constructors in com.streambase.sb.monitor that throw StreamBaseExceptionModifierConstructorDescriptionStreamBaseMonitor
(StreamBaseClient client) Create a monitoring object, which will connect to a server with the given StreamBaseClient object.StreamBaseMonitor
(StreamBaseClient sbClient, String streamName) ConstructorCreate a monitoring object, which will connect to a server with the given StreamBase URI.StreamBaseMonitor
(String uri) Create a monitoring object The given uri can either be a StreamBaseURI or a filename. -
Uses of StreamBaseException in com.streambase.sb.operator
Subclasses of StreamBaseException in com.streambase.sb.operatorModifier and TypeClassDescriptionclass
Shared object already registeredfinal class
A typecheck exception associated with an Operator property (or parameter) by name.class
Parameter interpretation exceptionclass
Thrown byOperator.requireInputPortCount(int)
when the required input port count doesn't match the actual input port count.class
Thrown when an operator tries to get a resource by name, but no such resource exists.class
May be thrown when an error occurs during an Operator's typecheck() method.Methods in com.streambase.sb.operator that throw StreamBaseExceptionModifier and TypeMethodDescriptionvoid
void
Override this method to consume rows.Delete a row in the table based on primary key.evaluate the given string expression in the context of the running module If an error occurs during the evaluation, the message return value will be a string containing the error messagevoid
PreparedQuery.execute
(CompiledTuple args, RowConsumer consumer) Run the query against a given set of arguments, and pass the results toconsumer
void
PreparedQuery.execute
(CompiledTuple args, TableAccessor table, RowConsumer consumer) Execute the queryvoid
ITupleDataInitializer.fillOutputTuple
(Tuple inputTuple, Tuple outputTuple, ITupleDataInitializer.ITupleHandler handler) Fill the output tuple from the input value, process the tuple handler to updated additional fields in the output.Operator.getDataSourceConnection
(String datasource) Retrieve a connection to a JDBC Data Source configured in HOCON configuration files.IResourceReader.getResourceContents
(String name) Read resource contentsOperator.getResourceContents
(String name) Returns an open input stream on the contents of the named resource file.IResourceReader.getResourceFile
(String name) Get resource fileOperator.getResourceFile
(String name) Returns aFile
pointing to the regular file or directory if it exists.Operator.getTableAccessor
(String name) Get a TableAccessor for a table in the local module by name of that table.Operator.getTupleCaptureTransformer
(Schema s) Get a TupleCaptureTransformer capable of translating tuples with the given schema to the equivalent schema with all the capture fields expanded out, and translating expanded tuples back into tuples with the given schemavoid
Operator.init()
After the Operator has typechecked successfully, but before the application or any managed threads start, the StreamBase server will call the init method.void
Insert a new row into the table.default Tuple
ITupleDataInitializer.newOutputTuple
(Tuple inputTuple) Deprecated.Use a combination ofITupleDataInitializer.newOutputTuple()
andITupleDataInitializer.fillOutputTuple(Tuple, Tuple, ITupleHandler)
default Tuple
ITupleDataInitializer.newOutputTuple
(Tuple inputTuple, ITupleDataInitializer.ITupleHandler handler) Deprecated.Use a combination ofITupleDataInitializer.newOutputTuple()
andITupleDataInitializer.fillOutputTuple(Tuple, Tuple, ITupleHandler)
Operator.newTupleDataInitializer
(int inputPort, int outputPort) Create a newITupleDataInitializer
based on the specified input and output ports.void
ITupleDataInitializer.populateOutputTuple
(Tuple inputTuple, Tuple outputTuple) Populate the ouptu tuple from the input value (no clearing done on output before filling, and no clearing done on the input tuple at the end)Prepare an index-accessing query.abstract void
Operator.processTuple
(int inputPort, Tuple tuple) This method will be called by the StreamBase server for each Tuple given to the Operator to process.TableAccessor.readPrimary
(Tuple pkey) Read a row from the table by primary key.final void
Operator.registerRunnable
(Runnable operatorRunnable) Deprecated.As of StreamBase version 3.7, replaced byOperator.registerRunnable(Runnable, boolean)
final void
Operator.registerRunnable
(Runnable operatorRunnable, boolean shouldInterrupt) Register a Runnable object to be managed by this Operator.final void
Operator.registerRunnable
(String runnableName, Runnable operatorRunnable, boolean shouldInterrupt) Register a Runnable object to be managed by this Operator.final void
Operator.registerRunnable
(String runnableName, Runnable operatorRunnable, boolean shouldInterrupt, boolean synchronizedShutdown) Register a Runnable object to be managed by this Operator.void
Operator.SharedObjectManager.registerSharedObject
(Object key, Operator.SharedObject value) Add the given SharedObject to this Container.Replace a row in the table, or insert if there is no existing row with matching primary key.void
Operator.SharedObject.resumeObject()
Resume the SharedObject.void
Operator.sendOutput
(int port, Tuple tuple) Enqueue a Tuple to be sent synchronously to downstream operators.void
Operator.sendOutput
(int port, List<Tuple> tuples) Enqueue a List of Tuples to be sent synchronously to downstream operators.void
Operator.sendOutputAsync
(int port, Tuple tuple) Enqueue a Tuple to be sent asynchronously to downstream operators.void
Operator.sendOutputAsync
(int port, List<Tuple> tuples) Enqueue a List of Tuples to be sent asynchronously to downstream operators.void
Operator.setDynamicVariable
(String name, Object value) Sets the value of this module's dynamic variable.static void
Operator.setLogLevel
(org.slf4j.Logger logger, Operator.LogLevel level) Sets the log level of the given logger.static void
Operator.setLogLevel
(org.slf4j.Logger logger, String level) Sets the log level of the given logger.void
Operator.SharedObject.shutdownObject()
Shutdown the SharedObject.void
Operator.SharedObject.startObject()
Start the SharedObject.void
Operator.SharedObject.suspendObject()
Suspend the SharedObject.void
TableAccessor.truncate()
Truncate the table, by removing all rowsConstructors in com.streambase.sb.operator with parameters of type StreamBaseException -
Uses of StreamBaseException in com.streambase.sb.unittest
Methods in com.streambase.sb.unittest that throw StreamBaseExceptionModifier and TypeMethodDescriptionboolean
boolean
FieldBasedTupleComparator.CompareFunctor.compare
(TupleComparator comparator, CompleteDataType cdt, Object expected, Object actual) boolean
Compare two tuples.abstract boolean
FieldBasedTupleComparator.CompareFunctor.compareImpl
(TupleComparator comparator, CompleteDataType cdt, Object expected, Object actual) Compare two values expected and actual, usingcomparator
for recursion as necessary.boolean
FieldBasedTupleComparator.ListCompareFunctor.compareImpl
(TupleComparator comparator, CompleteDataType cdt, Object expected, Object actual) boolean
FieldBasedTupleComparator.TupleCompareFunctor.compareImpl
(TupleComparator comparator, CompleteDataType cdt, Object expected, Object actual) boolean
FieldBasedTupleComparator.compareValues
(CompleteDataType cdt, Object expected, Object actual) boolean
TupleComparator.compareValues
(CompleteDataType cdt, Object expected, Object actual) Compare two values withCompleteDataType
cdt.abstract Tuple
AbstractTupleMaker.createTuple
(Schema schema, T t) CSVTupleMaker.createTuple
(Schema schema, String str) JSONSingleQuotesTupleMaker.createTuple
(Schema schema, String str) JSONTupleMaker.createTuple
(Schema schema, String str) ObjectArrayTupleMaker.createTuple
(Schema schema, Object[] objs) TupleMaker.createTuple
(Schema schema, T t) create aTuple
s from an input objectAbstractTupleMaker.createTuples
(Schema schema, Collection<T> ts) AbstractTupleMaker.createTuples
(Schema schema, T... ts) TupleMaker.createTuples
(Schema schema, Collection<T> t) create multipleTuple
s from input objectsTupleMaker.createTuples
(Schema schema, T... t) create multipleTuple
s from input objectsDequeuer.dequeue
(int numTuples) Try to dequeue tuples with theDequeuer.DEFAULT_TIMEOUT
andDequeuer.DEFAULT_TIMEOUT_UNIT
if numTuples == 0 will return immediately if numTuples < 0 will wait the maximum timeout before returningTry to dequeue tuples within a provided timeout.void
Dequeuer.drain()
Drain any tuples that are currently in flight in the server.void
SBServerManager.drain()
Wait for processing to complete on all currently enqueued tuples.void
Enqueue Tuple to the streamvoid
Enqueue multiple tuples to the stream<T> void
Enqueuer.enqueue
(TupleMaker<T> tupleMaker, List<T> t) Create multiple tuples using aTupleMaker
and then enqueue them.<T> void
Enqueuer.enqueue
(TupleMaker<T> tupleMaker, T t) Create a tuple using aTupleMaker
and then enqueue it.<T> void
Enqueuer.enqueue
(TupleMaker<T> tupleMaker, T... t) Create multiple tuples using aTupleMaker
and then enqueue them.void
Enqueue multiple tuples to the streamvoid
Expect a tuple from the dequeuer.void
Expect multiple tuples in a particular order from the dequeuer.void
Expecter.expect
(Expecter.DequeueSetting mode, Tuple expected) Expect a given tuple from the dequeuervoid
Expecter.expect
(Expecter.DequeueSetting mode, Tuple... tuples) Expect multiple tuples in a particular order from the dequeuer<T> void
Expecter.expect
(Expecter.DequeueSetting mode, TupleMaker<T> tupleMaker, List<T> t) Expect a tuple from the dequeuer<T> void
Expecter.expect
(Expecter.DequeueSetting mode, TupleMaker<T> tupleMaker, T t) Expect a tuple from the dequeuer<T> void
Expecter.expect
(Expecter.DequeueSetting mode, TupleMaker<T> tupleMaker, T... t) Expect a tuple from the dequeuervoid
Expecter.expect
(Expecter.DequeueSetting mode, List<Tuple> expected) Expect multiple tuples in a particular order from the dequeuer<T> void
Expecter.expect
(TupleMaker<T> tupleMaker, List<T> t) Expect multiple tuples in a particular order from the dequeuer.<T> void
Expecter.expect
(TupleMaker<T> tupleMaker, T t) Expect a tuple from the dequeuer.<T> void
Expecter.expect
(TupleMaker<T> tupleMaker, T... t) Expect multiple tuples in a particular order from the dequeuer.void
Expect multiple tuples in a particular order from the dequeuer.void
Expecter.expectNothing()
Expect no tuples to be available on the stream, while ensuring that the server has time to process any tuples that are currently in flight.void
Expecter.expectNothing
(long time, TimeUnit unit) Expect no tuples to be available on the stream, while ensuring that the server has time to process any tuples that are currently in flight.void
Expecter.expectPredicate
(Expecter.DequeueSetting mode, Expecter.Predicate p) Expect a tuple that fulfills the given predicate from the dequeuervoid
Expecter.expectPredicate
(Expecter.DequeueSetting mode, List<Expecter.Predicate> expected) Expect a number of tuples, each fulfilling one predicate in a list, from the Dequeuervoid
Expecter.expectUnordered
(Tuple... expected) Expect multiple tuples in any order from the dequeuer.void
Expecter.expectUnordered
(Expecter.DequeueSetting mode, Tuple... expected) Expect multiple tuples in any order from the dequeuer<T> void
Expecter.expectUnordered
(Expecter.DequeueSetting mode, TupleMaker<T> tupleMaker, List<T> t) Expect multiple tuples in any order from the dequeuer<T> void
Expecter.expectUnordered
(Expecter.DequeueSetting mode, TupleMaker<T> tupleMaker, T... t) Expect multiple tuples in any order from the dequeuervoid
Expecter.expectUnordered
(Expecter.DequeueSetting mode, List<Tuple> expected) Expect multiple tuples in any order from the dequeuer<T> void
Expecter.expectUnordered
(TupleMaker<T> tupleMaker, List<T> t) Expect multiple tuples in any order from the dequeuer.<T> void
Expecter.expectUnordered
(TupleMaker<T> tupleMaker, T... t) Expect multiple tuples in any order from the dequeuer.void
Expecter.expectUnordered
(List<Tuple> expected) Expect multiple tuples in any order from the dequeuer.void
Expecter.expectUnorderedPredicate
(Expecter.DequeueSetting mode, List<Expecter.Predicate> expected) Expect tuples that fulfill multiple predicates in any order from the dequeuerBaseTestEnvironment.getConf()
SBTestEnvironment.getConf()
SBServerManager.getDequeuer
(String path) Get the Tuple dequeue object for a streamstatic SBServerManager
ServerManagerFactory.getEmbeddedServer()
static SBServerManager
ServerManagerFactory.getEmbeddedServer
(SBTestEnvironment testEnv) static SBServerManager
ServerManagerFactory.getEmbeddedServer
(String confFilePath) SBServerManager.getEnqueuer
(String path) Get the Tuple enqueue object for a streamSBServerManager.getTableAccessor
(String tablePath) Return a TableAccessor suitable for manipulating this table.SBServerManager.getTableAccessor
(String tablePath, CaptureTransformStrategy captureStrategy) Return a TableAccessor suitable for manipulating this table.SBServerManager.getTimeService()
Return the current TimeService implementation used by the StreamBase Engineabstract boolean
Expecter.AbstractPredicate.isExpected
(Tuple t) boolean
Expecter.Predicate.isExpected
(Tuple t) void
Load a module into the default container.void
Load a module into the specified container.void
SBServerManager.loadAppString
(String appString, String container) Load an application (from a String) into the specified container.void
SBServerManager.loadDeploy
(String deployFile) Load the given StreamBase deployment file.void
BaseTestEnvironment.setNowImpl
(NowImplementation nowImpl) void
SBTestEnvironment.setNowImpl
(NowImplementation nowImpl) Set the current implementation of now() functionvoid
SBServerManager.shutdownServer()
Shutdown the StreamBase Engine, blocking until the StreamBase Engine is finished shutting downvoid
SBServerManager.startContainers()
Start all the containers for this StreamBase Engine.void
SBServerManager.startContainers
(Set<String> containersSuspendedOnStartup) Start all but the specified containers for this StreamBase Engine.void
SBServerManager.startContainers
(Set<String> containersSuspendedOnStartup, boolean deferSubscriptions) Start all but the specified containers for this StreamBase Enginevoid
SBServerManager.startServer()
Start the StreamBase Engine, blocking until the StreamBase Engine will accept connectionsvoid
SBServerManager.stopContainers()
Stop all containers in this StreamBase Enginevoid
Subscribes to a stream.void
SBServerManager.subscribeAll()
Subscribes to all streamsConstructors in com.streambase.sb.unittest that throw StreamBaseExceptionModifierConstructorDescriptionFieldBasedTupleComparator
(com.streambase.sb.DataType.Registry<FieldBasedTupleComparator.CompareFunctor> comparators, String... fields) ConstructorFieldBasedTupleComparator
(FieldBasedTupleComparator baseComparator, String... fields) Constructor -
Uses of StreamBaseException in com.tibco.ep.sb.ads
Subclasses of StreamBaseException in com.tibco.ep.sb.ads
SBUtils.newSchema(String, ByteOrder)