Uses of Class
com.streambase.sb.StreamBaseException

Packages that use StreamBaseException

Package	Description
com.streambase.liveview.client	Provides classes and interfaces fundamental to the TIBCO LiveView Java API.
com.streambase.liveview.server.table.plugin	Provides classes and interfaces to add custom table providers to TIBCO LiveView.
com.streambase.sb	Provides classes and interfaces fundamental to the TIBCO StreamBase Java API.
com.streambase.sb.adapter	Provides classes and interfaces to add custom adapters to StreamBase applications.
com.streambase.sb.client	Provides classes and interfaces used to communicate with a StreamBase server.
com.streambase.sb.expr
com.streambase.sb.feedsim	Provides abstract classes to extend feedsim input sources.
com.streambase.sb.monitor	Provides classes and interfaces to monitor the behavior of a running StreamBase server.
com.streambase.sb.operator	Provides classes and interfaces to add custom operators to StreamBase applications.
com.streambase.sb.unittest	Provides classes and interfaces used to author StreamBase Unit tests.
com.tibco.ep.sb.ads	Provides classes and interfaces for interacting with the TIBCO Artifact Management Server.

Uses of StreamBaseException in com.streambase.liveview.client

Subclasses of StreamBaseException in com.streambase.liveview.client

Modifier and Type	Class	Description
class	LiveViewConnectionCanceledException	Exception throws when the LiveView connection call is cancelled by the client
class	LiveViewException	An exception thrown by the LiveView Server
class	LiveViewQuerySyntaxException	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 StreamBaseException

