Uses of Class
com.streambase.sb.StreamBaseException

Packages that use StreamBaseException

Package	Description
com.streambase.liveview.client	Provides classes and interfaces fundamental to the LiveView Java API.
com.streambase.liveview.server.table.plugin	Provides classes and interfaces to add custom table providers for LiveView.
com.streambase.sb	Provides classes and interfaces fundamental to the Streaming Java API.
com.streambase.sb.adapter	Provides classes and interfaces to add custom adapters to Streaming applications.
com.streambase.sb.client	Provides classes and interfaces used to communicate with a Streaming 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 Streaming server.
com.streambase.sb.operator	Provides classes and interfaces to add custom operators to Streaming applications.
com.streambase.sb.unittest	Provides classes and interfaces used to author Streaming Unit tests.
com.tibco.ep.sb.ads	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.client

Modifier and Type	Class	Description
final class	LiveViewConnectionCanceledException	Exception throws when the LiveView connection call is cancelled by the client
class	LiveViewException	An exception thrown by the LiveView Server
final 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, 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 layer
void	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.sb

Modifier and Type	Class	Description
class	ApplicationValidationException	Module (aka application) validation exception
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	Parsing exception
class	SchemaMismatchException	A schema mismatch happened
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	Semantic validation exception
class	StreamBaseListException	An exception that contains a list of exceptions
class	TupleException	Tuple manipulation error
class	XmlInterpretationException	XML interpretation exception
class	XmlParsingException	XML parsing error

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)	Create a schema from XML

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, 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 ContainerStatus
static Constants.ContainerState	Constants.ContainerState.decode(String value)	Decode a String value into the proper Container status
static 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 string
static Timestamp	Timestamp.fromString(String dateString)	Create a timestamp using the given string
static Timestamp	Timestamp.fromString(String dateString, com.streambase.sb.util.CSV.FormatInfo format)	Create a timestamp using the given string and format.
Schema	SchemaUtil.SchemaProvider.getSchemaByHash(byte[] hash)	request a schema by hash
static Schema	SBUtils.newSchema(String xmlString, boolean hasHeader, ByteOrder order)	Deprecated. please use SBUtils.newSchema(String, ByteOrder)
static Schema	SBUtils.newSchema(String xmlString, ByteOrder order)	Create a new schema
static Schema	SBUtils.newSchema(Element element, boolean hasHeader, ByteOrder order)	Deprecated. please use SBUtils.newSchema(Element, ByteOrder)
static Schema	SBUtils.newSchema(Element element, ByteOrder order)	Create a new schema
static StreamProperties	SBUtils.newStreamProperties(String xmlstring, ByteOrder order)	Create new stream properties from XML string
static StreamProperties	SBUtils.newStreamProperties(Element element, ByteOrder order)	Create new stream properties from XML element
static com.fasterxml.jackson.databind.JsonNode	TupleJSONUtil.parseJSONString(String json)	Parse JSON string into a JSON object
TupleJSONUtil.SetTupleFromJSON	TupleJSONUtil.SetTupleFromJSON.process(String jsonVal, Tuple tuple)	Handles 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 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)	Deprecated. Use the TupleJSONUtil.SetTupleFromJSON Builder and its .process() to handle this functionality
static void	TupleJSONUtil.setTuple(Tuple tuple, Object jsonObject, boolean strict, String timestampFormat)	Deprecated. Use the TupleJSONUtil.SetTupleFromJSON Builder and its .process() to handle this functionality
static void	TupleJSONUtil.setTuple(Tuple tuple, Object jsonObject, boolean strict, String timestampFormat, boolean numericTimestampsAsInterval)	Deprecated. Use the TupleJSONUtil.SetTupleFromJSON Builder and its .process() to handle this functionality
static void	TupleUtil.setTuple(Tuple tuple, com.fasterxml.jackson.databind.JsonNode object)	Set the fields of a tuple based on the contents of a JSON object
static void	TupleJSONUtil.setTupleFromJSON(Tuple tuple, String JSONString)	Deprecated. Use the TupleJSONUtil.SetTupleFromJSON Builder and its .process() to handle this functionality
static void	TupleJSONUtil.setTupleFromJSON(Tuple tuple, String JSONString, String timestampFormat)	Deprecated. Use the TupleJSONUtil.SetTupleFromJSON Builder and its .process() to handle this functionality
static void	TupleJSONUtil.setTupleFromJSON(Tuple tuple, String JSONString, String timestampFormat, boolean numericTimestampsAsInterval)	Deprecated. Use the TupleJSONUtil.SetTupleFromJSON Builder and its .process() to handle this functionality
static void	TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple, String JSONString)	Deprecated. Use the TupleJSONUtil.SetTupleFromJSON Builder and its .process() to handle this functionality
static void	TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple, String JSONString, String timestampFormat)	Deprecated. Use the TupleJSONUtil.SetTupleFromJSON Builder and its .process() to handle this functionality
static void	TupleJSONUtil.setTupleFromJSONLoose(Tuple tuple, String JSONString, String timestampFormat, boolean numericTimestampsAsInterval)	Deprecated. Use the TupleJSONUtil.SetTupleFromJSON Builder and its .process() to handle this functionality
static 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 StreamBaseException

