Index (StreamBase Java API)

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

PREV NEXT

FRAMES NO FRAMES

A B C D E F G H I K L M N O P Q R S T U V W X

A

ADD_CONTAINER - Static variable in interface com.streambase.sb.client.XmlRpcCommands
addContainer(String, String, List) - Method in class com.streambase.sb.client.StreamBaseAdminClient: Add the given application to the given container in the StreamBaseServer
addContainer(String, String, List) - Method in class com.streambase.sb.client.XmlRpcAdmin
addHeader(String, String) - Method in class com.streambase.sb.client.XmlRpcAdmin
addMonitorListener(MonitorListener) - Method in class com.streambase.sb.monitor.StreamBaseMonitor: Add a listener for snapshot information.
AggregateWindow - Class in com.streambase.sb.operator: Abstract base class for all custom java aggregate functions.
AggregateWindow() - Constructor for class com.streambase.sb.operator.AggregateWindow
allTypes() - Static method in class com.streambase.sb.DataType: Return a read-only Collection of all the types that StreamBase supports.
array() - Method in class com.streambase.sb.ByteArrayView: Returns a reference to the backing array for this view.
AUTHENTICATE - Static variable in interface com.streambase.sb.client.XmlRpcCommands

B

BLOB - Static variable in class com.streambase.sb.DataType: Blob type of undefined length.
BOOL - Static variable in class com.streambase.sb.DataType: Boolean type, four bytes.
BufferTooSmallException - Exception in com.streambase.sb: An exception that is thrown when a string field in a tuple is set with a value that is too large.
BufferTooSmallException(String) - Constructor for exception com.streambase.sb.BufferTooSmallException
BufferTooSmallException(String, Throwable) - Constructor for exception com.streambase.sb.BufferTooSmallException
BufferTooSmallException(Throwable) - Constructor for exception com.streambase.sb.BufferTooSmallException
ByteArrayView - Class in com.streambase.sb: This class represents a StreamBase blob.
ByteArrayView() - Constructor for class com.streambase.sb.ByteArrayView

C

canDequeue() - Method in class com.streambase.sb.client.StreamBaseClient: Return true if we can call dequeue without blocking.
checkClientTrusted(X509Certificate[], String) - Method in class com.streambase.sb.client.SSLUtils.CertificateChecker
checkOpen() - Method in class com.streambase.sb.client.SocketChannelWrapper
checkOpen() - Method in class com.streambase.sb.client.SSLSocketWrapper
checkOpen() - Method in interface com.streambase.sb.client.TupleIO
checkpoint(String) - Method in class com.streambase.sb.client.StreamBaseAdminClient: Checkpoint (backup) a StreamBase Server
checkpoint(String) - Method in class com.streambase.sb.client.XmlRpcAdmin: Checkpoint (backup) a StreamBase Server.
CHECKPOINT - Static variable in interface com.streambase.sb.client.XmlRpcCommands
checkServerTrusted(X509Certificate[], String) - Method in class com.streambase.sb.client.SSLUtils.CertificateChecker
checkTuple(Tuple) - Method in class com.streambase.sb.client.StreamBaseClient.TupleBuffer: Check tuple to make sure it is up to snuff
checkType(DataType) - Method in class com.streambase.sb.Schema.Field: Check to make sure that the given type is the same as the type of this Field
clear() - Method in class com.streambase.sb.ReadOnlyTupleRep
clear() - Method in class com.streambase.sb.Tuple: Set all of this tuples fields to NULL
clear() - Method in class com.streambase.sb.TupleRep
ClientConnectException - Exception in com.streambase.sb.client
ClientConnectException(String) - Constructor for exception com.streambase.sb.client.ClientConnectException
ClientConnectException(String, Throwable) - Constructor for exception com.streambase.sb.client.ClientConnectException
ClientConnectException(Throwable) - Constructor for exception com.streambase.sb.client.ClientConnectException
ClientProperties - Class in com.streambase.sb.client
ClientProperties() - Constructor for class com.streambase.sb.client.ClientProperties
clone() - Method in class com.streambase.sb.monitor.ModuleInfo
clone() - Method in class com.streambase.sb.monitor.ThreadInfo
clone() - Method in class com.streambase.sb.ReadOnlyTupleRep
clone() - Method in class com.streambase.sb.Tuple: Clone this tuple, the new tuple will not share any buffers or data with the original
clone() - Method in class com.streambase.sb.TupleRep
close() - Method in class com.streambase.sb.client.SocketChannelWrapper
close() - Method in class com.streambase.sb.client.SSLSocketWrapper
close() - Method in class com.streambase.sb.client.StreamBaseAdminClient: Close/shutdown the connection to the StreamBase server.
close() - Method in class com.streambase.sb.client.StreamBaseClient: Flush all buffers and close the connection to the StreamBase server.
close() - Method in interface com.streambase.sb.client.TupleIO
close() - Method in class com.streambase.sb.monitor.StreamBaseMonitor: close this monitor
close() - Method in class com.streambase.sb.TupleCSVCharWriter: Close the stream.
close() - Method in class com.streambase.sb.TupleCSVOutputWriter: Close the stream.
CLOSED - Static variable in class com.streambase.sb.client.DequeueResult: Status code indicating that the connection was closed
CLUSTER_FINDENTITY - Static variable in interface com.streambase.sb.client.XmlRpcCommands
CLUSTER_FINDENTITY_NODEMANAGER_INDEX - Static variable in interface com.streambase.sb.client.XmlRpcCommands
CLUSTER_FINDENTITY_SBD_INDEX - Static variable in interface com.streambase.sb.client.XmlRpcCommands
CLUSTER_SHUTDOWN - Static variable in interface com.streambase.sb.client.XmlRpcCommands
CLUSTER_SHUTDOWN_NODES - Static variable in interface com.streambase.sb.client.XmlRpcCommands
CLUSTER_START - Static variable in interface com.streambase.sb.client.XmlRpcCommands
clusterFindEntity(String) - Method in class com.streambase.sb.client.XmlRpcAdmin: Get the address of a Stream.
clustershutdown() - Method in class com.streambase.sb.client.StreamBaseAdminClient: Shutdown a StreamBase cluster.
clustershutdown() - Method in class com.streambase.sb.client.XmlRpcAdmin: Shutdown a StreamBaseCluster.
clusterstart(String) - Method in class com.streambase.sb.client.StreamBaseAdminClient: Ask the StreamBase Cluster Manager to start all the nodes in the cluster.
clusterStart(String) - Method in class com.streambase.sb.client.XmlRpcAdmin: Ask the StreamBase Cluster Manager to start all the nodes in the cluster.
com.streambase.sb - package com.streambase.sb: Provides classes and interfaces fundamental to the StreamBase Java API.
com.streambase.sb.adapter - package com.streambase.sb.adapter
com.streambase.sb.client - package com.streambase.sb.client: Provides classes and interfaces used to communicate with a StreamBase server.
com.streambase.sb.monitor - package com.streambase.sb.monitor: Provides classes and interfaces to monitor the behavior of a running StreamBase server.
com.streambase.sb.operator - package com.streambase.sb.operator: Provides classes and interfaces to add custom operators to StreamBase applications.
com.streambase.sb.operator.parameter - package com.streambase.sb.operator.parameter: Provides classes and interfaces to specify parameters for custom operators.
compareTo(ByteArrayView) - Method in class com.streambase.sb.ByteArrayView: compare this ByteArrayView to another lexigraphically NB: no data is copied when doing this
CONNECTION_ID_STRING - Static variable in class com.streambase.sb.client.XmlRpcAdmin
CONTAINER - Static variable in class com.streambase.sb.EntityType: Represents a StreamBase Schema.
containerNames() - Method in class com.streambase.sb.monitor.Snapshot: Return a list of the names of the current containers
copy(int, int) - Method in class com.streambase.sb.ByteArrayView: Create a new ByteArrayView which wraps a new byte[] containing a copy of this view's data NB: this method copies the underlying data
copy() - Method in class com.streambase.sb.ByteArrayView: Create a new ByteArrayView which wraps a new byte[] containing a copy of this view's data NB: this method copies the underlying data
copyBytes(int, int) - Method in class com.streambase.sb.ByteArrayView: Create a new byte[] containing a copy of this view's data within the provided window.
copyBytes() - Method in class com.streambase.sb.ByteArrayView: Create a new byte[] containing a copy of this view's data.
createField(DataType, String) - Static method in class com.streambase.sb.Schema: Creates a new Field of the given DataType, with the given name.
createField(DataType, String, int) - Static method in class com.streambase.sb.Schema: Creates a new Field of the given DataType, with the given name and the given size.
createTuple() - Method in class com.streambase.sb.Schema: Create a Tuple with this schema.
createTuple(String[], int, int) - Method in class com.streambase.sb.Schema: Create a Tuple with this schema, obtaining its field values from an array.
createTuple(String[], int, int, String) - Method in class com.streambase.sb.Schema: Create a Tuple with this schema, obtaining its field values from an array.
createWritableTuple() - Method in class com.streambase.sb.ReadOnlyTupleRep
createWritableTuple() - Method in class com.streambase.sb.Tuple: Return a new tuple that is guaranteed to be writable
createWritableTuple() - Method in class com.streambase.sb.TupleRep
currentSize() - Method in class com.streambase.sb.client.StreamBaseClient.TupleBuffer: Get current size of this buffer

D

DataType - Class in com.streambase.sb: An enumeration that represents the types that StreamBase supports.
DEFAULT_CONTAINER - Static variable in class com.streambase.sb.client.StreamBaseURI: The default container ("default")
DEFAULT_HOST - Static variable in class com.streambase.sb.client.StreamBaseURI: The default StreamBase server ("localhost").
DEFAULT_PORT - Static variable in class com.streambase.sb.client.StreamBaseURI: The default StreamBase TCP port number (10000).
DEFAULT_STATE_CHANGE_TIMEOUT - Static variable in class com.streambase.sb.operator.Operator: Default value for the timeout for Operator state changes, in milliseconds.
DEFAULT_URI - Static variable in class com.streambase.sb.client.StreamBaseURI: The default URI (pointing to localhost, no container, port 10000).
dequeue() - Method in class com.streambase.sb.client.StreamBaseClient: Dequeue a batch of tuples from a subscribed stream.
dequeue(int) - Method in class com.streambase.sb.client.StreamBaseClient: Dequeue a batch of tuples from a subscribed stream.
DequeueResult - Class in com.streambase.sb.client: Encapsulates the data returned from a dequeue() operation.
describe(String) - Method in class com.streambase.sb.client.StreamBaseClient: Return an XML description of a StreamBase entity
describe(String) - Method in class com.streambase.sb.client.XmlRpcAdmin: Return an XML description of a StreamBase entity
DESCRIBE - Static variable in interface com.streambase.sb.client.XmlRpcCommands
description(String) - Method in class com.streambase.sb.operator.parameter.SBPropertyDescriptor: Calls setShortDescription method, but can be chained as in: new SBPropertyDescriptor("value", Bean.class).description("useful value to set")
displayName(String) - Method in class com.streambase.sb.operator.parameter.SBPropertyDescriptor: Calls setDisplayName method, but can be chained as in: new SBPropertyDescriptor("value", Bean.class).displayName("Important Value")
DOUBLE - Static variable in class com.streambase.sb.DataType: Double type, eight bytes.
drain() - Method in class com.streambase.sb.client.StreamBaseAdminClient: Drain a StreamBase Server
drain(String) - Method in class com.streambase.sb.client.StreamBaseAdminClient: Drain a container within a StreamBase Server
drain(String) - Method in class com.streambase.sb.client.XmlRpcAdmin
DRAIN - Static variable in interface com.streambase.sb.client.XmlRpcCommands
DROPPING_TUPLES - Static variable in class com.streambase.sb.operator.Operator.SuspendBehaviorStates: Drop tuples when the Operator is suspended.

E