Modifier and Type	Method	Description
Map<String,com.streambase.liveview.config.AbstractConfigObject>	TableProviderManager.compileLVConfs(List<File> tableFiles, boolean buildYaml)
void	TableProviderManager.createTable(String name, LiveviewConfiguration conf, boolean saveInProject)	Does pre-checks, saves lvconf file and registers the table in defined state with the services layer
void	TableProviderManager.deleteTable(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.sb

Modifier and Type	Class	Description
class	ApplicationValidationException
class	NotImplementedException	Signals that some feature has not yet been implemented.
class	NotSupportedException	Signals that some feature is not supported
class	NullValueException	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	ParsingException
class	SchemaMismatchException
static class	SchemaUtil.FieldConflictException	A SemanticValidationException that also stores the index of the schema that caused it, when we're computing merges of schemas.
class	SchemaValidationException	Exception to indicate validation failures
class	SemanticValidationException
class	StreamBaseListException	An exception that contains a list of exceptions
class	TupleException	Tuple manipulation error
class	XmlInterpretationException
class	XmlParsingException

Method parameters in com.streambase.sb with type arguments of type StreamBaseException

Modifier and Type	Method	Description
static Schema	SchemaUtil.createSchema(Element element, ByteOrder ord, SchemaUtil.SchemaProvider schemaProvider, List<StreamBaseException> errors)

Methods in com.streambase.sb that throw StreamBaseException

Modifier and Type	Method	Description
void	TimeService.advanceBy(long timeAdvance, TimeUnit timeUnit)	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 future
Object	AbstractFunction.apply(Object... args)
Object	BasicFunction.apply(Tuple input)
Object	Function.apply(Tuple input)	Applies the given arguments to this function and returns the output.
Object	Function.apply(Object... args)	Applies the given arguments to this function and returns the output.
static Schema	SchemaUtil.createSchema(String name, Schema definedHere, List<Schema> parentSchemas, 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, 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, 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 ContainerStatus
static Constants.ContainerState	Constants.ContainerState.decode(String value)	Decode a String value into the proper Container status
static Constants.LeadershipStatus	Constants.LeadershipStatus.decode(int value)	Deprecated. Decode the given integer into a LeadershipStatus
static Constants.LeadershipStatus	Constants.LeadershipStatus.decode(String value)	Deprecated. Decode the given String into a LeadershipStatus
static Timestamp	Timestamp.fromString(CharSequence dateString)	Create a timestamp using the given string
static Timestamp	Timestamp.fromString(String dateString)	Create a timestamp using the given string
static Timestamp	Timestamp.fromString(String dateString, CSV.FormatInfo format)	Create a timestamp using the given string and format.
Constants.LeadershipStatus	HATupleFields.getLeadershipStatus()
Schema	SchemaUtil.SchemaProvider.getSchemaByHash(byte[] hash)	request a schema by hash
static Schema	SBUtils.newSchema(String xmlString, boolean hasHeader, ByteOrder order)	Deprecated. use the version without hasHeader
static Schema	SBUtils.newSchema(String xmlString, ByteOrder order)
static Schema	SBUtils.newSchema(Element element, boolean hasHeader, ByteOrder order)	Deprecated. use the version without hasHeader
static Schema	SBUtils.newSchema(Element element, ByteOrder order)
static StreamProperties	SBUtils.newStreamProperties(String xmlstring, ByteOrder order)
static StreamProperties	SBUtils.newStreamProperties(Element element, ByteOrder order)
static Tuple	TupleUtil.randomTuple(Tuple tuple, int maxCount)	Create a tuple which contains random values
static Tuple	TupleUtil.randomTuple(Tuple tuple, int maxCount, int flags)	Create a tuple which contains random values
static Tuple	TupleUtil.randomTuple(Random random, Tuple tuple, int maxCount)	Create a tuple which contains random values
static Tuple	TupleUtil.randomTuple(Random random, Tuple tuple, int maxCount, int flags)	Create a tuple which contains random values
static void	TupleJSONUtil.setTuple(Tuple tuple, Object jsonObject, boolean strict)	Set the fields of a tuple based on the contents of a JSON object
static void	TupleJSONUtil.setTuple(Tuple tuple, Object jsonObject, boolean strict, String timestampFormat)	Set the fields of a tuple based on the contents of a JSON object
static void	TupleJSONUtil.setTuple(Tuple tuple, Object jsonObject, boolean strict, String timestampFormat, boolean numericTimestampsAsInterval)	Set the fields of a tuple based on the contents of a JSON object
static void	TupleUtil.setTuple(Tuple tuple, com.alibaba.fastjson.JSONObject object)	Set the fields of a tuple based on the contents of a JSON object
static void	TupleJSONUtil.setTupleFromJSON(Tuple tuple, String JSONString)	Set the fields of a tuple based on the contents of a JSON string
static void	TupleJSONUtil.setTupleFromJSON(Tuple tuple, String JSONString, String timestampFormat)	Set the fields of a tuple based on the contents of a JSON string
static void	TupleJSONUtil.setTupleFromJSON(Tuple tuple, String JSONString, String timestampFormat, boolean numericTimestampsAsInterval)	Set the fields of a tuple based on the contents of a JSON string
static void	TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple, String JSONString)	Set the fields of a tuple based on the contents of a JSON string.
static void	TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple, String JSONString, String timestampFormat)	Set the fields of a tuple based on the contents of a JSON string.
static void	TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple, String JSONString, String timestampFormat, boolean numericTimestampsAsInterval)	Set the fields of a tuple based on the contents of a JSON string.

Constructors in com.streambase.sb with parameters of type StreamBaseException

Constructor	Description
StreamBaseIllegalArgumentException(StreamBaseException e)

Constructors in com.streambase.sb that throw StreamBaseException