Modifier	Constructor	Description
	StreamBaseIllegalArgumentException(StreamBaseException e)	Constructor

Constructors in com.streambase.sb that throw StreamBaseException

Modifier	Constructor	Description
	Schema(String xmlSchema)	Construct a Schema out of XML represented as a String
	StreamProperties(String xml)	Create a StreamProperties from the given string representation of an XML document
(package private)	StreamProperties(String xml, ByteOrder byteOrder)	Create a StreamProperties from the given string representation of an XML document
	StreamProperties(Element element)	Create a StreamProperties from the given XML document
(package private)	StreamProperties(Element element, ByteOrder byteOrder)	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
(package private) class	ClusterRedirectException
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 return StreamBaseException

Modifier and Type	Method	Description
static StreamBaseException	HAAdmin.processExceptions(String message, List<Throwable> exceptions, String baseUri, Class<?> exceptionsCheck)	Look through the exceptions; if we have one that isn't an XMLRPCException then throw that one otherwise bundle them all up into a list exception.

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

Modifier and Type	Method	Description
(package private) void	TupleConnections.addConnection(StreamBaseURI uri, StreamProperties props)	Add a connection
String[]	Admin.addContainer(long timeoutMS, String containerName, byte[] application, List<String> containerStreamMappings)	Add the given application to the given container in the StreamBaseServer
String[]	HAAdmin.addContainer(long timeoutMS, String containerName, byte[] application, List<String> containerStreamMappings)
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[]	Admin.addDeploy(long timeoutMS, byte[] deploy, List<String> args)	Add the given deploy file to the server.
String[]	HAAdmin.addDeploy(long timeoutMS, byte[] deploy, List<String> args)
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)
(package private) boolean	StreamBaseClient.TupleBuffer.addTuple(Tuple tuple)	Add a tuple
(package private) boolean	StreamBaseClient.TupleBuffer.addTuples(Collection<Tuple> tuples)	Add tuples
boolean	Admin.checkLicense(long timeoutMS, String featureName)	Return true if a license for the specified feature is available and false otherwise.
boolean	HAAdmin.checkLicense(long timeoutMS, String featureName)
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	Admin.clearEvalCache(long timeoutMS, String containerName)	Clear evaluation cache
String	HAAdmin.clearEvalCache(long timeoutMS, String containerName)
String	StreamBaseAdminClient.clearEvalCache(String containerName)	Clear evaluation cache
String	XmlRpcAdmin.clearEvalCache(long timeoutMS, String containerName)
abstract void	BaseClient.close()
void	StreamBaseClient.close()
void	StreamBaseClient.close(String message)	Flush all buffers and close the connection to the StreamBase server.
(package private) static Admin	AdminFactory.create(List<StreamBaseURI> _uris)	Create the admin implementation object that does the actual communication to the 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	Admin.describe(long timeoutMS, String entityName)	Return an XML description of a StreamBase entity
String	HAAdmin.describe(long timeoutMS, String entityName)
String	StreamBaseClient.describe(String entityName)	Return an XML description of a StreamBase entity
String	XmlRpcAdmin.describe(long timeoutMS, String entityName)
void	Admin.drain(long timeoutMS, String containerName)	Drain a StreamBase container or if empty the entire Server
void	HAAdmin.drain(long timeoutMS, String containerName)
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	Admin.enqueue(long timeoutMS, StreamProperties props, Collection<String> tuples)	Enqueue a list of CSV encoded tuples using connectionless XMLRPC
void	HAAdmin.enqueue(long timeoutMS, StreamProperties props, Collection<String> tuples)
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.
(package private) void	StreamBaseClient.SerializedTupleBuffer.enqueue(boolean hasMore)
(package private) abstract void	StreamBaseClient.TupleBuffer.enqueue(boolean hasMore)	actually enqueue the buffer
(package private) boolean	TupleConnection.enqueue(StreamBaseClient.SerializedTupleBuffer buffer, boolean hasMore)	Enqueue a tuple buffer
void	XmlRpcAdmin.enqueue(long timeoutMS, StreamProperties props, Collection<String> tuples)
(package private) void	TupleConnections.enqueueTupleBuffer(StreamBaseClient.SerializedTupleBuffer buffer, boolean hasMore)	Private version of enqueue that does all of the work.
void	Admin.fastForwardTime(long timeoutMS, Object msecs)	Number of milliseconds to jump forward in time.
void	HAAdmin.fastForwardTime(long timeout, Object value)
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	Admin.getByteOrder(long timeoutMS)	What is the byte order of the server?
ByteOrder	HAAdmin.getByteOrder(long timeoutMS)
ByteOrder	XmlRpcAdmin.getByteOrder(long timeoutMS)
(package private) List<TupleConnections.StreamTupleConnection>	TupleConnections.getConnections(StreamProperties props)	Return an unmodifiable list of List<StreamConnection>
Object	StreamBaseClient.getDynamicVariable(String dynamicVariablePath)	Get the given dynamic variable
Schema.Field	HAAdmin.getDynamicVariableField(long timeoutMS, com.streambase.sb.util.Path dynamicVariablePath)
Schema.Field	XmlRpcAdmin.getDynamicVariableField(long timeoutMS, com.streambase.sb.util.Path dynvarPath)
Tuple	Admin.getDynamicVariables(long timeoutMS, com.streambase.sb.util.Path modulePath)	Return the current value of the dynamic variables in the given module, as a Tuple of field name to Java value.
Tuple	HAAdmin.getDynamicVariables(long timeoutMS, com.streambase.sb.util.Path modulePath)
Tuple	StreamBaseClient.getDynamicVariables(String modulePath)	Get a Tuple of all the dynamic variables on the given module
Tuple	XmlRpcAdmin.getDynamicVariables(long timeoutMS, com.streambase.sb.util.Path modulePath)
String	Admin.getEvalCacheContent(long timeoutMS, String containerName)	Get evaluation cache content
String	HAAdmin.getEvalCacheContent(long timeout, String containerName)
String	StreamBaseAdminClient.getEvalCacheContent(String containerName)	Get evaluation cache content
String	XmlRpcAdmin.getEvalCacheContent(long timeoutMS, String containerName)
String	Admin.getMapperCacheContent(long timeoutMS, String containerName)	Get mapper cache content
String	HAAdmin.getMapperCacheContent(long timeoutMS, String containerName)
String	StreamBaseAdminClient.getMapperCacheContent(String containerName)	Get mapper cache contents
String	XmlRpcAdmin.getMapperCacheContent(long timeoutMS, String containerName)
Map<Integer,String>	Admin.getNamesForContainer(long timeoutMS, int id)	Return a map of id and names for the given container id.
Map<Integer,String>	HAAdmin.getNamesForContainer(long timeoutMS, int id)
Map<Integer,String>	XmlRpcAdmin.getNamesForContainer(long timeoutMS, int id)
String[]	Admin.getOperatorProperties(long timeoutMS, String operatorName)	For the given Operator, return its set of properties and their values.
String[]	HAAdmin.getOperatorProperties(long timeoutMS, String operatorName)
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	Admin.getOperatorProperty(long timeoutMS, String operatorName, String propertyName)	Return the value of the given property on the given Operator.
String	HAAdmin.getOperatorProperty(long timeoutMS, String operatorName, String propertyName)
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	Admin.getSchemaByHash(long timeoutMS, byte[] hash)	Return the Schema object for the given hash value
Schema	HAAdmin.getSchemaByHash(long timeoutMS, byte[] hash)
Schema	StreamBaseClient.getSchemaByHash(byte[] hash)	Return the Schema object for the given hash value
Schema	XmlRpcAdmin.getSchemaByHash(long timeoutMS, byte[] hash)
Schema	Admin.getSchemaByName(long timeoutMS, String schemaName)	Return the Schema object for the given name
Schema	HAAdmin.getSchemaByName(long timeoutMS, String schemaName)
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	Admin.getStreamProperties(long timeoutMS, String streamName)	Return the StreamProperties for the given name.
StreamProperties	Admin.getStreamProperties(long timeoutMS, String streamName, CaptureTransformStrategy strategy)	Return the StreamProperties for the given name.
StreamProperties	HAAdmin.getStreamProperties(long timeoutMS, String streamName)
StreamProperties	HAAdmin.getStreamProperties(long timeoutMS, String streamName, CaptureTransformStrategy strategy)
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	Admin.getStreamPropertiesByHash(long timeoutMS, byte[] hash)	Return the StreamProperties for the given hash
StreamProperties	HAAdmin.getStreamPropertiesByHash(long timeoutMS, byte[] hash)
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	Admin.getTargetTime(long timeoutMS)	Get target time
String	HAAdmin.getTargetTime(long timeout)
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[]	Admin.internalCommand(long timeoutMS, String... args)	run an internal command
String[]	HAAdmin.internalCommand(long timeoutMS, String... args)
String[]	XmlRpcAdmin.internalCommand(long timeoutMS, String... args)
String[]	Admin.killAllConnections(long timeoutMS)	Kill all of the connections on the server
String[]	HAAdmin.killAllConnections(long timeoutMS)
String[]	StreamBaseAdminClient.killAllConnections()	Kill all of the connections on the server
String[]	XmlRpcAdmin.killAllConnections(long timeoutMS)
String[]	Admin.killConnection(long timeoutMS, byte[] connectionId)	Kill the connection with the given connectionId
String[]	HAAdmin.killConnection(long timeoutMS, byte[] connectionId)
String[]	StreamBaseAdminClient.killConnection(byte[] connectionId)	Kill the connection with the given connectionId
String[]	XmlRpcAdmin.killConnection(long timeoutMS, byte[] connectionId)
String[]	Admin.listConnections(long timeoutMS, StreamBaseAdminClient.ListConnectionArgument... arg)	Return an array of client connections
String[]	HAAdmin.listConnections(long timeoutMS, StreamBaseAdminClient.ListConnectionArgument... args)
String[]	StreamBaseAdminClient.listConnections(StreamBaseAdminClient.ListConnectionArgument... args)	Return an array of client connections
String[]	XmlRpcAdmin.listConnections(long timeoutMS, StreamBaseAdminClient.ListConnectionArgument... args)
String[]	Admin.listEntities(long timeoutMS, String entityType, int flags, CaptureTransformStrategy strategy)	Return an array of entity names for the given entity type
String[]	HAAdmin.listEntities(long timeoutMS, String entityType, int flags, CaptureTransformStrategy strategy)
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 com.streambase.sb.client.TupleIO	TupleIOFactory.makeTupleIO(StreamBaseURI uri, ClientSettings settings)
String[]	Admin.manageJdbcConnections(long timeoutMS, 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[]	HAAdmin.manageJdbcConnections(long timeoutMS, List<String> args)
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	HAAdmin.modifyApplication(long timeoutMS, byte[] application)	Modify the StreamBase Server with the given StreamBase application.
void	XmlRpcAdmin.modifyApplication(long timeoutMS, byte[] application)	Modify the StreamBase Server with the given StreamBase application.
String[]	Admin.modifyContainer(long timeoutMS, String containerName, List<String> args)	Modify the given container
String[]	HAAdmin.modifyContainer(long timeoutMS, String containerName, List<String> args)
String[]	StreamBaseAdminClient.modifyContainer(String containerName, List<String> options)	Modifies the given container.
String[]	XmlRpcAdmin.modifyContainer(long timeoutMS, String containerName, List<String> args)
(package private) org.apache.xmlrpc.client.XmlRpcClient	XmlRpcAdmin.newXmlRpcClient(StreamBaseURI uri)	Create a new XML RPC client
(package private) boolean	TupleConnection.open()	Open connection
String[]	Admin.operatorStatus(long timeoutMS, String containerName)	Return the status of each Operator present in the StreamBase server.
String[]	BaseClient.operatorStatus(String containerName)	Return the status of all the operators in the specified container
String[]	HAAdmin.operatorStatus(long timeoutMS, String containerName)
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>	Admin.readTable(long timeoutMS, String tablePath, int rowLimit, String predicate)	Return rows from the table.
List<Tuple>	HAAdmin.readTable(long timeoutMS, String tablePath, int rowLimit, String predicate)
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[]	Admin.removeContainer(long timeoutMS, String containerName, List<String> args)	Remove the given container in the StreamBaseServer
String[]	HAAdmin.removeContainer(long timeoutMS, String containerName, List<String> args)
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[]	Admin.restartContainer(long timeoutMS, String containerName)	Restart the given container
String[]	HAAdmin.restartContainer(long timeoutMS, String containerName)
String[]	StreamBaseAdminClient.restartContainer(String containerName)	Restart a container
String[]	XmlRpcAdmin.restartContainer(long timeoutMS, String containerName)
void	Admin.restartOperators(long timeoutMS, List<String> operators)	Restart the given Operators on the StreamBase server.
void	HAAdmin.restartOperators(long timeoutMS, List<String> operatorNames)
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	Admin.resume(long timeoutMS, String containerName)	Resume a paused StreamBase container of if empty the whole Server
void	HAAdmin.resume(long timeoutMS, String containerName)
void	StreamBaseAdminClient.resume(String containerName)	Resume a container in a StreamBase server
void	XmlRpcAdmin.resume(long timeoutMS, String containerName)
void	Admin.resumeOperators(long timeoutMS, List<String> operators)	Resume the given Operators on the StreamBase server
void	HAAdmin.resumeOperators(long timeoutMS, List<String> operatorsNames)
void	StreamBaseAdminClient.resumeOperators(List<String> operatorNames)	Resume the given Operators on the StreamBase server
void	XmlRpcAdmin.resumeOperators(long timeoutMS, List<String> operatorNames)
void	Admin.setDynamicVariable(long timeoutMS, com.streambase.sb.util.Path dynamicVariablePath, Object value)	Set the value of the given dynamic variable to the given value.
void	HAAdmin.setDynamicVariable(long timeoutMS, com.streambase.sb.util.Path dynamicVariablePath, Object value)
void	StreamBaseClient.setDynamicVariable(String dynvarPath, Object value)	Set the given dynamic variable to a new value
void	XmlRpcAdmin.setDynamicVariable(long timeoutMS, com.streambase.sb.util.Path dynamicVariablePath, Object value)
void	Admin.setOperatorProperty(long timeoutMS, String operatorName, String propertyName, String value)	On the given Operator, set the given property to the given value.
void	HAAdmin.setOperatorProperty(long timeoutMS, String operatorName, String propertyName, String 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 value
void	TupleConnections.setQuiescentLimit(long timeoutMS)	Set connection timeout
void	Admin.setRuntimeParam(long timeoutMS, String paramName, String paramValue, String operator)	set the given runtime param
void	HAAdmin.setRuntimeParam(long timeoutMS, String paramName, String paramValue, String operator)
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	Admin.shutdown(long timeoutMS, String containerName)	Shutdown a StreamBase container or if empty the whole server
String	HAAdmin.shutdown(long timeoutMS, String containerName)
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	Admin.shutdownOperators(long timeoutMS, List<String> operators)	Shut down the given Operators on the StreamBase server.
void	HAAdmin.shutdownOperators(long timeoutMS, List<String> operatorNames)
void	StreamBaseAdminClient.shutdownOperators(List<String> operatorNames)	Shut down the given Operators on the StreamBase server.
void	XmlRpcAdmin.shutdownOperators(long timeoutMS, List<String> operatorNames)
String[]	Admin.status(long timeoutMS, boolean verbose)	Return the status of the StreamBase Server
String[]	BaseClient.status()	Return the status of the StreamBase Server
String[]	BaseClient.status(boolean verbose)	Return the status of the StreamBase Server
String[]	HAAdmin.status(long timeoutMS, boolean verbose)
String[]	XmlRpcAdmin.status(long timeoutMS, boolean verbose)
SubscriptionEntry	Admin.subscribe(long timeoutMS, SubscriptionEntry subscription, List<TupleConnections.StreamTupleConnection> connections)	Subscribe to an output stream.
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
SubscriptionEntry	HAAdmin.subscribe(long timeoutMS, SubscriptionEntry subscription, List<TupleConnections.StreamTupleConnection> connections)
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.
(package private) SubscriptionEntry	TupleConnection.subscribe(long timeoutMS, SubscriptionEntry subscription)	Subscribe to internal control stream
List<?>	XmlRpcAdmin.subscribe(long timeoutMS, SubscriptionEntry subscription)	Subscribe
SubscriptionEntry	XmlRpcAdmin.subscribe(long timeoutMS, SubscriptionEntry subscription, List<TupleConnections.StreamTupleConnection> connections)
(package private) void	TupleConnection.subscribeAll(long timeoutMS, boolean ignoreErrors)	Subscribe to all of the streams in our list
SubscriptionEntry	TupleConnection.subscribeInternalControl(long timeoutMS)	Subscribe internal control stream
void	Admin.suspend(long timeoutMS, String name)	Suspend (pause) a StreamBase container or operator
void	HAAdmin.suspend(long timeoutMS, String name)	Suspend (pause) a StreamBase container or operator
void	StreamBaseAdminClient.suspend(String name)	Suspend (pause) a container or operator within a StreamBase Server
void	XmlRpcAdmin.suspend(long timeoutMS, String name)
void	Admin.suspendOperators(long timeoutMS, List<String> operators)	Suspend the given Operators on the StreamBase Server
void	HAAdmin.suspendOperators(long timeoutMS, List<String> operatorNames)
void	StreamBaseAdminClient.suspendOperators(List<String> operatorNames)	Suspend (pause) the given Operators on the StreamBase Server
void	XmlRpcAdmin.suspendOperators(long timeoutMS, List<String> operatorNames)
StreamProperties[]	Admin.typecheck(long timeoutMS, String application, boolean full)	Typecheck (validate) the given StreamBase Application.
StreamProperties[]	HAAdmin.typecheck(long timeoutMS, String application, boolean full)
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	Admin.unsubscribe(long timeoutMS, StreamProperties props, String logicalstream, List<TupleConnections.StreamTupleConnection> connections)	UnSubscribe to an output stream.
void	DeMUXStreamBaseClient.unsubscribe(StreamProperties logicalProps)
void	DeMUXStreamBaseClient.unsubscribe(String logicalStreamName)
void	HAAdmin.unsubscribe(long timeoutMS, StreamProperties props, String logicalstream, List<TupleConnections.StreamTupleConnection> connections)
void	StreamBaseClient.unsubscribe(StreamProperties logicalProps)	Unsubscribe from the given stream name.
void	StreamBaseClient.unsubscribe(String logicalStreamName)	Unsubscribe from the given stream name.
(package private) void	TupleConnection.unsubscribe(long timeoutMS, StreamProperties props, String logicalStream)	Unsubscribe internal control stream
void	XmlRpcAdmin.unsubscribe(long timeoutMS, StreamProperties props, String logicalstream, List<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

Modifier	Constructor	Description
(package private)	BaseClient(List<StreamBaseURI> uris, ClientSettings settings)	Construct a BaseClient with the given URI
	DeMUXStreamBaseClient(StreamBaseURI streamBaseURI)	Constructor
	DeMUXStreamBaseClient(String uri)	Constructor
	DeMUXStreamBaseClient(List<StreamBaseURI> uris, ClientSettings settings)	Constructor
(package private)	HAAdmin(List<StreamBaseURI> uris)	Constructor
(package private)	SerializedTupleBuffer(StreamProperties props)	Constructor
	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.
(package private)	TupleConnection(StreamBaseURI uri, StreamBaseClient client, TupleConnections connections, long clientReadTimeout)	Constructor
(package private)	XmlRpcAdmin(StreamBaseURI uri)	Constructor

Uses of StreamBaseException in com.streambase.sb.expr

Subclasses of StreamBaseException in com.streambase.sb.expr

Modifier and Type	Class	Description
class	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

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, com.streambase.sb.monitor.StatTuplev3 st)	Fetch the item name using the client
String	StatsUtil.IdentityHelper.getName(com.streambase.sb.monitor.StatTuplev3 st)
String	StatsUtil.IdentityHelper.getNameFromId(long id)	Stats Stream v3 only.
Map<Integer,String>	StatsUtil.IdentityHelper.IdentityUpdater.getUpdateByContainerId(int containerId)
(package private) boolean	Snapshot.isDone(Snapshot.Source source)	Is result processing complete?
Iterator<Tuple>	Snapshot.Source.nextResult()	Get next result
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

Modifier	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
final class	Operator.PropertyTypecheckException	A typecheck exception associated with an Operator property (or parameter) by name.
class	ParameterInterpretationException	Parameter interpretation exception
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	ITupleDataInitializer.ITupleHandler.accept(Tuple inputTuple, Tuple outputTuple)
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
void	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.
Connection	Operator.getDataSourceConnection(String datasource)	Retrieve a connection to a JDBC Data Source configured in HOCON configuration files.
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
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.
default Tuple	ITupleDataInitializer.newOutputTuple(Tuple inputTuple)	Deprecated. Use a combination of ITupleDataInitializer.newOutputTuple() and ITupleDataInitializer.fillOutputTuple(Tuple, Tuple, ITupleHandler)
default Tuple	ITupleDataInitializer.newOutputTuple(Tuple inputTuple, ITupleDataInitializer.ITupleHandler handler)	Deprecated. Use a combination of ITupleDataInitializer.newOutputTuple() and ITupleDataInitializer.fillOutputTuple(Tuple, Tuple, ITupleHandler)
ITupleDataInitializer	Operator.newTupleDataInitializer(int inputPort, int outputPort)	Create a new ITupleDataInitializer 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)
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.
final void	Operator.registerRunnable(Runnable operatorRunnable)	Deprecated. As of StreamBase version 3.7, replaced by Operator.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.
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
(package private) void	Operator.OperatorThread.waitForAcceptance()	Block until the operator thread has successfully switched into the new state requested by postStateChange.

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

Modifier	Constructor	Description
	TypecheckException(StreamBaseException cause)	Constructor

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

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

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.