enableBuffering(int, int) - Method in class com.streambase.sb.client.StreamBaseClient: Turn on buffering.
enableBuffering(int) - Method in class com.streambase.sb.client.StreamBaseClient: Turn on buffering with a default WakeAndFlushBuffer thread set to 250ms
enqueue(String, Tuple) - Method in class com.streambase.sb.client.StreamBaseClient: Enqueue a single Tuple onto a stream.
enqueue(StreamProperties, Tuple) - Method in class com.streambase.sb.client.StreamBaseClient: Enqueue a single Tuple onto a stream.
enqueue(String, Collection) - Method in class com.streambase.sb.client.StreamBaseClient: Enqueue a collection of Tuples onto a stream.
enqueue(StreamProperties, Collection) - Method in class com.streambase.sb.client.StreamBaseClient: Enqueue a collection of Tuples onto a stream.
EntityType - Class in com.streambase.sb: An enumeration that represents the kinds of entities that StreamBase supports.
EnumPropertyDescriptor - Class in com.streambase.sb.operator.parameter: Metadata for parameters that has one of a fixed set of String values.
EnumPropertyDescriptor(String, Class, String[]) - Constructor for class com.streambase.sb.operator.parameter.EnumPropertyDescriptor: Construct an enumerated property descriptor.
EnumPropertyDescriptor(String, Class, String, String, String[]) - Constructor for class com.streambase.sb.operator.parameter.EnumPropertyDescriptor: Construct an enumerated property descriptor with customized read/write method names.
equals(Object) - Method in class com.streambase.sb.ByteArrayView: check if two ByteArrayViews are byte-for-byte identical NB: this may devolve to a byte by byte comparison
equals(Object) - Method in class com.streambase.sb.client.StreamBaseClient.TupleBuffer
equals(Object) - Method in class com.streambase.sb.DataType: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in class com.streambase.sb.monitor.ModuleInfo.QueueInfo
equals(Object) - Method in class com.streambase.sb.Schema
equals(Object) - Method in class com.streambase.sb.StreamProperties
equals(Object) - Method in class com.streambase.sb.Tuple: Test whether the given object is equal to this one.

F

failover() - Method in class com.streambase.sb.client.XmlRpcAdmin: Failover a primary HA node to a Secondary
FAILOVER - Static variable in interface com.streambase.sb.client.XmlRpcCommands
fields() - Method in class com.streambase.sb.Schema: Return a List of the Fields in this Schema
fieldValuesEqual(Tuple, Tuple, int) - Method in class com.streambase.sb.DataType: Compare a particular field in two different tuples Note: the field should be the same type as this DataType
finalize() - Method in class com.streambase.sb.monitor.StreamBaseMonitor
flush() - Method in class com.streambase.sb.TupleCSVCharWriter: Flush the stream.
flush() - Method in class com.streambase.sb.TupleCSVOutputWriter: Flush the stream.
flushAllBuffers() - Method in class com.streambase.sb.client.StreamBaseClient: Flush all pending enqueue buffers
flushBuffer(String) - Method in class com.streambase.sb.client.StreamBaseClient: Flush any pending enqueue buffer for the stream name provided
flushBuffer(StreamProperties) - Method in class com.streambase.sb.client.StreamBaseClient: Flush any pending enqueue buffer for the stream name provided
forName(String) - Static method in class com.streambase.sb.DataType: For the given name return a DataType Object.
forName(String) - Static method in class com.streambase.sb.EntityType: Retrieve an EntityType for the given entity name
forType(Object) - Static method in class com.streambase.sb.DataType: Return the appropriate DataType for the given type.
forType(Class) - Static method in class com.streambase.sb.DataType: Return the appropriate DataType for the given clazz.
fromEnvironment() - Static method in class com.streambase.sb.client.StreamBaseURI: Returns the URI found in the streambase.uri system property, or DEFAULT_URI if none is found.
fromString(String) - Static method in class com.streambase.sb.Timestamp: Create a timestamp using the given string
FULLY_QUALIFIED_NAMES - Static variable in class com.streambase.sb.client.StreamBaseClient: Flag for listEntities.

G