Constructor	Description
ClusterNotificationTupleFields(Tuple tuple)
HATupleFields(Tuple tuple)
Schema(String xmlSchema)	Construct a Schema out of XML represented as a String
StreamProperties(String a_xmlString)	Create a StreamProperties from the given string representation of an XML document
StreamProperties(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

Modifier and Type	Method	Description
void	InputAdapter.processTuple(int inputPort, Tuple tuple)

Uses of StreamBaseException in com.streambase.sb.client

Subclasses of StreamBaseException in com.streambase.sb.client

Modifier and Type	Class	Description
class	ClientConnectException
class	HAServerIOException	Exception thrown when there's an I/O error with a HA server
class	NetworkException	Exception thrown when a network error/problem occurs
class	ProtocolException	Exception thrown when a protocol error/problem occurs
class	URIException	Exception thrown when URI parsing fails.

Methods in com.streambase.sb.client that throw StreamBaseException

Modifier and Type	Method	Description
String[]	StreamBaseAdminClient.addContainer(String containerName, byte[] application, List<String> options)	Add the given application to the given container in the StreamBase server
String[]	StreamBaseAdminClient.addContainer(String containerName, File application, List<String> options)	Add the given application to the given container in the StreamBase server
String[]	StreamBaseAdminClient.addContainer(String containerName, String applicationText, List<String> options)	Add the given application to the given container in the StreamBase server
String[]	XmlRpcAdmin.addContainer(long timeoutMS, String containerName, byte[] application, List<String> containerStreamMappings)
String[]	StreamBaseAdminClient.addDeploy(byte[] deployText, String... args)	Deprecated. Replaced with application fragments and HOCON configuration
String[]	StreamBaseAdminClient.addDeploy(File deployFile, String... options)	Deprecated. Replaced with application fragments and HOCON configuration
String[]	StreamBaseAdminClient.addDeploy(String deployText, String... args)	Deprecated. Replaced with application fragments and HOCON configuration
String[]	XmlRpcAdmin.addDeploy(long timeoutMS, byte[] deployFile, List<String> args)
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 name
String	StreamBaseAdminClient.clearEvalCache(String containerName)	Clear evaluation cache
String	XmlRpcAdmin.clearEvalCache(long timeoutMS, String containerName)
void	StreamBaseClient.close()
void	StreamBaseClient.close(String msg)	Flush all buffers and close the connection to the StreamBase server.
DequeueResult	DeMUXStreamBaseClient.dequeue()
DequeueResult	DeMUXStreamBaseClient.dequeue(long timeoutMS)
DequeueResult	StreamBaseClient.dequeue()	Dequeue a batch of tuples from a subscribed stream.
DequeueResult	StreamBaseClient.dequeue(long timeoutMS)	Dequeue a batch of tuples from a subscribed stream.
String	StreamBaseClient.describe(String entityName)	Return an XML description of a StreamBase entity
String	XmlRpcAdmin.describe(long timeoutMS, String entityName)
void	StreamBaseAdminClient.drain()	Drain a StreamBase Server Has no effect if the server is not running
void	StreamBaseAdminClient.drain(String containerName)	Drain a container within a StreamBase Server Has no effect if the server is not running
void	XmlRpcAdmin.drain(long timeoutMS, String containerName)
void	StreamBaseClient.enableBuffering(int bufferSize)	Turn on buffering with a default WakeAndFlushBuffer thread set to 250ms
void	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	StreamBaseClient.enqueue(String stream, Tuple tuple)	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 time
void	XmlRpcAdmin.fastForwardTime(long timeoutMS, Object msecs)
void	StreamBaseClient.flushAllBuffers()	Flush any pending enqueue buffers.
void	StreamBaseClient.flushBuffer(StreamProperties props)	Deprecated. use StreamBaseClient.flushAllBuffers() to preserve inter-stream ordering
void	StreamBaseClient.flushBuffer(String stream_name)	Deprecated. use StreamBaseClient.flushAllBuffers() to preserve inter-stream ordering
Set<StreamProperties>	StreamBaseClient.getAllStreamProperties(EntityType type)	Return all the StreamProperties available.
Set<StreamProperties>	StreamBaseClient.getAllStreamProperties(EntityType type, CaptureTransformStrategy strategy)	Return all the StreamProperties available
ByteOrder	XmlRpcAdmin.getByteOrder(long timeoutMS)
Object	StreamBaseClient.getDynamicVariable(String dynamicVariablePath)	Get the given dynamic variable
Schema.Field	XmlRpcAdmin.getDynamicVariableField(long timeoutMS, Path dynvarPath)
Tuple	StreamBaseClient.getDynamicVariables(String modulePath)	Get a Tuple of all the dynamic variables on the given module
Tuple	XmlRpcAdmin.getDynamicVariables(long timeoutMS, Path modulePath)
String	StreamBaseAdminClient.getEvalCacheContent(String containerName)	Get evaluation cache content
String	XmlRpcAdmin.getEvalCacheContent(long timeoutMS, String containerName)
Constants.LeadershipStatus	StreamBaseAdminClient.getLeadershipStatus()	Deprecated. Legacy high-availability service, migrate to SB 10 high-availability service.
Constants.LeadershipStatus	XmlRpcAdmin.getLeadershipStatus(long timeoutMS)
String	StreamBaseAdminClient.getMapperCacheContent(String containerName)	Get mapper cache contents
String	XmlRpcAdmin.getMapperCacheContent(long timeoutMS, String containerName)
Map<Integer,String>	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)
String	StreamBaseAdminClient.getOperatorProperty(String operatorName, String propertyName)	Return the value of the given property on the given Operator.
String	XmlRpcAdmin.getOperatorProperty(long timeoutMS, String operatorName, String propertyName)
Schema	StreamBaseClient.getSchemaByHash(byte[] hash)	Return the Schema object for the given hash value
Schema	XmlRpcAdmin.getSchemaByHash(long timeoutMS, byte[] hash)
Schema	StreamBaseClient.getSchemaByName(String name)	Return the Schema object for the given name.
Schema	XmlRpcAdmin.getSchemaByName(long timeoutMS, String schemaName)
Schema	StreamBaseClient.getSchemaForStream(String streamName)	Return the schema of a stream.
StreamProperties	StreamBaseClient.getStreamProperties(String streamName)	Return the StreamProperties for the given stream name
StreamProperties	StreamBaseClient.getStreamProperties(String streamName, CaptureTransformStrategy strategy)	Return the StreamProperties for the given stream name
StreamProperties	XmlRpcAdmin.getStreamProperties(long timeoutMS, String streamName)
StreamProperties	XmlRpcAdmin.getStreamProperties(long timeoutMS, String streamName, CaptureTransformStrategy strategy)
StreamProperties	StreamBaseClient.getStreamPropertiesByHash(byte[] hash)	Return the StreamProperties for the given hash StreamProperties are cached locally in the client.
StreamProperties	StreamBaseClient.getStreamPropertiesByHash(String hashHexString)	Return the StreamProperties for the given hash StreamProperties are cached locally in the client.
StreamProperties	XmlRpcAdmin.getStreamPropertiesByHash(long timeoutMS, byte[] hash)
String	StreamBaseAdminClient.getTargetTime()	Get target time
String	XmlRpcAdmin.getTargetTime(long timeoutMS)
static SSLSocketFactory	SSLUtils.initSSL()
static SSLSocketFactory	SSLUtils.initSSL(String keystore, String keystorePass, String keyPass)
String[]	XmlRpcAdmin.internalCommand(long timeoutMS, String... args)
String[]	StreamBaseAdminClient.killAllConnections()	Kill all of the connections on the server
String[]	XmlRpcAdmin.killAllConnections(long timeoutMS)
String[]	StreamBaseAdminClient.killConnection(byte[] connectionId)	Kill the connection with the given connectionId
String[]	XmlRpcAdmin.killConnection(long timeoutMS, byte[] connectionId)
String[]	StreamBaseAdminClient.listConnections(StreamBaseAdminClient.ListConnectionArgument... args)	Return an array of client connections
String[]	XmlRpcAdmin.listConnections(long timeoutMS, StreamBaseAdminClient.ListConnectionArgument... args)
String[]	StreamBaseAdminClient.listEntities(String entityType, int flags)	Return an array of entity names for the given entity type
String[]	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 type
String[]	XmlRpcAdmin.listEntities(long timeoutMS, String entityType, int flags, CaptureTransformStrategy strategy)
static SSLContext	SSLUtils.makeClientSSLContext()
static SSLContext	SSLUtils.makeClientSSLContext(boolean debug)
static SSLContext	SSLUtils.makeSSLContext(String keystore, String keystorePass, String keyPass)
static 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[]	XmlRpcAdmin.manageJdbcConnections(long timeoutMS, List<String> args)
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[]	XmlRpcAdmin.modifyContainer(long timeoutMS, String containerName, List<String> args)	Modify the given container
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 call
List<Tuple>	StreamBaseClient.readTable(String tablePath, int rowLimit)	Return rows from a Query Table or Materialized Window.
List<Tuple>	StreamBaseClient.readTable(String tablePath, int rowLimit, String predicate)	Return rows from a Query Table or Materialized Window, applying an optional predicate to decide which rows are returned.
List<Tuple>	XmlRpcAdmin.readTable(long timeoutMS, String tablePath, int rowLimit, String predicate)
String[]	StreamBaseAdminClient.removeContainer(String containerName, String... args)	Remove the given container in the StreamBase server
String[]	XmlRpcAdmin.removeContainer(long timeoutMS, String containerName, List<String> args)
String[]	StreamBaseAdminClient.restartContainer(String containerName)	Restart a container
String[]	XmlRpcAdmin.restartContainer(long timeoutMS, String containerName)
void	StreamBaseAdminClient.restartOperators(List<String> operatorNames)	Restart the given Operators on the StreamBase server.
void	XmlRpcAdmin.restartOperators(long timeoutMS, List<String> operatorNames)
StreamProperties	DeMUXStreamBaseClient.resubscribe(StreamProperties props, String logicalstream, String predicate)
StreamProperties	DeMUXStreamBaseClient.resubscribe(String streamname, String logicalstream, String predicate)
StreamProperties	StreamBaseClient.resubscribe(StreamProperties props, String logicalstream, String predicate)	Resubscribe to a stream with a predicate.
StreamProperties	StreamBaseClient.resubscribe(String streamname, String logicalstream, String predicate)	Resubscribe to a stream with a predicate.
void	StreamBaseAdminClient.resume(String containerName)	Resume a container in a StreamBase server
void	XmlRpcAdmin.resume(long timeoutMS, String containerName)
void	StreamBaseAdminClient.resumeOperators(List<String> operatorNames)	Resume the given Operators on the StreamBase server
void	XmlRpcAdmin.resumeOperators(long timeoutMS, List<String> operatorNames)
void	StreamBaseClient.setDynamicVariable(String dynvarPath, Object value)	Set the given dynamic variable to a new value
void	XmlRpcAdmin.setDynamicVariable(long timeoutMS, Path dynamicVariablePath, Object value)
void	StreamBaseAdminClient.setLeadershipStatus(Constants.LeadershipStatus leadershipStatus)	Deprecated. Legacy high-availability service, migrate to SB 10 high-availability service.
void	XmlRpcAdmin.setLeadershipStatus(long timeoutMS, Constants.LeadershipStatus leadershipStatus)
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 value
void	StreamBaseAdminClient.setRuntimeParam(String paramName, String paramValue, String operator)	Set a runtime parameter on one, or all, operators.
void	XmlRpcAdmin.setRuntimeParam(long timeoutMS, String paramName, String paramValue, String operator)
String	StreamBaseAdminClient.shutdown()	Shutdown a StreamBase server
String	StreamBaseAdminClient.shutdown(String containerName)	Shutdown a container within a StreamBase server
String	XmlRpcAdmin.shutdown(long timeoutMS, String containerName)
void	StreamBaseAdminClient.shutdownOperators(List<String> operatorNames)	Shut down the given Operators on the StreamBase server.
void	XmlRpcAdmin.shutdownOperators(long timeoutMS, List<String> operatorNames)
String[]	XmlRpcAdmin.status(long timeoutMS, boolean verbose)
StreamProperties	DeMUXStreamBaseClient.subscribe(StreamProperties props)
StreamProperties	DeMUXStreamBaseClient.subscribe(StreamProperties props, String logicalstream, String predicate)
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamname)
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamName, CaptureTransformStrategy strategy)
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamName, CaptureTransformStrategy strategy, String logicalstream, String predicate)
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamname, String logicalstream, String predicate)
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamname, String logicalstream, String predicate, DeMUXStreamBaseClient.DequeueListener listener)	This is the only subscribe operation that is supported by the DeMUXStreamBaseClient
StreamProperties	StreamBaseClient.subscribe(StreamProperties props)	Subscribe to a stream
StreamProperties	StreamBaseClient.subscribe(StreamProperties props, String logicalstream, String predicate)	Subscribe to a stream with a predicate.
StreamProperties	StreamBaseClient.subscribe(String streamname)	Subscribe to a stream
StreamProperties	StreamBaseClient.subscribe(String streamName, CaptureTransformStrategy strategy)	Subscribe to a stream
StreamProperties	StreamBaseClient.subscribe(String streamName, CaptureTransformStrategy strategy, String logicalstream, String predicate)	Subscribe to a stream with a predicate.
StreamProperties	StreamBaseClient.subscribe(String streamname, String logicalstream, String predicate)	Subscribe to a stream with a predicate.
List<?>	XmlRpcAdmin.subscribe(long timeoutMS, com.streambase.sb.client.SubscriptionEntry subscription)	Subscribe
com.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 stream
void	StreamBaseAdminClient.suspend(String name)	Suspend (pause) a container or operator within a StreamBase Server
void	XmlRpcAdmin.suspend(long timeoutMS, String name)
void	StreamBaseAdminClient.suspendOperators(List<String> operatorNames)	Suspend (pause) the given Operators on the StreamBase Server
void	XmlRpcAdmin.suspendOperators(long timeoutMS, List<String> operatorNames)
StreamProperties[]	StreamBaseClient.typecheck(String application)	Typecheck (validate) the given StreamBase Application.
StreamProperties[]	StreamBaseClient.typecheck(String application, boolean full)	Typecheck (validate) the given StreamBase Application.
StreamProperties[]	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	XmlRpcAdmin.unsubscribe(long timeoutMS, String streamName, String logicalName)	Unsubscribe a stream
protected void	StreamBaseClient.unsubscribeInternal(StreamProperties logicalProps)	Un-subscribe from stream