GET_OPERATOR_PROPERTIES - Static variable in interface com.streambase.sb.client.XmlRpcCommands
GET_OPERATOR_PROPERTY - Static variable in interface com.streambase.sb.client.XmlRpcCommands
GET_SCHEMA_BY_HASH - Static variable in interface com.streambase.sb.client.XmlRpcCommands
GET_SCHEMA_BY_NAME - Static variable in interface com.streambase.sb.client.XmlRpcCommands
GET_STREAM_PROPERTIES - Static variable in interface com.streambase.sb.client.XmlRpcCommands
GET_STREAM_PROPERTIES_BY_HASH - Static variable in interface com.streambase.sb.client.XmlRpcCommands
getAcceptedIssuers() - Method in class com.streambase.sb.client.SSLUtils.CertificateChecker
getArgs(SBPropertyDescriptor, HashMap) - Method in class com.streambase.sb.operator.parameter.SBPropertyDescriptor.SingleValueSetter
getBasicAuthenticationString() - Method in class com.streambase.sb.client.StreamBaseURI: Returns a Base64-encoded username + password if authentication is enabled, or null otherwise.
getBlobBuffer(Schema.Field) - Method in class com.streambase.sb.ReadOnlyTupleRep
getBlobBuffer(String) - Method in class com.streambase.sb.Tuple: Return a ByteArrayView for a given Blob field
getBlobBuffer(int) - Method in class com.streambase.sb.Tuple: Return a ByteArrayView for a given Blob field
getBlobBuffer(Schema.Field) - Method in class com.streambase.sb.Tuple: Return a ByteArrayView for a given Blob field
The Schema.Field objects used to set and get Tuple field values must be obtained via the Tuple's Schema object.
getBlobBuffer(Schema.Field) - Method in class com.streambase.sb.TupleRep
getBoolean(Schema.Field) - Method in class com.streambase.sb.ReadOnlyTupleRep
getBoolean(String) - Method in class com.streambase.sb.Tuple: Return a boolean for the given boolean field name
getBoolean(int) - Method in class com.streambase.sb.Tuple: Return a boolean for the given fieldIndex
getBoolean(Schema.Field) - Method in class com.streambase.sb.Tuple: Return a boolean for the given boolean field
The Schema.Field objects used to set and get Tuple field values must be obtained via the Tuple's Schema object.
getBoolean(Schema.Field) - Method in class com.streambase.sb.TupleRep
getBooleanAsByte(Schema.Field) - Method in class com.streambase.sb.ReadOnlyTupleRep
getBooleanAsByte(Schema.Field) - Method in class com.streambase.sb.TupleRep
getByteOrder() - Method in class com.streambase.sb.client.XmlRpcAdmin
getByteOrder() - Method in class com.streambase.sb.ReadOnlyTupleRep
getByteOrder() - Method in class com.streambase.sb.TupleRep
getConnectionID() - Method in class com.streambase.sb.client.StreamBaseClient: Return the Connection ID for this Client Connection.
getContainer() - Method in class com.streambase.sb.client.StreamBaseURI: Returns the container name component of the URI.
getContainerName() - Method in class com.streambase.sb.StreamProperties: Return the container name part of the name
getCurrentQueueLength() - Method in class com.streambase.sb.monitor.ModuleInfo.QueueInfo: Return the approximate number of tuples currently in this queue.
getCycle() - Method in class com.streambase.sb.monitor.Snapshot: Returns the cycle number of this snapshot.
getDataLength() - Method in class com.streambase.sb.client.StreamBaseClient.TupleBuffer
getDataType() - Method in class com.streambase.sb.Schema.Field: Return the DataType of the Field
getDequeueClientCount() - Method in class com.streambase.sb.monitor.SystemInfo: Returns the current number of dequeuing clients
getDisplayName() - Method in class com.streambase.sb.operator.Operator: Return the display name of this Operator.
getDouble(Schema.Field) - Method in class com.streambase.sb.ReadOnlyTupleRep
getDouble(String) - Method in class com.streambase.sb.Tuple: Return a double for the given double field name
getDouble(int) - Method in class com.streambase.sb.Tuple: Return a double for the given double fieldIndex
getDouble(Schema.Field) - Method in class com.streambase.sb.Tuple: Return a double for the given double field
The Schema.Field objects used to set and get Tuple field values must be obtained via the Tuple's Schema object.
getDouble(Schema.Field) - Method in class com.streambase.sb.TupleRep
getField(int) - Method in class com.streambase.sb.Schema: Return a Field object at the given index
getField(String) - Method in class com.streambase.sb.Schema: Return a Field object with the given name
getField() - Method in exception com.streambase.sb.Schema.ValidateFieldList.ValidationException: the field that caused the error
getField(String) - Method in class com.streambase.sb.Tuple: Return an object containing the value of the specified field name.
getField(int) - Method in class com.streambase.sb.Tuple: Return an object containing the value of the specified fieldIndex This is a String, Integer, Double, Boolean, or Timestamp object depending on the field type.
getField(Schema.Field) - Method in class com.streambase.sb.Tuple: Return an object containing the value of the specified field.
getFieldAsObject(Tuple, Schema.Field) - Method in class com.streambase.sb.DataType: Extract a field from the tuple as an Object of the appropriate type Note: the field should be the same type as this DataType
getFieldAsString(Tuple, Schema.Field, Tuple.TupleFormatter) - Method in class com.streambase.sb.DataType: Extract a field from the tuple and return a String intended to represent its value in a human readable manner using the provided formatter.
getFieldCount() - Method in class com.streambase.sb.Schema: Return the number of Fields within the Schema.
getFieldIndex(String) - Method in class com.streambase.sb.Schema: Return the index within the Schema of the Field with the given name
getFields() - Method in class com.streambase.sb.Schema: Return an array of Field objects corresponding to the fields in the schema.
getFieldTypes() - Method in class com.streambase.sb.Schema: A utility function to speed up multiple accesses to field types of a schema in contexts where multiple tuples are processed; the function should be called outside of for loops processing tuples and their fields
getFreeMemory() - Method in class com.streambase.sb.monitor.SystemInfo: Returns the amount of free memory in the StreamBase server process.
getHash() - Method in class com.streambase.sb.Schema: Return the hash for this schema generated by the server.
getHost() - Method in class com.streambase.sb.client.StreamBaseURI: Returns the host name component of the URI.
getIndex() - Method in class com.streambase.sb.Schema.Field: Return the index of this field within the Schema
getInputPortCount() - Method in class com.streambase.sb.monitor.OperatorInfo: Returns the number of input ports on this operator.
getInputPortCount() - Method in class com.streambase.sb.operator.Operator: Return the number of input ports.
getInputSchema(int) - Method in class com.streambase.sb.operator.Operator: Returns the schema of an input port.
getInputTuplesDequeuedDelta() - Method in class com.streambase.sb.monitor.OperatorInfo: Returns the number of input tuples consumed by this operator since the previous Snapshot.
getInputTuplesDequeuedTotal() - Method in class com.streambase.sb.monitor.OperatorInfo: Returns the total number of input tuples consumed by this operator since the StreamBase Server was started.
getInputTuplesEnqueuedDelta() - Method in class com.streambase.sb.monitor.OperatorInfo: Returns the number of tuples enqueued on this operator's input streams since the previous Snapshot.
getInputTuplesEnqueuedTotal() - Method in class com.streambase.sb.monitor.OperatorInfo: Returns the total number of input tuples enqueued on this operator's input streams since the StreamBase Server was started.
getInt(Schema.Field) - Method in class com.streambase.sb.ReadOnlyTupleRep
getInt(String) - Method in class com.streambase.sb.Tuple: Return a int for the given int field name
getInt(int) - Method in class com.streambase.sb.Tuple: Return a int for the given int fieldIndex
getInt(Schema.Field) - Method in class com.streambase.sb.Tuple: Return a int for the given int field
The Schema.Field objects used to set and get Tuple field values must be obtained via the Tuple's Schema object.
getInt(Schema.Field) - Method in class com.streambase.sb.TupleRep
getKeystore() - Method in class com.streambase.sb.client.StreamBaseURI: Return the keystore for the connection.
getKeystorePassphrase() - Method in class com.streambase.sb.client.StreamBaseURI: Return the passphrase for the keystore for the connection.
getLong(Schema.Field) - Method in class com.streambase.sb.ReadOnlyTupleRep
getLong(String) - Method in class com.streambase.sb.Tuple: Return a long for the given long field name
getLong(int) - Method in class com.streambase.sb.Tuple: Return a int for the given int field
The Schema.Field objects used to set and get Tuple field values must be obtained via the Tuple's Schema object.
getLong(Schema.Field) - Method in class com.streambase.sb.Tuple: Return a long for the given long field
The Schema.Field objects used to set and get Tuple field values must be obtained via the Tuple's Schema object.
getLong(Schema.Field) - Method in class com.streambase.sb.TupleRep
getMaxMemory() - Method in class com.streambase.sb.monitor.SystemInfo: Returns the maximum amount of memory which the StreamBase server process is allowed to allocate.
getMaxQueueLength() - Method in class com.streambase.sb.monitor.ModuleInfo.QueueInfo: Return the maximum numbers of tuples that this queue can currently contain.
getModuleInfo(String) - Method in class com.streambase.sb.monitor.Snapshot: Returns information about the specified module.
getModuleQualifiedName() - Method in class com.streambase.sb.StreamProperties: Return the module qualified name of this Stream.
getName() - Method in class com.streambase.sb.DataType: Get the name of this DataType.
getName() - Method in class com.streambase.sb.monitor.ModuleInfo: Returns the name of the thread.
getName() - Method in class com.streambase.sb.monitor.ModuleInfo.QueueInfo: Return the name of this queue
getName() - Method in class com.streambase.sb.monitor.OperatorInfo: Returns the name of the operator.
getName() - Method in class com.streambase.sb.monitor.ThreadInfo: Returns the name of the thread.
getName() - Method in class com.streambase.sb.operator.Operator: Return the name of this Operator.
getName() - Method in class com.streambase.sb.Schema.Field: Return the name of the Field
getName() - Method in class com.streambase.sb.Schema: Return the name of the Schema
getName() - Method in class com.streambase.sb.StreamProperties: Return the stream name part of the name
getNumFields() - Method in class com.streambase.sb.Schema: Deprecated. Since 5.0 use @see com.streambase.sb.Schema#getFieldCount()
getNumTasks() - Method in class com.streambase.sb.monitor.ModuleInfo: Return the number of tasks on the task queue
getOperatorInfo(String) - Method in class com.streambase.sb.monitor.Snapshot: Returns information about the specified operator.
getOperatorProperties(String) - Method in class com.streambase.sb.client.StreamBaseAdminClient: For the given Operator, return its set of properties and their values.
getOperatorProperties(String) - Method in class com.streambase.sb.client.XmlRpcAdmin: For the given Operator, return its set of properties and their values.
getOperatorProperty(String, String) - Method in class com.streambase.sb.client.StreamBaseAdminClient: Return the value of the given property on the given Operator.
getOperatorProperty(String, String) - Method in class com.streambase.sb.client.XmlRpcAdmin: Return the value of the given property on the given Operator.
getOutputPortCount() - Method in class com.streambase.sb.monitor.OperatorInfo: Returns the number of output ports on this operator.
getOutputPortCount() - Method in class com.streambase.sb.operator.Operator: Returns the number of output ports.
getOutputSchema(int) - Method in class com.streambase.sb.operator.Operator: Return the output schema.
getOutputTuplesEnqueuedDelta() - Method in class com.streambase.sb.monitor.OperatorInfo: Returns the number of output tuples produced by this operator since the previous Snapshot.
getOutputTuplesEnqueuedTotal() - Method in class com.streambase.sb.monitor.OperatorInfo: Returns the total number of output tuples produced by this operator since the StreamBase Server was started.
getParam(String) - Method in class com.streambase.sb.client.StreamBaseURI: Returns a parameter with a given key, or null if none exists.
getParameters() - Method in class com.streambase.sb.operator.Operator: Returns the Java Bean that holds the user-configurable parameters visible in the StreamBase Studio Properties View of this operator.
getParams() - Method in class com.streambase.sb.client.StreamBaseURI: Returns an unmodifiable map of all parameters.
getParams() - Method in exception com.streambase.sb.StreamBaseException
getPassword() - Method in class com.streambase.sb.client.StreamBaseURI: Return the password for the connection.
getPercentCPU() - Method in class com.streambase.sb.monitor.ThreadInfo: Returns the percent of CPU used by this thread, in microseconds.
getPercentSystem() - Method in class com.streambase.sb.monitor.ThreadInfo: Returns the percent of system CPU time used by this thread, in microseconds.
getPercentUsage() - Method in class com.streambase.sb.monitor.OperatorInfo: The percentage usage is then profiler hits/ total profiler hits.)
getPercentUser() - Method in class com.streambase.sb.monitor.ThreadInfo: Returns the percent of user CPU time used by this thread, in microseconds.
getPort() - Method in class com.streambase.sb.client.StreamBaseURI: Returns the port number.
getPortCounts() - Method in class com.streambase.sb.operator.Operator: An optional method that subclasses can override to dynamically tell Studio the number of input and output ports.
getPrimaryURI() - Method in class com.streambase.sb.client.StreamBaseURI: Create a URI from this URI that strips out the secondary host/port information
getProcessSize() - Method in class com.streambase.sb.monitor.SystemInfo: Deprecated. As of StreamBase 3.0, use getTotalMemory(), which returns a size in bytes.
getProfilerHits() - Method in class com.streambase.sb.monitor.OperatorInfo: Number of miniticks used by the operator, as determined by profiler samples.
getQualifiedName() - Method in class com.streambase.sb.StreamProperties: Return the fully qualified name of this Stream.
getResourceContents(String) - Method in class com.streambase.sb.operator.Operator: Returns an open input stream on the contents of the named resource file.
getReuseTuple() - Method in class com.streambase.sb.operator.Operator: Get the state of the input Tuple reuse flag.
getSchema() - Method in class com.streambase.sb.client.DequeueResult: Returns the schema for the tuples dequeued
getSchema() - Method in class com.streambase.sb.StreamProperties: Return the stream's Schema
getSchema() - Method in class com.streambase.sb.Tuple: Return the Schema for this Tuple
getSchemaByHash(byte[]) - Method in class com.streambase.sb.client.StreamBaseClient: Return the Schema object for the given hash value
getSchemaByHash(byte[]) - Method in class com.streambase.sb.client.XmlRpcAdmin: Return the Schema object for the given hash value
getSchemaByName(String) - Method in class com.streambase.sb.client.StreamBaseClient: Return the Schema object for the given name
getSchemaByName(String) - Method in class com.streambase.sb.client.XmlRpcAdmin: Return the Schema object for the given name
getSchemaForStream(String) - Method in class com.streambase.sb.client.StreamBaseClient: Return the schema of a stream.
getSecondaryHostName() - Method in class com.streambase.sb.client.StreamBaseURI: Return the secondary HA host.
getSecondaryHostPort() - Method in class com.streambase.sb.client.StreamBaseURI: Return the secondary HA host's port.
getSecondaryURI() - Method in class com.streambase.sb.client.StreamBaseURI: Create a URI from this URI that uses the secondary host/port name as the Primary If there is no secondary host/port it will use the primary host/port.
getSessionState() - Method in class com.streambase.sb.operator.Operator: Retreive session state for this operator that has the same object extent as the application, not the instance (which may be repeatedly destroyed and recreated).
getSize() - Method in class com.streambase.sb.DataType: Get the size in bytes of this DataType.
getSize() - Method in class com.streambase.sb.monitor.OperatorInfo: Returns the size the operator.
getSize() - Method in class com.streambase.sb.Schema.Field: The size of the field (in bytes) of the Field without any header information.
getSizeUpperBound() - Method in class com.streambase.sb.ReadOnlyTupleRep
getStatus() - Method in class com.streambase.sb.client.DequeueResult: Return the status of this DequeueResult.
getStatus() - Method in class com.streambase.sb.monitor.OperatorInfo: Returns the status of the operator.
getStreamName() - Method in class com.streambase.sb.client.DequeueResult: Returns the name of the stream on which tuples were dequeued.
getStreamProperties() - Method in class com.streambase.sb.client.DequeueResult: Return the StreamProperties for this DequeueResult
getStreamProperties(String) - Method in class com.streambase.sb.client.StreamBaseClient: Return the StreamProperties for the given stream name
getStreamProperties(String) - Method in class com.streambase.sb.client.XmlRpcAdmin: Return the StreamProperties for the given name
getStreamPropertiesByHash(String) - Method in class com.streambase.sb.client.StreamBaseClient: Return the StreamProperties for the given hash
getStreamPropertiesByHash(byte[]) - Method in class com.streambase.sb.client.StreamBaseClient: Return the StreamProperties for the given hash
getStreamPropertiesByHash(byte[]) - Method in class com.streambase.sb.client.XmlRpcAdmin: Return the StreamProperties for the given hash
getString(Schema.Field) - Method in class com.streambase.sb.ReadOnlyTupleRep
getString(String) - Method in class com.streambase.sb.Tuple: Return a String for the given field name.
getString(int) - Method in class com.streambase.sb.Tuple: Return a String for the given fieldIndex.
getString(Schema.Field) - Method in class com.streambase.sb.Tuple: Return a String for the given field.
getString(Schema.Field) - Method in class com.streambase.sb.TupleRep
getStringBuffer(Schema.Field) - Method in class com.streambase.sb.ReadOnlyTupleRep
getStringBuffer(String) - Method in class com.streambase.sb.Tuple: Return a ByteArrayView for a given String field name
getStringBuffer(int) - Method in class com.streambase.sb.Tuple: Return a ByteArrayView for a given String fieldIndex
getStringBuffer(Schema.Field) - Method in class com.streambase.sb.Tuple: Return a ByteArrayView for a given String field
The Schema.Field objects used to set and get Tuple field values must be obtained via the Tuple's Schema object.
getStringBuffer(Schema.Field) - Method in class com.streambase.sb.TupleRep
getStringBytes(Schema.Field) - Method in class com.streambase.sb.ReadOnlyTupleRep
getStringBytes(String) - Method in class com.streambase.sb.Tuple: Deprecated. As of StreamBase 5.0, use Tuple.getString(java.lang.String) instead
getStringBytes(int) - Method in class com.streambase.sb.Tuple: Deprecated. As of StreamBase 5.0, use Tuple.getString(java.lang.String) instead
getStringBytes(Schema.Field) - Method in class com.streambase.sb.Tuple: Deprecated. As of StreamBase 5.0, use Tuple.getString(java.lang.String) instead
getStringBytes(Schema.Field) - Method in class com.streambase.sb.TupleRep
getStringBytesForCodeGen(Schema.Field) - Method in class com.streambase.sb.ReadOnlyTupleRep
getStringBytesForCodeGen(Schema.Field) - Method in class com.streambase.sb.TupleRep
getStringOffLenForCodeGen(Schema.Field) - Method in class com.streambase.sb.ReadOnlyTupleRep
getStringOffLenForCodeGen(Schema.Field) - Method in class com.streambase.sb.TupleRep
getSystemInfo() - Method in class com.streambase.sb.monitor.Snapshot: The SystemInfo object for this snapshot.
getSystemTimeDelta() - Method in class com.streambase.sb.monitor.ThreadInfo: Returns the system time spent by thread since the last Snapshot, in microseconds.
getSystemTimeTotal() - Method in class com.streambase.sb.monitor.ThreadInfo: Returns the system time spent by this thread since the StreamBase Server started, in microseconds.
getThreadInfo(String) - Method in class com.streambase.sb.monitor.Snapshot: Returns information about the specified thread.
getTimeRunning() - Method in class com.streambase.sb.monitor.SystemInfo: Returns the time that the StreamBase Server has been running, in seconds.
getTimestamp() - Method in class com.streambase.sb.monitor.Snapshot: Return the time when this snapshot was taken.
getTimestamp(Schema.Field) - Method in class com.streambase.sb.ReadOnlyTupleRep
getTimestamp(String) - Method in class com.streambase.sb.Tuple: Return a Timestamp for the given Timestamp field name
getTimestamp(int) - Method in class com.streambase.sb.Tuple: Return a Timestamp for the given Timestamp fieldIndex
getTimestamp(Schema.Field) - Method in class com.streambase.sb.Tuple: Return a Timestamp for the given Timestamp field
The Schema.Field objects used to set and get Tuple field values must be obtained via the Tuple's Schema object.
getTimestamp(Schema.Field) - Method in class com.streambase.sb.TupleRep
getTimestampAsLong(Schema.Field) - Method in class com.streambase.sb.ReadOnlyTupleRep
getTimestampAsLong(Schema.Field) - Method in class com.streambase.sb.TupleRep
getTotalMemory() - Method in class com.streambase.sb.monitor.SystemInfo: Returns the total amount of memory available for use in the StreamBase server process.
getTotalProfilerHits() - Method in class com.streambase.sb.monitor.OperatorInfo: Number of miniticks used by all operators in the contained ProfileState.
getTransport() - Method in class com.streambase.sb.client.SBHTTPTransportFactory
getTuple(int) - Method in class com.streambase.sb.client.DequeueResult: Deprecated. please use iterator() to access Tuples sequentially
getTuple() - Method in class com.streambase.sb.client.DequeueResult: Deprecated.
getTupleCount() - Method in class com.streambase.sb.client.DequeueResult: Returns the number of tuples dequeued.
getTupleId() - Method in class com.streambase.sb.ReadOnlyTupleRep
getTupleId() - Method in class com.streambase.sb.TupleRep
getTupleLength() - Method in class com.streambase.sb.ReadOnlyTupleRep
getTupleLength() - Method in class com.streambase.sb.TupleRep: Calculate (exact) length of this tuple's serialization in bytes
getType() - Method in class com.streambase.sb.Timestamp: Return the current type of timestamp
getURI() - Method in class com.streambase.sb.client.XmlRpcAdmin
getUsedMemory() - Method in class com.streambase.sb.monitor.SystemInfo: Returns the total amount of memory currently in use in the StreamBase server process.
getUser() - Method in class com.streambase.sb.client.StreamBaseURI: Return the user name for the connection.
getUserTimeDelta() - Method in class com.streambase.sb.monitor.ThreadInfo: Returns the user time spent by thread since the last Snapshot, in microseconds.
getUserTimeTotal() - Method in class com.streambase.sb.monitor.ThreadInfo: Returns the user time spent by thread since the StreamBase Server started, in microseconds.
getValues() - Method in class com.streambase.sb.operator.parameter.EnumPropertyDescriptor: Return the list of allowable values for the property.
getVersion() - Static method in class com.streambase.sb.client.StreamBaseClient: Get the version of this client.
GOOD - Static variable in class com.streambase.sb.client.DequeueResult: Status code indicating a normal dequeue

H

HAServerIOException - Exception in com.streambase.sb.client: Exception thrown when there's an I/O error with a HA server
HAServerIOException(String) - Constructor for exception com.streambase.sb.client.HAServerIOException
HAServerIOException(Throwable) - Constructor for exception com.streambase.sb.client.HAServerIOException
HAServerIOException(String, Throwable) - Constructor for exception com.streambase.sb.client.HAServerIOException
hasField(String) - Method in class com.streambase.sb.Schema: Return true if the Schema has a field with the given name, or false if not.
hashCode() - Method in class com.streambase.sb.ByteArrayView
hashCode() - Method in class com.streambase.sb.client.StreamBaseClient.TupleBuffer
hashCode() - Method in class com.streambase.sb.DataType: compute a hash for this DataType
hashCode() - Method in class com.streambase.sb.monitor.ModuleInfo.QueueInfo
hashCode() - Method in class com.streambase.sb.Schema
hashCode() - Method in class com.streambase.sb.StreamProperties
hashCode() - Method in class com.streambase.sb.Tuple: Compute a hashCode for the object.
hasHeader() - Method in class com.streambase.sb.Schema: Does this Schema have a header?
hasNotYetStarted() - Method in class com.streambase.sb.operator.Operator: Returns true if this Operator has not yet started running.
hasSchema(String) - Method in class com.streambase.sb.client.StreamBaseClient: Returns whether or not a schema with the passed in schemaName is available; you can get this Schema by calling getSchemaByName.
hasStream(String) - Method in class com.streambase.sb.client.StreamBaseClient: Returns whether or not the client has a stream with the passed in name.
hasStreamProperties(String) - Method in class com.streambase.sb.client.StreamBaseClient: Returns whether or not a stream with the given name exists.
HEADER_SIZE - Static variable in class com.streambase.sb.Schema: The header of each tuple has a tuple id which requires a fixed amount of space.

I

INCLUDE_MODULES - Static variable in class com.streambase.sb.client.StreamBaseClient: Flag for listEntities.
init() - Method in class com.streambase.sb.operator.AggregateWindow: Called before each new use of this object.
init() - Method in class com.streambase.sb.operator.Operator: After the Operator has typechecked successfully, but before the application or any managed threads start, the StreamBase server will call the init method.
initHttpHeaders(XmlRpcRequest) - Method in class com.streambase.sb.client.SBHTTPTransport
initSSL() - Static method in class com.streambase.sb.client.SSLUtils
initSSL(String, String) - Static method in class com.streambase.sb.client.SSLUtils
INPUT_STREAMS - Static variable in class com.streambase.sb.EntityType: Represents input streams only.
InputAdapter - Class in com.streambase.sb.adapter: Abstract base class for input adapters.
InputAdapter() - Constructor for class com.streambase.sb.adapter.InputAdapter
inputs - Variable in class com.streambase.sb.operator.PortCounts
INT - Static variable in class com.streambase.sb.DataType: Integer type, four bytes.
INTERNAL_COMMAND - Static variable in interface com.streambase.sb.client.XmlRpcCommands
internalCommand(String[]) - Method in class com.streambase.sb.client.XmlRpcAdmin
INTERVAL - Static variable in class com.streambase.sb.Timestamp: Timestamps can be timestamps or intervals.
isClosed() - Method in class com.streambase.sb.client.StreamBaseClient: Return true if the client connection is closed.
isCluster() - Method in class com.streambase.sb.client.XmlRpcAdmin
isDroppingTuples() - Method in class com.streambase.sb.operator.Operator: Returns true if the Operator will drop any tuples it receives when it is suspended.
isHA() - Method in class com.streambase.sb.client.XmlRpcAdmin
isNull(Schema.Field) - Method in class com.streambase.sb.ReadOnlyTupleRep
isNull(String) - Method in class com.streambase.sb.Tuple: Determines whether a field in the tuple is null.
isNull(int) - Method in class com.streambase.sb.Tuple: Determines whether a field in the tuple is null.
isNull(Schema.Field) - Method in class com.streambase.sb.Tuple: Determines whether a field in the tuple is null.
isNull(Schema.Field) - Method in class com.streambase.sb.TupleRep
isProcessingTuples() - Method in class com.streambase.sb.operator.Operator: Returns true if the Operator will process any tuples it receives when it is suspended.
isReadOnly() - Method in class com.streambase.sb.ReadOnlyTupleRep
isReadOnly() - Method in class com.streambase.sb.Tuple: Returns true if this is a read only tuple (read only tuples throw an UnsupportedOperationException when setter methods are called)
isReadOnly() - Method in class com.streambase.sb.TupleRep
isRequired() - Method in class com.streambase.sb.operator.parameter.SBPropertyDescriptor: Return whether the property is required.
isRunning() - Method in class com.streambase.sb.operator.Operator: Returns true if this Operator is currently running, false otherwise.
isShutdown() - Method in class com.streambase.sb.operator.Operator: Returns true if this Operator is currently shut down, false otherwise.
isSSL() - Method in class com.streambase.sb.client.StreamBaseURI
isSuspended() - Method in class com.streambase.sb.operator.Operator: Returns true if this Operator is currently suspended, false otherwise.
isVariableSize() - Method in class com.streambase.sb.DataType: Return whether this DataType is of variable size or not (currently only for STRING).
iterator() - Method in class com.streambase.sb.client.DequeueResult: Returns an iterator of all tuples.

K

KEYSTORE_PARAM - Static variable in class com.streambase.sb.client.StreamBaseURI: URI parameter used for a keystore for SSL with client authentication (2-way ssl).
KEYSTORE_PASS_PARAM - Static variable in class com.streambase.sb.client.StreamBaseURI: URI parameter used for the passphrase for a keystore for SSL with client authentication (2-way ssl).
KILL_CONNECTIONS - Static variable in interface com.streambase.sb.client.XmlRpcCommands
killAllConnections() - Method in class com.streambase.sb.client.StreamBaseAdminClient: Kill all of the connections on the server
killAllConnections() - Method in class com.streambase.sb.client.XmlRpcAdmin
killConnection(byte[]) - Method in class com.streambase.sb.client.StreamBaseAdminClient: Kill the connection with the given connectionId
killConnection(byte[]) - Method in class com.streambase.sb.client.XmlRpcAdmin

L

length() - Method in class com.streambase.sb.ByteArrayView: return the length of this view NB: no data is copied when doing this
LIST_CONNECTIONS - Static variable in interface com.streambase.sb.client.XmlRpcCommands
LIST_ENTITIES - Static variable in interface com.streambase.sb.client.XmlRpcCommands
listConnections() - Method in class com.streambase.sb.client.StreamBaseAdminClient: Return an array of client connections
listConnections() - Method in class com.streambase.sb.client.XmlRpcAdmin: Return an array of client connections
listEntities(EntityType) - Method in class com.streambase.sb.client.StreamBaseClient: Return an array of entity names for the given entity type.
listEntities(EntityType, int) - Method in class com.streambase.sb.client.StreamBaseClient: Return an array of entity names for the given entity type
listEntities(EntityType, int) - Method in class com.streambase.sb.client.XmlRpcAdmin: Return an array of entity names for the given entity type
LOAD_CHECKPOINT - Static variable in interface com.streambase.sb.client.XmlRpcCommands
loadCheckpoint(String) - Method in class com.streambase.sb.client.StreamBaseAdminClient: Checkpoint (backup) a StreamBase Server
loadCheckpoint(String) - Method in class com.streambase.sb.client.XmlRpcAdmin: Checkpoint (backup) a StreamBase Server.
LONG - Static variable in class com.streambase.sb.DataType: Long type, eight bytes.

M

makeClientSSLContext() - Static method in class com.streambase.sb.client.SSLUtils
makeClientSSLContext(boolean) - Static method in class com.streambase.sb.client.SSLUtils
makeSSLContext(String, String) - Static method in class com.streambase.sb.client.SSLUtils
makeTupleIO(StreamBaseURI, long, long, boolean) - Static method in class com.streambase.sb.client.TupleIOFactory
makeView(byte[]) - Static method in class com.streambase.sb.ByteArrayView: Create a new ByteArrayView which wraps the entire provided byte[] NB: no data is copied when doing this
makeView(byte[], int, int) - Static method in class com.streambase.sb.ByteArrayView: Create a new ByteArrayView which wraps the provided byte[] between offset and length from offset NB: no data is copied when doing this
MAX_QUEUE_SIZE - Variable in class com.streambase.sb.client.ClientProperties
MAX_QUEUE_SIZE_PROP - Static variable in class com.streambase.sb.client.ClientProperties: The maximum size of the queue that we are going to allow this is so that we will block the server if the server sends us data faster than we can process it
MAX_TUPLES_IN_QUEUE - Variable in class com.streambase.sb.client.ClientProperties
MAX_TUPLES_IN_QUEUE_DEFAULT - Static variable in class com.streambase.sb.client.ClientProperties
MAX_TUPLES_IN_QUEUE_PROP - Static variable in class com.streambase.sb.client.ClientProperties: Maximum # of tuples in the the queue.
modify(String) - Method in class com.streambase.sb.client.StreamBaseAdminClient: Add the given application to the default container in the StreamBaseServer
MODIFY_APPLICATION - Static variable in interface com.streambase.sb.client.XmlRpcCommands
modifyApplication(String) - Method in class com.streambase.sb.client.XmlRpcAdmin: Modify the StreamBase Server with the given StreamBase application.
ModuleInfo - Class in com.streambase.sb.monitor: Represents information about a parallel module in a StreamBase Server.
ModuleInfo.QueueInfo - Class in com.streambase.sb.monitor: Information about a Queue on a Parallel Module
moduleInfos() - Method in class com.streambase.sb.monitor.Snapshot: Returns an iterator over all the ModuleInfo objects.
moduleNames() - Method in class com.streambase.sb.monitor.Snapshot: Returns the set of all thread names.
MonitorListener - Interface in com.streambase.sb.monitor: Implement this interface in order to receive the information produced by a StreamBaseMonitor object.
msecs(long, long) - Static method in class com.streambase.sb.Timestamp: Create a timestamp using the following type and # of milliseconds
msecs(long, double) - Static method in class com.streambase.sb.Timestamp: Create a timestamp using the following type and # of milliseconds

N

NetworkException - Exception in com.streambase.sb.client: Exception thrown when a network error/problem occurs
NetworkException(String) - Constructor for exception com.streambase.sb.client.NetworkException
NetworkException(String, Throwable) - Constructor for exception com.streambase.sb.client.NetworkException
NetworkException(Throwable) - Constructor for exception com.streambase.sb.client.NetworkException
newTupleConnections(StreamBaseClient) - Method in class com.streambase.sb.client.XmlRpcAdmin
newURLConnection(URL) - Method in class com.streambase.sb.client.SBHTTPTransport
NO_CONTAINER - Static variable in class com.streambase.sb.client.StreamBaseURI: No container specified ("")
NO_FLAGS - Static variable in class com.streambase.sb.client.StreamBaseClient: Flag for listEntities to signifiy no options set.
NO_SUCH_FIELD - Static variable in class com.streambase.sb.Schema: Used to indicate that a Field does not exist
NOT_YET_STARTED - Static variable in class com.streambase.sb.operator.Operator.OperatorStates: The initial state of an Operator.
NotImplementedException - Exception in com.streambase.sb: Signals that some feature has not yet been implemented.
NotImplementedException(String) - Constructor for exception com.streambase.sb.NotImplementedException
NotImplementedException(String, Throwable) - Constructor for exception com.streambase.sb.NotImplementedException
NotImplementedException(Throwable) - Constructor for exception com.streambase.sb.NotImplementedException
now() - Static method in class com.streambase.sb.Timestamp: Create a timestamp using the current time
NULL_STRING - Static variable in class com.streambase.sb.Tuple: The default String representation of a null valued field
NullValueException - Exception in com.streambase.sb: An exception that is thrown when a field value is requested as a primitive (e.g., Tuple.getBoolean()), but it is null.
NullValueException(String) - Constructor for exception com.streambase.sb.NullValueException
NullValueException(String, Throwable) - Constructor for exception com.streambase.sb.NullValueException
NullValueException(Throwable) - Constructor for exception com.streambase.sb.NullValueException