Constructors in com.streambase.sb.client that throw StreamBaseException

Constructor	Description
DeMUXStreamBaseClient(StreamBaseURI streamBaseURI)
DeMUXStreamBaseClient(String uri)
DeMUXStreamBaseClient(List<StreamBaseURI> uris, ClientSettings settings)
SSLSocketWrapper(StreamBaseURI uri, ClientSettings settings)
StreamBaseAdminClient()	Create a StreamBaseAdminClient.
StreamBaseAdminClient(StreamBaseURI uri)	Create a StreamBaseAdminClient, connecting to the server at the provided URI.
StreamBaseAdminClient(String uri)	Create a StreamBaseAdminClient.
StreamBaseAdminClient(List<StreamBaseURI> uris)	Create a StreamBaseAdminClient.
StreamBaseAdminClient(List<StreamBaseURI> uris, ClientSettings settings)	Create a StreamBaseAdminClient.
StreamBaseClient()	Create a StreamBaseClient.
StreamBaseClient(StreamBaseURI uri)	Create a StreamBaseClient, connecting to the server at the provided URI
StreamBaseClient(String uriStrings)	Create a StreamBaseClient from one or more comma-separated URI strings
StreamBaseClient(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.expr

Modifier and Type	Class	Description
class	ExprException	Semantic exception parsing an expression.

Uses of StreamBaseException in com.streambase.sb.feedsim

Methods in com.streambase.sb.feedsim that throw StreamBaseException

Modifier and Type	Method	Description
abstract Schema	FeedSimTupleInputStream.getSchema()	This method must return the Schema of the data to be returned by readTuple()
abstract Tuple	FeedSimTupleInputStream.readTuple()	This method is called by a FeedSim thread to get the next tuple to send.

Uses of StreamBaseException in com.streambase.sb.monitor

Methods in com.streambase.sb.monitor that throw StreamBaseException

Modifier and Type	Method	Description
static String	StatsUtil.getName(StatsUtil.IdentityHelper helper, StatTuplev3 st)	Fetch the item name using the client
String	StatsUtil.IdentityHelper.getName(StatTuplev3 st)
String	StatsUtil.IdentityHelper.getNameFromId(long id)	Stats Stream v3 only.
protected String	Snapshot.getOperatorType(StreamBaseClient sbClient, String name)
Map<Integer,String>	StatsUtil.IdentityHelper.IdentityUpdater.getUpdateByContainerId(int containerId)
Iterator<Tuple>	Snapshot.Source.nextResult()
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 StreamBaseException

Constructor	Description
StreamBaseMonitor(StreamBaseClient client)	Create a monitoring object, which will connect to a server with the given StreamBaseClient object.
StreamBaseMonitor(StreamBaseClient sbClient, String streamName)	Constructor
StreamBaseMonitor(StreamBaseURI uri)	Create 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.operator

Modifier and Type	Class	Description
class	AlreadyRegisteredException
class	DbConnectTypecheckException
class	Operator.PropertyTypecheckException	A typecheck exception associated with an Operator property (or parameter) by name.
class	ParameterInterpretationException
class	ResourceNotFoundException	Thrown when an operator tries to get a resource by name, but no such resource exists.
class	SqlTypecheckException
class	TypecheckException	May be thrown when an error occurs during an Operator's typecheck() method.

Methods in com.streambase.sb.operator that throw StreamBaseException

Modifier and Type	Method	Description
void	RowConsumer.consume(Tuple row)	Override this method to consume rows.
Tuple	TableAccessor.delete(Tuple pkey)	Delete a row in the table based on primary key.
String	Operator.evaluate(String st, Tuple input)	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 message
void	PreparedQuery.execute(CompiledTuple args, RowConsumer consumer)	Run the query against a given set of arguments, and pass the results to consumer
void	PreparedQuery.execute(CompiledTuple args, TableAccessor table, RowConsumer consumer)	Execute the query
InputStream	IResourceReader.getResourceContents(String name)
InputStream	Operator.getResourceContents(String name)	Returns an open input stream on the contents of the named resource file.
File	IResourceReader.getResourceFile(String name)
File	Operator.getResourceFile(String name)	Returns a File pointing to the regular file or directory if it exists.
TableAccessor	Operator.getTableAccessor(String name)	Get a TableAccessor for a table in the local module by name of that table.
TupleCaptureTransformer	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 schema This method may only be called at runtime; the exact schemas of any capture fields are not fully determined at typecheck time.
void	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	TableAccessor.insert(Tuple row)	Insert a new row into the table.
PreparedQuery	TableAccessor.prepare(String predicate, Schema args)	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.
Tuple	TableAccessor.readPrimary(Tuple pkey)	Read a row from the table by primary key.
void	Operator.registerRunnable(Runnable operatorRunnable)	Deprecated. As of StreamBase version 3.7, replaced by Operator.registerRunnable(Runnable, boolean)
void	Operator.registerRunnable(Runnable operatorRunnable, boolean shouldInterrupt)	Register a Runnable object to be managed by this Operator.
void	Operator.registerRunnable(String runnableName, Runnable operatorRunnable, boolean shouldInterrupt)	Register a Runnable object to be managed by this Operator.
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.
Tuple	TableAccessor.replace(Tuple row)	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 rows

Constructors in com.streambase.sb.operator with parameters of type StreamBaseException

Constructor	Description
TypecheckException(StreamBaseException cause)

Uses of StreamBaseException in com.streambase.sb.unittest

Methods in com.streambase.sb.unittest that throw StreamBaseException

Modifier and Type	Method	Description
boolean	FieldBasedTupleComparator.compare(Tuple expected, Tuple actual)
boolean	FieldBasedTupleComparator.CompareFunctor.compare(TupleComparator comparator, CompleteDataType cdt, Object expected, Object actual)	Handle null checks before delegating to FieldBasedTupleComparator.CompareFunctor.compareImpl(com.streambase.sb.unittest.TupleComparator, com.streambase.sb.CompleteDataType, java.lang.Object, java.lang.Object)
boolean	TupleComparator.compare(Tuple expected, Tuple actual)	Compare two tuples.
abstract boolean	FieldBasedTupleComparator.CompareFunctor.compareImpl(TupleComparator comparator, CompleteDataType cdt, Object expected, Object actual)	Compare two values expected and actual, using comparator 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 with CompleteDataType cdt.
abstract Tuple	AbstractTupleMaker.createTuple(Schema schema, T t)
Tuple	CSVTupleMaker.createTuple(Schema schema, String str)
Tuple	JSONSingleQuotesTupleMaker.createTuple(Schema schema, String str)
Tuple	JSONTupleMaker.createTuple(Schema schema, String str)
Tuple	ObjectArrayTupleMaker.createTuple(Schema schema, Object[] objs)
Tuple	TupleMaker.createTuple(Schema schema, T t)	create a Tuples from an input object
List<Tuple>	AbstractTupleMaker.createTuples(Schema schema, Collection<T> ts)
List<Tuple>	AbstractTupleMaker.createTuples(Schema schema, T... ts)
List<Tuple>	TupleMaker.createTuples(Schema schema, Collection<T> t)	create multiple Tuples from input objects
List<Tuple>	TupleMaker.createTuples(Schema schema, T... t)	create multiple Tuples from input objects
List<Tuple>	Dequeuer.dequeue(int numTuples)	Try to dequeue tuples with the Dequeuer.DEFAULT_TIMEOUT and Dequeuer.DEFAULT_TIMEOUT_UNIT if numTuples == 0 will return immediately if numTuples < 0 will wait the maximum timeout before returning
List<Tuple>	Dequeuer.dequeue(int numTuples, long timeout, TimeUnit timeUnit)	Try 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	Enqueuer.enqueue(Tuple tuple)	Enqueue Tuple to the stream
void	Enqueuer.enqueue(Tuple... tuples)	Enqueue multiple tuples to the stream
<T> void	Enqueuer.enqueue(TupleMaker<T> tupleMaker, List<T> t)	Create multiple tuples using a TupleMaker and then enqueue them.
<T> void	Enqueuer.enqueue(TupleMaker<T> tupleMaker, T t)	Create a tuple using a TupleMaker and then enqueue it.
<T> void	Enqueuer.enqueue(TupleMaker<T> tupleMaker, T... t)	Create multiple tuples using a TupleMaker and then enqueue them.
void	Enqueuer.enqueue(List<Tuple> tuples)	Enqueue multiple tuples to the stream
void	Expecter.expect(Tuple tuple)	Expect a tuple from the dequeuer.
void	Expecter.expect(Tuple... tuples)	Expect multiple tuples in a particular order from the dequeuer.
void	Expecter.expect(Expecter.DequeueSetting mode, Tuple expected)	Expect a given tuple from the dequeuer
void	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 dequeuer
void	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	Expecter.expect(List<Tuple> expected)	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 dequeuer
void	Expecter.expectPredicate(Expecter.DequeueSetting mode, List<Expecter.Predicate> expected)	Expect a number of tuples, each fulfilling one predicate in a list, from the Dequeuer
void	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 dequeuer
void	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 dequeuer
String	BaseTestEnvironment.getConf()
String	SBTestEnvironment.getConf()
Dequeuer	SBServerManager.getDequeuer(String path)	Get the Tuple dequeue object for a stream
static SBServerManager	ServerManagerFactory.getEmbeddedServer()
static SBServerManager	ServerManagerFactory.getEmbeddedServer(SBTestEnvironment testEnv)
static SBServerManager	ServerManagerFactory.getEmbeddedServer(String confFilePath)
Enqueuer	SBServerManager.getEnqueuer(String path)	Get the Tuple enqueue object for a stream
TableAccessor	SBServerManager.getTableAccessor(String tablePath)	Return a TableAccessor suitable for manipulating this table.
TableAccessor	SBServerManager.getTableAccessor(String tablePath, CaptureTransformStrategy captureStrategy)	Return a TableAccessor suitable for manipulating this table.
TimeService	SBServerManager.getTimeService()	Return the current TimeService implementation used by the StreamBase Engine
abstract boolean	Expecter.AbstractPredicate.isExpected(Tuple t)
boolean	Expecter.Predicate.isExpected(Tuple t)
void	SBServerManager.loadApp(String fullyQualifiedModuleName)	Load a module into the default container.
void	SBServerManager.loadApp(String fullyQualifiedModuleName, String container)	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() function
void	SBServerManager.shutdownServer()	Shutdown the StreamBase Engine, blocking until the StreamBase Engine is finished shutting down
void	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 Engine
void	SBServerManager.startServer()	Start the StreamBase Engine, blocking until the StreamBase Engine will accept connections
void	SBServerManager.stopContainers()	Stop all containers in this StreamBase Engine
void	SBServerManager.subscribe(String streamPath)	Subscribes to a stream.
void	SBServerManager.subscribeAll()	Subscribes to all streams

Constructors in com.streambase.sb.unittest that throw StreamBaseException

Constructor	Description
FieldBasedTupleComparator(DataType.Registry<FieldBasedTupleComparator.CompareFunctor> comparators, String... fields)
FieldBasedTupleComparator(FieldBasedTupleComparator baseComparator, String... fields)

Uses of StreamBaseException in com.tibco.ep.sb.ads

Subclasses of StreamBaseException in com.tibco.ep.sb.ads

Modifier and Type	Class	Description
class	ArtifactException	Artifact exception.