O

offset() - Method in class com.streambase.sb.ByteArrayView: return the offset into the backing array of this view NB: no data is copied when doing this
OPERATOR - Static variable in class com.streambase.sb.EntityType: Represents a StreamBase operator.
Operator - Class in com.streambase.sb.operator: Abstract base class for User code that is used as a Java Operator or an embedded Adapter in a StreamBase application.
Operator() - Constructor for class com.streambase.sb.operator.Operator: Constructs an operator.
Operator.OperatorStates - Class in com.streambase.sb.operator: The set of runtime states that an Operator can be in.
Operator.SuspendBehaviorStates - Class in com.streambase.sb.operator: Suspend behavior defines how an Operator handles tuples when it is suspended; meaning when it is in the SUSPENDED state.
OPERATOR_STATUS - Static variable in interface com.streambase.sb.client.XmlRpcCommands
OperatorInfo - Class in com.streambase.sb.monitor: Represents information about a single operator in a StreamBase application.
OperatorInfo(String) - Constructor for class com.streambase.sb.monitor.OperatorInfo
operatorInfos() - Method in class com.streambase.sb.monitor.Snapshot: Returns an iterator over all the OperatorInfo objects.
operatorNames() - Method in class com.streambase.sb.monitor.Snapshot: Returns the set of all operator names.
operatorStatus(String) - Method in class com.streambase.sb.client.XmlRpcAdmin: Return the status of each Operator present in the StreamBase server.
optional() - Method in class com.streambase.sb.operator.parameter.SBPropertyDescriptor: Mark the descriptor as optional.
OUTPUT_STREAMS - Static variable in class com.streambase.sb.EntityType: Represents output streams only.
OutputAdapter - Class in com.streambase.sb.adapter: Abstract base class for output adapters.
OutputAdapter() - Constructor for class com.streambase.sb.adapter.OutputAdapter
outputs - Variable in class com.streambase.sb.operator.PortCounts

P

Parameterizable - Interface in com.streambase.sb.operator: Interface for the objects that hold the user-configurable parameters for Java Operators when they appear in StreamBase Studio.
parseArgs(SBPropertyDescriptor, String) - Method in class com.streambase.sb.operator.parameter.SBPropertyDescriptor.SingleValueSetter: Parse the single argument value from a string into the array of parameters to pass to the setter method.
PASSWORD_PARAM - Static variable in class com.streambase.sb.client.StreamBaseURI: URI parameter used for password.
PortCounts - Class in com.streambase.sb.operator: A record type to describe the number of input and output ports an operator has.
PortCounts(int, int) - Constructor for class com.streambase.sb.operator.PortCounts: Constructs a new PortCounts object requesting a change in the number of input and/or output ports.
postShutdown() - Method in class com.streambase.sb.operator.Operator: postShutdown is called by the StreamBase runtime just after shutting down this Operator.
prettyPrint() - Method in class com.streambase.sb.monitor.OperatorInfo: Pretty-print an OperatorInfo object to the standard output.
prettyPrint() - Method in class com.streambase.sb.monitor.Snapshot: Shortcut for prettyPrint(true, true, true, false).
prev_timestamp - Variable in class com.streambase.sb.monitor.Snapshot
println() - Method in class com.streambase.sb.TupleCSVCharWriter: Writes a line separator to the buffer.
println() - Method in class com.streambase.sb.TupleCSVOutputWriter: Writes a line separator.
PROCESSING_TUPLES - Static variable in class com.streambase.sb.operator.Operator.SuspendBehaviorStates: Process tuples when the Operator is suspended.
processTuple(int, Tuple) - Method in class com.streambase.sb.adapter.InputAdapter
processTuple(int, Tuple) - Method in class com.streambase.sb.operator.Operator: This method will be called by the StreamBase server for each Tuple given to the Operator to process.
props() - Method in class com.streambase.sb.client.StreamBaseClient.TupleBuffer: get stream properties for this Buffer
PROTOCOL_STRING - Static variable in class com.streambase.sb.client.XmlRpcAdmin
ProtocolException - Exception in com.streambase.sb.client: Exception thrown when a protocol error/problem occurs
ProtocolException(String) - Constructor for exception com.streambase.sb.client.ProtocolException
ProtocolException(String, Throwable) - Constructor for exception com.streambase.sb.client.ProtocolException
ProtocolException(Throwable) - Constructor for exception com.streambase.sb.client.ProtocolException

Q

queues() - Method in class com.streambase.sb.monitor.ModuleInfo: Return a Collection of QueueInfo's which contains information about each queue

R

read(ByteBuffer, long) - Method in class com.streambase.sb.client.SocketChannelWrapper
read(ByteBuffer, long) - Method in class com.streambase.sb.client.SSLSocketWrapper
read(ByteBuffer, long) - Method in interface com.streambase.sb.client.TupleIO: Read into buf.
READ_BUF_SIZE - Variable in class com.streambase.sb.client.ClientProperties
READ_BUF_SIZE_PROP - Static variable in class com.streambase.sb.client.ClientProperties: Size (bytes) of the read ByteBuffer
ReadOnlyTupleRep - Class in com.streambase.sb
ReadOnlyTupleRep(Schema, ByteArrayUtils) - Constructor for class com.streambase.sb.ReadOnlyTupleRep
ReadOnlyTupleRep(Schema, ByteOrder) - Constructor for class com.streambase.sb.ReadOnlyTupleRep
RECONNECT_SLEEP - Variable in class com.streambase.sb.client.ClientProperties
RECONNECT_SLEEP_PROP - Static variable in class com.streambase.sb.client.ClientProperties: How often the background thread attempts to reconnect (in milliseconds)
registerRunnable(Runnable, boolean) - Method in class com.streambase.sb.operator.Operator: Register a Runnable object to be managed by this Operator.
registerRunnable(Runnable) - Method in class com.streambase.sb.operator.Operator: Deprecated. As of StreamBase version 3.7, replaced by Operator.registerRunnable(Runnable, boolean)
release() - Method in class com.streambase.sb.operator.AggregateWindow: Called after the end of a use of this object.
REMOVE_CONTAINER - Static variable in interface com.streambase.sb.client.XmlRpcCommands
removeContainer(String) - Method in class com.streambase.sb.client.StreamBaseAdminClient: Remove the given container in the StreamBaseServer
removeContainer(String) - Method in class com.streambase.sb.client.XmlRpcAdmin
removeMonitorListener(MonitorListener) - Method in class com.streambase.sb.monitor.StreamBaseMonitor: Remove a listener that was previously added.
removeMonitorListeners() - Method in class com.streambase.sb.monitor.StreamBaseMonitor: Remove all listeners.
requireInputPortCount(int) - Method in class com.streambase.sb.operator.Operator: Throws a PortMismatchException if the number of ports is not numPorts.
reset() - Method in class com.streambase.sb.TupleCSVCharWriter: Resets the buffer so that you can reuse it.
ResourceFilePropertyDescriptor - Class in com.streambase.sb.operator.parameter: PropertyDescriptor subclass used by StreamBase operators to hold metadata for resource file parameters used in StreamBase Studio to set operator parameters and used to serialize/deserialize the operator to xml in .sbapp files.
ResourceFilePropertyDescriptor(String, Class) - Constructor for class com.streambase.sb.operator.parameter.ResourceFilePropertyDescriptor
ResourceFilePropertyDescriptor(String, Class, String, String) - Constructor for class com.streambase.sb.operator.parameter.ResourceFilePropertyDescriptor: Construct a property descriptor with non-standard read/write method names.
ResourceFilePropertyDescriptor(PropertyDescriptor, Class) - Constructor for class com.streambase.sb.operator.parameter.ResourceFilePropertyDescriptor: Copy a property descriptor.
ResourceNotFoundException - Exception in com.streambase.sb.operator: Thrown when an operator tries to get a resource by name, but no such resource exists.
ResourceNotFoundException(String) - Constructor for exception com.streambase.sb.operator.ResourceNotFoundException: Constructor.
RESTART_OPERATORS - Static variable in interface com.streambase.sb.client.XmlRpcCommands
restartOperators(Vector) - Method in class com.streambase.sb.client.StreamBaseAdminClient: Restart the given Operators on the StreamBase server.
restartOperators(Vector) - Method in class com.streambase.sb.client.XmlRpcAdmin
resubscribe(String, String, String) - Method in class com.streambase.sb.client.StreamBaseClient: Resubscribe to a stream with a predicate
resubscribe(StreamProperties, String, String) - Method in class com.streambase.sb.client.StreamBaseClient: Resubscribe to a stream with a predicate
resume() - Method in class com.streambase.sb.client.StreamBaseAdminClient: Resume a paused StreamBase server
resume(String) - Method in class com.streambase.sb.client.StreamBaseAdminClient: Resume a container in a StreamBaseServer
resume(String) - Method in class com.streambase.sb.client.XmlRpcAdmin: Resume a paused StreamBase server
RESUME - Static variable in interface com.streambase.sb.client.XmlRpcCommands
resume() - Method in class com.streambase.sb.operator.Operator: resume() is called when an operator starts or resumes execution, before any registered runnables are started or resumed.
RESUME_OPERATORS - Static variable in interface com.streambase.sb.client.XmlRpcCommands
resumed() - Method in class com.streambase.sb.operator.Operator: resumed() is called after all registered runnables of the operator have started or resumed.
resumeOperators(Vector) - Method in class com.streambase.sb.client.StreamBaseAdminClient: Resume the given Operators on the StreamBase server
resumeOperators(Vector) - Method in class com.streambase.sb.client.XmlRpcAdmin
reuseTuple() - Method in class com.streambase.sb.client.DequeueResult: Deprecated.
reuseTuple(Tuple) - Method in class com.streambase.sb.client.DequeueResult: Deprecated.
run() - Method in class com.streambase.sb.monitor.StreamBaseMonitor: Read and process monitor snapshots from sbd.

S

sameFieldsAs(Schema) - Method in class com.streambase.sb.Schema: Returns true if this schema has the same field types and names in the same order as another Schema.
sameFieldTypes(Schema) - Method in class com.streambase.sb.Schema: Returns true if this schema has the same field types in the same order as another Schema
SBHTTPTransport - Class in com.streambase.sb.client: A simple wrapper around XmlRpcSunTransport objects that adds SB-specific HTTP headers.
SBHTTPTransport(XmlRpcClient, Map, SSLSocketFactory) - Constructor for class com.streambase.sb.client.SBHTTPTransport
SBHTTPTransportFactory - Class in com.streambase.sb.client: Factory for creating SBXmlRPCCommonsTransport objects which is just a simple wrapper around XmlRpcSunTransport objects that adds SB-specific HTTP headers.
SBHTTPTransportFactory(XmlRpcClient, Map, SSLSocketFactory) - Constructor for class com.streambase.sb.client.SBHTTPTransportFactory
SBPropertyDescriptor - Class in com.streambase.sb.operator.parameter: PropertyDescriptor subclass used by StreamBase operators to hold metadata for parameters used in StreamBase Studio to set operator parameters and used to serialize/deserialize the operator to xml in .sbapp files.
SBPropertyDescriptor(String, Class) - Constructor for class com.streambase.sb.operator.parameter.SBPropertyDescriptor: Construct a property descriptor.
SBPropertyDescriptor(String, Class, String, String) - Constructor for class com.streambase.sb.operator.parameter.SBPropertyDescriptor: Construct a property descriptor with non-standard read/write method names.
SBPropertyDescriptor(PropertyDescriptor, Class) - Constructor for class com.streambase.sb.operator.parameter.SBPropertyDescriptor: Copy a property descriptor.
SBPropertyDescriptor.SingleValueSetter - Class in com.streambase.sb.operator.parameter: This abstract specialization of Setter assumes that the property type will have a single value (which currently accounts for all property types except string lists).
SBPropertyDescriptor.SingleValueSetter() - Constructor for class com.streambase.sb.operator.parameter.SBPropertyDescriptor.SingleValueSetter
SCHEMA - Static variable in class com.streambase.sb.EntityType: Represents a StreamBase Schema.
Schema - Class in com.streambase.sb: Contains meta data about a Tuple.
Schema(String, List, boolean) - Constructor for class com.streambase.sb.Schema: Create a new schema from a set of fields
Schema(String, List, boolean, ByteOrder) - Constructor for class com.streambase.sb.Schema: Create a new schema from a set of fields
Schema(Element, boolean) - Constructor for class com.streambase.sb.Schema: Construct a Schema from an XMLElement
Schema(String, boolean) - Constructor for class com.streambase.sb.Schema: Construct a Schema out of XML represented as a String
Schema(String, Schema.Field[], boolean) - Constructor for class com.streambase.sb.Schema: Construct a Schema out of a list of Fields
Schema(String, Schema, boolean) - Constructor for class com.streambase.sb.Schema: Construct a Schema with a new name from another schema
schema - Variable in class com.streambase.sb.Tuple
Schema.Field - Class in com.streambase.sb: Contains meta data about a Field in a Schema
Schema.Field(Schema.Field) - Constructor for class com.streambase.sb.Schema.Field: Construct a Field
Schema.Field(String, DataType) - Constructor for class com.streambase.sb.Schema.Field: Construct a Field
Schema.ValidateFieldList.ValidationException - Exception in com.streambase.sb: Exception to indicate validation failures
SECONDARY_HOST_PARAM - Static variable in class com.streambase.sb.client.StreamBaseURI: URI parameter used for secondary host name.
SECONDARY_PORT_PARAM - Static variable in class com.streambase.sb.client.StreamBaseURI: URI parameter used for secondary port name.
secs(long, long) - Static method in class com.streambase.sb.Timestamp: Create a timestamp using the following type and # of seconds
secs(long, double) - Static method in class com.streambase.sb.Timestamp: Create a timestamp using the following type and # of seconds
sendOutput(int, Tuple) - Method in class com.streambase.sb.operator.Operator: Enqueue a Tuple to be sent to downstream operators.
sendOutput(int, List) - Method in class com.streambase.sb.operator.Operator: Enqueue a List of Tuples to be sent to downstream operators.
serialize(byte[], int) - Method in class com.streambase.sb.ReadOnlyTupleRep
serialize(byte[], int) - Method in class com.streambase.sb.TupleRep
SET_OPERATOR_PROPERTY - Static variable in interface com.streambase.sb.client.XmlRpcCommands
SET_RUNTIME_PARAM - Static variable in interface com.streambase.sb.client.XmlRpcCommands
setBlobBuffer(Schema.Field, ByteArrayView) - Method in class com.streambase.sb.ReadOnlyTupleRep
setBlobBuffer(String, ByteArrayView) - Method in class com.streambase.sb.Tuple: Set the named blob.
setBlobBuffer(int, ByteArrayView) - Method in class com.streambase.sb.Tuple: Set the blob field at fieldIndex.
setBlobBuffer(Schema.Field, ByteArrayView) - Method in class com.streambase.sb.Tuple: Set the named blob buffer.
setBlobBuffer(Schema.Field, ByteArrayView) - Method in class com.streambase.sb.TupleRep
setBlobFormatter(Tuple.TupleFormatter) - Method in class com.streambase.sb.TupleCSVOutputWriter
setBoolean(Schema.Field, boolean) - Method in class com.streambase.sb.ReadOnlyTupleRep
setBoolean(String, boolean) - Method in class com.streambase.sb.Tuple: Set the named boolean field to a boolean
setBoolean(int, boolean) - Method in class com.streambase.sb.Tuple: Set the boolean field at fieldIndex to a boolean
setBoolean(Schema.Field, boolean) - Method in class com.streambase.sb.Tuple: Set the named boolean field to a boolean
The Schema.Field objects used to set and get Tuple field values must be obtained via the Tuple's Schema object.
setBoolean(Schema.Field, boolean) - Method in class com.streambase.sb.TupleRep
setBuffer(byte[], int) - Method in class com.streambase.sb.ReadOnlyTupleRep: present serialized tuple data to this object based on the Tuple's schema and nullmask data found in the buffer determine 'valueOffsets': locations within 'data' where non-null values can be found and read No data is copied! Clients can read field values after the method is invoked data shouldn't change until we are done with field access ReadOnlyTupleRep is really a "tuple view" of a byte array segment
setConnectionID(byte[]) - Method in class com.streambase.sb.client.XmlRpcAdmin
setDisplayName(String) - Method in class com.streambase.sb.operator.Operator: The display name is the String that's shown in the list of available Operators.
setDouble(Schema.Field, double) - Method in class com.streambase.sb.ReadOnlyTupleRep
setDouble(String, double) - Method in class com.streambase.sb.Tuple: Set the named double field to a double
setDouble(int, double) - Method in class com.streambase.sb.Tuple: Set the double field at fieldIndex to a double
setDouble(Schema.Field, double) - Method in class com.streambase.sb.Tuple: Set the named double field to a double
The Schema.Field objects used to set and get Tuple field values must be obtained via the Tuple's Schema object.
setDouble(Schema.Field, double) - Method in class com.streambase.sb.TupleRep
setField(String, Object) - Method in class com.streambase.sb.Tuple: Set a field to a given value.
setField(int, Object) - Method in class com.streambase.sb.Tuple: Set a field to a given value.
setField(Schema.Field, Object) - Method in class com.streambase.sb.Tuple: Set a field to a given boxed value
The Schema.Field objects used to set and get Tuple field values must be obtained via the Tuple's Schema object.
setFieldFromObject(Tuple, Schema.Field, Object) - Method in class com.streambase.sb.DataType: set a field from the tuple with an Object
setInt(Schema.Field, int) - Method in class com.streambase.sb.ReadOnlyTupleRep
setInt(String, int) - Method in class com.streambase.sb.Tuple: Set the named int field to an int
setInt(int, int) - Method in class com.streambase.sb.Tuple: Set the int field at fieldIndex to an int
setInt(Schema.Field, int) - Method in class com.streambase.sb.Tuple: Set the named int field to an int
The Schema.Field objects used to set and get Tuple field values must be obtained via the Tuple's Schema object.
setInt(Schema.Field, int) - Method in class com.streambase.sb.TupleRep
setLong(Schema.Field, long) - Method in class com.streambase.sb.ReadOnlyTupleRep
setLong(String, long) - Method in class com.streambase.sb.Tuple: Set the named int field to an int
setLong(int, long) - Method in class com.streambase.sb.Tuple: Set the int field at fieldIndex to an int
setLong(Schema.Field, long) - Method in class com.streambase.sb.Tuple: Set the named int field to an int
The Schema.Field objects used to set and get Tuple field values must be obtained via the Tuple's Schema object.
setLong(Schema.Field, long) - Method in class com.streambase.sb.TupleRep
setNull(Schema.Field) - Method in class com.streambase.sb.ReadOnlyTupleRep
setNull(Schema.Field) - Method in class com.streambase.sb.Tuple: Set a field to null.
setNull(String) - Method in class com.streambase.sb.Tuple: Set a field to null.
setNull(int) - Method in class com.streambase.sb.Tuple: Set a field to null
setNull(Schema.Field) - Method in class com.streambase.sb.TupleRep
setOperatorProperty(String, String, String) - Method in class com.streambase.sb.client.StreamBaseAdminClient: On the given Operator, set the given property to the given value.
setOperatorProperty(String, String, String) - Method in class com.streambase.sb.client.XmlRpcAdmin: On the given Operator, set the given property to the given value.
setOutputSchema(int, Schema) - Method in class com.streambase.sb.operator.Operator: Sets the output schema for the given output port (port #'s are zero based).
setParameters(Parameterizable) - Method in class com.streambase.sb.operator.Operator: Sets the Java Bean that holds the user-configurable parameters visible in the StreamBase Studio Properties View of this operator.
setPortHints(int, int) - Method in class com.streambase.sb.operator.Operator: Used to tell StreamBase Studio how many ports to draw on the Java Operator when the operator is drawn in the IDE's canvas.
setQuiescentLimit(long) - Method in class com.streambase.sb.client.StreamBaseClient: If more then timeoutMS milliseconds elapse without receiving data or a heart beat from the server, the client will close.
setRequired(boolean) - Method in class com.streambase.sb.operator.parameter.SBPropertyDescriptor: Set whether the property is required.
setReuseTuple(boolean) - Method in class com.streambase.sb.operator.Operator: Allow/disallow the runtime to reuse tuples on operator input.
setRuntimeParam(String, String, String) - Method in class com.streambase.sb.client.StreamBaseAdminClient: Set a runtime parameter on one, or all, operators.
setRuntimeParam(String, String, String) - Method in class com.streambase.sb.client.XmlRpcAdmin
setSessionState(Object) - Method in class com.streambase.sb.operator.Operator: Maintain state for this operator that has the same object extent as the application, not the instance (which may be repeatedly destroyed and recreated when High Availability servers are used).
setString(Schema.Field, String, boolean) - Method in class com.streambase.sb.ReadOnlyTupleRep
setString(String, String) - Method in class com.streambase.sb.Tuple: Set the named field to a string.
setString(String, String, boolean) - Method in class com.streambase.sb.Tuple: Set the named field to a string.
setString(int, String) - Method in class com.streambase.sb.Tuple: Set the field at fieldIndex to a string.
setString(int, String, boolean) - Method in class com.streambase.sb.Tuple: Set the field at fieldIndex to a string.
setString(Schema.Field, String) - Method in class com.streambase.sb.Tuple: Set the named field to a string.
setString(Schema.Field, String, boolean) - Method in class com.streambase.sb.Tuple: Set the named field to a string.
setString(Schema.Field, String, boolean) - Method in class com.streambase.sb.TupleRep
setStringBuffer(Schema.Field, ByteArrayView) - Method in class com.streambase.sb.ReadOnlyTupleRep
setStringBuffer(String, ByteArrayView) - Method in class com.streambase.sb.Tuple: Set the named string
setStringBuffer(int, ByteArrayView) - Method in class com.streambase.sb.Tuple: Set the String field at fieldIndex
setStringBuffer(Schema.Field, ByteArrayView) - Method in class com.streambase.sb.Tuple: Set the named String buffer
The Schema.Field objects used to set and get Tuple field values must be obtained via the Tuple's Schema object.
setStringBuffer(Schema.Field, ByteArrayView) - Method in class com.streambase.sb.TupleRep
setStringBytes(Schema.Field, byte[], boolean) - Method in class com.streambase.sb.ReadOnlyTupleRep
setStringBytes(Schema.Field, byte[], long) - Method in class com.streambase.sb.ReadOnlyTupleRep
setStringBytes(String, byte[]) - Method in class com.streambase.sb.Tuple: Deprecated. As of StreamBase 5.0, use Tuple.setString(java.lang.String, java.lang.String) instead
setStringBytes(String, byte[], boolean) - Method in class com.streambase.sb.Tuple: Deprecated. As of StreamBase 5.0, use Tuple.setString(java.lang.String, java.lang.String) instead
setStringBytes(int, byte[]) - Method in class com.streambase.sb.Tuple: Deprecated. As of StreamBase 5.0, use Tuple.setString(java.lang.String, java.lang.String) instead
setStringBytes(int, byte[], boolean) - Method in class com.streambase.sb.Tuple: Deprecated. As of StreamBase 5.0, use Tuple.setString(java.lang.String, java.lang.String) instead
setStringBytes(Schema.Field, byte[]) - Method in class com.streambase.sb.Tuple: Deprecated. As of StreamBase 5.0, use Tuple.setString(java.lang.String, java.lang.String) instead
setStringBytes(Schema.Field, byte[], boolean) - Method in class com.streambase.sb.Tuple: Deprecated. As of StreamBase 5.0, use Tuple.setString(java.lang.String, java.lang.String) instead
setStringBytes(Schema.Field, byte[], boolean) - Method in class com.streambase.sb.TupleRep
setStringBytes(Schema.Field, byte[], long) - Method in class com.streambase.sb.TupleRep
setSuspendBehavior(int) - Method in class com.streambase.sb.operator.Operator: Set the suspend behavior of this Operator.
setTimeout(long) - Method in class com.streambase.sb.client.XmlRpcAdmin: Time, in milliseconds for I/O to timeout.
setTimestamp(Schema.Field, Timestamp) - Method in class com.streambase.sb.ReadOnlyTupleRep
setTimestamp(Schema.Field, long) - Method in class com.streambase.sb.ReadOnlyTupleRep
setTimestamp(String, Timestamp) - Method in class com.streambase.sb.Tuple: Set the named field to a timestamp.
setTimestamp(int, Timestamp) - Method in class com.streambase.sb.Tuple: Set the field at fieldIndex to a timestamp.
setTimestamp(Schema.Field, Timestamp) - Method in class com.streambase.sb.Tuple: Set the named field to a timestamp.
setTimestamp(Schema.Field, Timestamp) - Method in class com.streambase.sb.TupleRep
setTimestamp(Schema.Field, long) - Method in class com.streambase.sb.TupleRep
setTupleId(int) - Method in class com.streambase.sb.ReadOnlyTupleRep
setTupleId(int) - Method in class com.streambase.sb.TupleRep
setValues(String[]) - Method in class com.streambase.sb.operator.parameter.EnumPropertyDescriptor: Set the list of allowable values for the property.
shouldRun() - Method in class com.streambase.sb.operator.Operator: Return whether or not calling operator thread is enabled and should continue running.
shutdown() - Method in class com.streambase.sb.client.StreamBaseAdminClient: Shutdown a StreamBase server
shutdown(String) - Method in class com.streambase.sb.client.StreamBaseAdminClient: Shutdown a container within a StreamBase server
shutdown(String) - Method in class com.streambase.sb.client.XmlRpcAdmin
SHUTDOWN - Static variable in interface com.streambase.sb.client.XmlRpcCommands
SHUTDOWN - Static variable in class com.streambase.sb.operator.Operator.OperatorStates: The terminal state of the Operator.
shutdown() - Method in class com.streambase.sb.operator.Operator: shutdown is called by the StreamBase runtime just prior to shutting down this Operator.
SHUTDOWN_MANAGER - Static variable in interface com.streambase.sb.client.XmlRpcCommands
SHUTDOWN_OPERATORS - Static variable in interface com.streambase.sb.client.XmlRpcCommands
SHUTDOWN_SECONDARY - Static variable in interface com.streambase.sb.client.XmlRpcCommands
shutdownOperators(Vector) - Method in class com.streambase.sb.client.StreamBaseAdminClient: Shut down the given Operators on the StreamBase server.
shutdownOperators(Vector) - Method in class com.streambase.sb.client.XmlRpcAdmin
shutdownSecondary() - Method in class com.streambase.sb.client.StreamBaseAdminClient: Shutdown a StreamBase Secondary Server while in HA mode
shutdownSecondary() - Method in class com.streambase.sb.client.XmlRpcAdmin: Shutdown a StreamBase Server while in HA mode
size() - Method in class com.streambase.sb.TupleCSVCharWriter: Returns the current size of the buffer(the number of characters written since the last reset()).
slice(int, int) - Method in class com.streambase.sb.ByteArrayView: Create a new ByteArrayView which wraps a portion of this one NB: no data is copied when doing this
Snapshot - Class in com.streambase.sb.monitor: Stores a snapshot of information from a StreamBase application.
snapshotReceived(Snapshot) - Method in interface com.streambase.sb.monitor.MonitorListener: Called by a StreamBaseMonitor object when it has received a Snapshot.
SO_KEEPALIVE - Static variable in class com.streambase.sb.client.ClientProperties
SocketChannelWrapper - Class in com.streambase.sb.client
SocketChannelWrapper(String, int, long, long, boolean) - Constructor for class com.streambase.sb.client.SocketChannelWrapper
SSLSocketWrapper - Class in com.streambase.sb.client: This is a simple wrapper around SSLSockets that does the I/O in background threads to simulate asynchronous I/O.
SSLSocketWrapper(StreamBaseURI) - Constructor for class com.streambase.sb.client.SSLSocketWrapper
SSLUtils - Class in com.streambase.sb.client
SSLUtils() - Constructor for class com.streambase.sb.client.SSLUtils
SSLUtils.CertificateChecker - Class in com.streambase.sb.client: Temporary hack certificate checker.
SSLUtils.CertificateChecker() - Constructor for class com.streambase.sb.client.SSLUtils.CertificateChecker
STARTED - Static variable in class com.streambase.sb.operator.Operator.OperatorStates: The Operator has been started; resume() has been called.
status(boolean) - Method in class com.streambase.sb.client.XmlRpcAdmin: Return the status of the StreamBase Server
STATUS - Static variable in interface com.streambase.sb.client.XmlRpcCommands
storeData(ByteBuffer) - Method in class com.streambase.sb.client.StreamBaseClient.TupleBuffer
STREAM - Static variable in class com.streambase.sb.EntityType: Represents a StreamBase Stream.
StreamBaseAdminClient - Class in com.streambase.sb.client: This class is used to send administrative commands to the StreamBase Server
StreamBaseAdminClient(String) - Constructor for class com.streambase.sb.client.StreamBaseAdminClient: Create a StreamBaseAdminClient.
StreamBaseAdminClient() - Constructor for class com.streambase.sb.client.StreamBaseAdminClient: Create a StreamBaseAdminClient.
StreamBaseAdminClient(StreamBaseURI) - Constructor for class com.streambase.sb.client.StreamBaseAdminClient: Create a StreamBaseAdminClient, connecting to the server at the provided URI.
StreamBaseClient - Class in com.streambase.sb.client: A client used to subscribe to StreamBase streams and to send commands to the StreamBase Server.
StreamBaseClient(String) - Constructor for class com.streambase.sb.client.StreamBaseClient: Create a StreamBaseClient, connecting to the server at the provided URI String
StreamBaseClient() - Constructor for class com.streambase.sb.client.StreamBaseClient: Create a StreamBaseClient from StreamBaseURI.fromEnvironment()
StreamBaseClient(StreamBaseURI) - Constructor for class com.streambase.sb.client.StreamBaseClient: Create a StreamBaseClient, connecting to the server at the provided URI
StreamBaseClient.TupleBuffer - Class in com.streambase.sb.client: Class for abstracting away where tuples come from, Buffers, Collections & Single Enqueues
StreamBaseException - Exception in com.streambase.sb: The base class of all StreamBase non-runtime exceptions.
StreamBaseException(String) - Constructor for exception com.streambase.sb.StreamBaseException
StreamBaseException(String, Throwable) - Constructor for exception com.streambase.sb.StreamBaseException
StreamBaseException(Throwable) - Constructor for exception com.streambase.sb.StreamBaseException
StreamBaseMonitor - Class in com.streambase.sb.monitor: Monitors a StreamBase Server, and gathers statistics.
StreamBaseMonitor(StreamBaseURI) - Constructor for class com.streambase.sb.monitor.StreamBaseMonitor: Create a monitoring object, which will connect to a server with the given StreamBase URI.
StreamBaseRuntimeException - Exception in com.streambase.sb: The base class of all StreamBase runtime exceptions.
StreamBaseRuntimeException(String) - Constructor for exception com.streambase.sb.StreamBaseRuntimeException
StreamBaseRuntimeException(String, Throwable) - Constructor for exception com.streambase.sb.StreamBaseRuntimeException
StreamBaseRuntimeException(Throwable) - Constructor for exception com.streambase.sb.StreamBaseRuntimeException
StreamBaseURI - Class in com.streambase.sb.client: A Uniform Resource Identifier containing information necessary to connect to a StreamBase server.
StreamBaseURI(String) - Constructor for class com.streambase.sb.client.StreamBaseURI: Constructor that parses a StreamBase URI passed in as a String.
StreamBaseURI(String, String, int) - Constructor for class com.streambase.sb.client.StreamBaseURI: Constructor roughly equivalent to new StreamBaseURI("sb://host:port/container").
StreamBaseURI(String, int) - Constructor for class com.streambase.sb.client.StreamBaseURI: Constructor roughly equivalent to new StreamBaseURI("sb://host:port/").
StreamBaseURI(String, String, int, String, String) - Constructor for class com.streambase.sb.client.StreamBaseURI: Constructor roughly equivalent to new StreamBaseURI("sb://host:port/container;user=user;password=password").
StreamBaseURI(String, String, int, boolean, Map) - Constructor for class com.streambase.sb.client.StreamBaseURI: Constructor roughly equivalent to new StreamBaseURI("scheme://host:port/container;param1=value1(...)"), where scheme is either "sb" or "sbs" depending on whether useSSL is true or false, and param1=value1(...) stands for every entry in the params Map
StreamBaseURI(String, String, int, Map) - Constructor for class com.streambase.sb.client.StreamBaseURI: Equivalent to StreamBaseURI(host, container, port, false, params)
StreamBaseURI(String, int, Map) - Constructor for class com.streambase.sb.client.StreamBaseURI: Equivalent to StreamBaseURI(host, NO_CONTAINER, port, params)
StreamProperties - Class in com.streambase.sb: This class contains meta data about a stream.
StreamProperties(Element) - Constructor for class com.streambase.sb.StreamProperties: Create a StreamProperties from the given XML document
StreamProperties(String) - Constructor for class com.streambase.sb.StreamProperties: Create a StreamProperties from the given string representation of an XML document
STRING - Static variable in class com.streambase.sb.DataType: String type of user-defined length.
STRING_HEADER_SIZE - Static variable in class com.streambase.sb.Schema: The size of a String header in bytes
subscribe(String) - Method in class com.streambase.sb.client.StreamBaseClient: Subscribe to a stream
subscribe(StreamProperties) - Method in class com.streambase.sb.client.StreamBaseClient: Subscribe to a stream
subscribe(String, String, String) - Method in class com.streambase.sb.client.StreamBaseClient: Subscribe to a stream with a predicate.
subscribe(StreamProperties, String, String) - Method in class com.streambase.sb.client.StreamBaseClient: Subscribe to a stream with a predicate.
subscribe(StreamProperties, String, String, List) - Method in class com.streambase.sb.client.XmlRpcAdmin: Subscribe to an output stream with predicate.
subscribe(String, String, String) - Method in class com.streambase.sb.client.XmlRpcAdmin
SUBSCRIBE - Static variable in interface com.streambase.sb.client.XmlRpcCommands
suspend() - Method in class com.streambase.sb.client.StreamBaseAdminClient: Suspend (pause) a StreamBase Server
suspend(String) - Method in class com.streambase.sb.client.StreamBaseAdminClient: Suspend (pause) a container within a StreamBase Server
suspend(String) - Method in class com.streambase.sb.client.XmlRpcAdmin: Suspend (pause) a StreamBase Server
SUSPEND - Static variable in interface com.streambase.sb.client.XmlRpcCommands
suspend() - Method in class com.streambase.sb.operator.Operator: suspend() will be called when an operator suspends, before any registered runnables are suspended.
SUSPEND_OPERATORS - Static variable in interface com.streambase.sb.client.XmlRpcCommands
SUSPENDED - Static variable in class com.streambase.sb.operator.Operator.OperatorStates: The Operator has been suspended; suspend() has been called.
suspended() - Method in class com.streambase.sb.operator.Operator: suspended() will be called after all registered runnables of the operator have suspended.
suspendOperators(Vector) - Method in class com.streambase.sb.client.StreamBaseAdminClient: Suspend (pause) the given Operators on the StreamBase Server
suspendOperators(Vector) - Method in class com.streambase.sb.client.XmlRpcAdmin
SYSTEM_CONTAINER - Static variable in class com.streambase.sb.client.StreamBaseURI: The system container ("system")
SystemInfo - Class in com.streambase.sb.monitor: Represents system-level information.
SystemInfo() - Constructor for class com.streambase.sb.monitor.SystemInfo

T

terminate() - Method in class com.streambase.sb.monitor.Snapshot: Ask the StreamBaseMonitor to terminate at the end of the current snapshot.
terminate() - Method in class com.streambase.sb.monitor.StreamBaseMonitor: Ask the monitor to terminate.
ThreadInfo - Class in com.streambase.sb.monitor: Represents information about a single thread in a StreamBase Server.
threadInfos() - Method in class com.streambase.sb.monitor.Snapshot: Returns an iterator over all the ThreadInfo objects.
threadNames() - Method in class com.streambase.sb.monitor.Snapshot: Returns the set of all thread names.
TIMEOUT - Static variable in class com.streambase.sb.client.DequeueResult: Status code indicating a timeout during dequeue
TIMESTAMP - Static variable in class com.streambase.sb.DataType: Timestamp type, eight byte storage.
Timestamp - Class in com.streambase.sb: This class represents a Streambase Timestamp.
Timestamp(Date) - Constructor for class com.streambase.sb.Timestamp: Create a Timestamp out of a java.util.Date
TIMESTAMP - Static variable in class com.streambase.sb.Timestamp: Timestamps can be timestamps or intervals.
toByteBuffer() - Method in class com.streambase.sb.ReadOnlyTupleRep
toByteBuffer() - Method in class com.streambase.sb.TupleRep
toCharArray() - Method in class com.streambase.sb.TupleCSVCharWriter: Returns a copy of the input data.
toDate() - Method in class com.streambase.sb.Timestamp: Create a java.util.Date
toDelimitedString(char) - Method in class com.streambase.sb.Tuple: Return the tuple as a string delimited by the given character.
toElement(Document) - Method in class com.streambase.sb.Schema.Field: Return an XML representation of this Field
toElement(Document) - Method in class com.streambase.sb.Schema: Create an XML document representation of this Schema
toElement(Document, boolean) - Method in class com.streambase.sb.Schema: Create an XML document representation of this Schema
toMsecs() - Method in class com.streambase.sb.Timestamp: Return the # of milliseconds since the epoch or in the interval
toSecs() - Method in class com.streambase.sb.Timestamp: Return the # of seconds since the epoch or in the interval
toSQLDate() - Method in class com.streambase.sb.Timestamp: Create a java.sql.Date
toSQLTimestamp() - Method in class com.streambase.sb.Timestamp: Create a java.sql.Timestamp
toString() - Method in class com.streambase.sb.ByteArrayView: Formats a ByteArrayView by printing out every byte as a char.
toString() - Method in class com.streambase.sb.client.StreamBaseURI: Returns a string representation of the URI.
toString() - Method in class com.streambase.sb.DataType: Return the name of the DataType.
toString() - Method in class com.streambase.sb.EntityType: Return the name of the entity as a string.
toString() - Method in class com.streambase.sb.monitor.ModuleInfo.QueueInfo
toString() - Method in class com.streambase.sb.monitor.OperatorInfo: Returns a string representation of the ThreadInfo object.
toString() - Method in class com.streambase.sb.monitor.Snapshot: Returns a string representation of the Snapshot object.
toString() - Method in class com.streambase.sb.monitor.ThreadInfo: Returns a string representation of the ThreadInfo object.
toString() - Method in class com.streambase.sb.Schema.Field: Return a String representation of this field.
toString() - Method in class com.streambase.sb.Schema: Return the name of the schema
toString(boolean) - Method in class com.streambase.sb.Timestamp: Create string representation of this timestamp, optionally include timezone
toString() - Method in class com.streambase.sb.Timestamp: Create string representation of this timestamp with the timezone
toString(char, boolean) - Method in class com.streambase.sb.Tuple: Deprecated.
toString(char, char, boolean) - Method in class com.streambase.sb.Tuple: Return a string representation of this Tuple.
toString(char, char, boolean, boolean) - Method in class com.streambase.sb.Tuple: Return a string representation of this Tuple.
toString(char, char, boolean, String) - Method in class com.streambase.sb.Tuple: Return a string representation of this Tuple.
toString(char, char, boolean, boolean, String) - Method in class com.streambase.sb.Tuple: Return a string representation of this Tuple.
toString() - Method in class com.streambase.sb.TupleCSVCharWriter: Converts input data to a string.
toStringWithFields() - Method in class com.streambase.sb.Schema: Return a String representation of this Schema
TRUST_ALGORITHM - Static variable in class com.streambase.sb.client.SSLUtils
Tuple - Class in com.streambase.sb: An abstract class that represents a Tuple of Data.
Tuple(Schema) - Constructor for class com.streambase.sb.Tuple
TUPLE_CONNECTION_NO_DEQUEUE_THREAD - Static variable in class com.streambase.sb.client.ClientProperties
TUPLE_CONNECTION_QUIESCENT_LIMIT - Variable in class com.streambase.sb.client.ClientProperties
TUPLE_CONNECTION_QUIESCENT_LIMIT_PROP - Static variable in class com.streambase.sb.client.ClientProperties: If more then TUPLE_CONNECTION_QUIESCENT_LIMIT number of milliseconds elapse without receiving data or a heart beat from the server, the StreamBaseClient object is closed.
TUPLE_CONNECTION_TIMEOUT - Variable in class com.streambase.sb.client.ClientProperties
TUPLE_CONNECTION_TIMEOUT_PROP - Static variable in class com.streambase.sb.client.ClientProperties: Default timeout for TupleConnection, if the StreamBase server's write queue fills and it's unresponsive for TUPLE_CONNECTION_TIMEOUT milliseconds, we assume that it's hung.
TupleCSVCharWriter - Class in com.streambase.sb: This class implements a character buffer that can be used to write tuple data in a CSV format.
TupleCSVCharWriter() - Constructor for class com.streambase.sb.TupleCSVCharWriter: Construct a TupleCSVCharWriter using a default format.
TupleCSVCharWriter(int, char, char, boolean, String, String) - Constructor for class com.streambase.sb.TupleCSVCharWriter: Construct a TupleCSVCharWriter with user specified format.
TupleCSVOutputWriter - Class in com.streambase.sb: This class implements a buffered writer that can be used to write tuple data to an OutputStream in a CSV format.
TupleCSVOutputWriter(OutputStream) - Constructor for class com.streambase.sb.TupleCSVOutputWriter: Construct a TupleCSVOutputWriter using a default format.
TupleCSVOutputWriter(OutputStream, char, char, boolean, String, String, String, boolean) - Constructor for class com.streambase.sb.TupleCSVOutputWriter: Construct a TupleCSVOutputWriter with user specified format.
TupleCSVOutputWriter(OutputStream, char, char, boolean, String, String, String) - Constructor for class com.streambase.sb.TupleCSVOutputWriter
TupleException - Exception in com.streambase.sb: Signals that an operation related to fields failed.
TupleException(String) - Constructor for exception com.streambase.sb.TupleException
TupleException(String, Throwable) - Constructor for exception com.streambase.sb.TupleException
TupleException(Throwable) - Constructor for exception com.streambase.sb.TupleException
TupleIO - Interface in com.streambase.sb.client: The IO abstraction used by TupleConnection to hide the IO implementation.
TupleIOFactory - Class in com.streambase.sb.client: Determines from the StreamBaseURI what sort of TupleIO object should be created
TupleIOFactory() - Constructor for class com.streambase.sb.client.TupleIOFactory
TupleRep - Class in com.streambase.sb
TupleRep(Tuple) - Constructor for class com.streambase.sb.TupleRep
TupleRep(Schema, ByteOrder) - Constructor for class com.streambase.sb.TupleRep
TupleRep(Schema, ByteArrayUtils) - Constructor for class com.streambase.sb.TupleRep
tuples() - Method in class com.streambase.sb.client.DequeueResult: Deprecated. use iterator() instead
typecheck(String) - Method in class com.streambase.sb.client.StreamBaseClient: Typecheck (validate) the given StreamBase Application.
typecheck(String, boolean) - Method in class com.streambase.sb.client.StreamBaseClient: Typecheck (validate) the given StreamBase Application.
typecheck(String, boolean) - Method in class com.streambase.sb.client.XmlRpcAdmin: Typecheck (validate) the given StreamBase Application.
TYPECHECK - Static variable in interface com.streambase.sb.client.XmlRpcCommands
typecheck() - Method in class com.streambase.sb.operator.Operator: The typecheck method is called by the StreamBase server to ensure that all the parameters for this operator are correct.
TypecheckException - Exception in com.streambase.sb.operator: Thrown when an error occurs during the Operator's typecheck() method.
TypecheckException(String) - Constructor for exception com.streambase.sb.operator.TypecheckException
TypecheckException(String, Throwable) - Constructor for exception com.streambase.sb.operator.TypecheckException
TypecheckException(Throwable) - Constructor for exception com.streambase.sb.operator.TypecheckException

U

unsubscribe(String) - Method in class com.streambase.sb.client.StreamBaseClient: Unsubscribe from the given stream name.
unsubscribe(StreamProperties) - Method in class com.streambase.sb.client.StreamBaseClient: Unsubscribe from the given stream name.
unsubscribe(StreamProperties, String, List) - Method in class com.streambase.sb.client.XmlRpcAdmin: UnSubscribe to an output stream.
unsubscribe(String, String) - Method in class com.streambase.sb.client.XmlRpcAdmin
UNSUBSCRIBE - Static variable in interface com.streambase.sb.client.XmlRpcCommands
URIException - Exception in com.streambase.sb.client: Exception thrown when URI parsing fails.
URIException(String, String) - Constructor for exception com.streambase.sb.client.URIException
USER_PARAM - Static variable in class com.streambase.sb.client.StreamBaseURI: URI parameter used for username.
UUID_LENGTH - Static variable in class com.streambase.sb.Schema: The length of the UUID of the Schema

V

verify() - Method in class com.streambase.sb.ReadOnlyTupleRep
verify() - Method in class com.streambase.sb.TupleRep
view(int, int) - Method in class com.streambase.sb.ByteArrayView: Create a new ByteBuffer which wraps a portion of this one NB: no data is copied when doing this
view() - Method in class com.streambase.sb.ByteArrayView: Create a new ByteBuffer which wraps all of this one NB: no data is copied when doing this

W

WINDOW_SPEC - Static variable in class com.streambase.sb.EntityType: Represents a StreamBase window.
write(String) - Method in class com.streambase.sb.TupleCSVCharWriter: Writes a string to the buffer.
write(String, int, int) - Method in class com.streambase.sb.TupleCSVCharWriter: Writes a portion of a string to the buffer.
write(char[]) - Method in class com.streambase.sb.TupleCSVCharWriter: Writes the contents of a char[] to the buffer.
write(char[], int, int) - Method in class com.streambase.sb.TupleCSVCharWriter: Writes a portion of a char[] to the buffer.
write(char) - Method in class com.streambase.sb.TupleCSVCharWriter: Writes a single character to the buffer.
write(Tuple) - Method in class com.streambase.sb.TupleCSVCharWriter: Writes the contents of a tuple in a CSV format.
write(Tuple, int) - Method in class com.streambase.sb.TupleCSVCharWriter: Writes the contents of a tuple in a CSV format with user specified field delimiting behavior.
write(String) - Method in class com.streambase.sb.TupleCSVOutputWriter: Writes a string.
write(String, int, int) - Method in class com.streambase.sb.TupleCSVOutputWriter: Writes a portion of a string.
write(char[]) - Method in class com.streambase.sb.TupleCSVOutputWriter: Writes the contents of a char[].
write(char[], int, int) - Method in class com.streambase.sb.TupleCSVOutputWriter: Writes a portion of a char[].
write(char) - Method in class com.streambase.sb.TupleCSVOutputWriter: Writes a single character.
write(Tuple) - Method in class com.streambase.sb.TupleCSVOutputWriter: Writes the contents of a tuple in a CSV format.
write(Tuple, int) - Method in class com.streambase.sb.TupleCSVOutputWriter: Writes the contents of a tuple in a CSV format with user specified field delimiting behavior.
WRITE_BUF_SIZE - Variable in class com.streambase.sb.client.ClientProperties
WRITE_BUF_SIZE_PROP - Static variable in class com.streambase.sb.client.ClientProperties: Size (bytes) of the tuple write ByteBuffer
writeDelimitedValue(String, boolean) - Method in class com.streambase.sb.TupleCSVCharWriter: Writes a string value to the buffer in a delimited format.
writeDelimitedValue(String, boolean) - Method in class com.streambase.sb.TupleCSVOutputWriter: Writes a string value in a delimited format.
writeFully(ByteBuffer) - Method in class com.streambase.sb.client.SocketChannelWrapper
writeFully(ByteBuffer) - Method in class com.streambase.sb.client.SSLSocketWrapper
writeFully(ByteBuffer) - Method in interface com.streambase.sb.client.TupleIO: Write all the data in the buf
writeTo(Writer) - Method in class com.streambase.sb.TupleCSVCharWriter: Writes the contents of the buffer to another character stream writer.

X

XmlRpcAdmin - Class in com.streambase.sb.client: Interface describes the admin commands that pass from the client to the stream base server.
XmlRpcCommands - Interface in com.streambase.sb.client

A B C D E F G H I K L M N O P Q R S T U V W X

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

PREV NEXT

FRAMES NO FRAMES