- canAssignFrom(CompleteDataType) - Method in class com.streambase.sb.CompleteDataType
-
Check if a value of this type can be assigned a value of the other type.
- canAssignFromImpl(CompleteDataType) - Method in class com.streambase.sb.CompleteDataType
-
Method for subclasses to override if they have a broader concept of type.
- canAssignFromImpl(CompleteDataType) - Method in class com.streambase.sb.CompleteDataType.FunctionType
-
Method for subclasses to override if they have a broader concept of type.
- cancel() - Method in class com.streambase.liveview.client.NullProgressMonitor
-
This implementation sets the value of an internal state variable.
- cancel() - Method in interface com.streambase.liveview.client.ProgressMonitor
-
The client can cancel the current request
- cancel() - Method in interface com.streambase.sb.Cancellable
-
A request to cancel the task
- Cancellable - Interface in com.streambase.sb
-
Represents tasks (possibly to run in the future) that can be cancelled.
- canChangeFieldCount() - Method in enum com.streambase.sb.SchemaUtil.CoercionOptions
-
- canDequeue() - Method in class com.streambase.sb.client.DeMUXStreamBaseClient
-
- canDequeue() - Method in class com.streambase.sb.client.StreamBaseClient
-
Return true if we can call dequeue without blocking.
- canDequeue(StreamProperties) - Method in class com.streambase.sb.client.StreamBaseClient.TupleBuffer
-
- canEnqueue(StreamProperties) - Method in class com.streambase.sb.client.StreamBaseClient.TupleBuffer
-
- canTransformCaptures(Collection<SchemaUtil.CoercionOptions>) - Static method in enum com.streambase.sb.SchemaUtil.CoercionOptions
-
- canTransformsCaptures() - Method in enum com.streambase.sb.SchemaUtil.CoercionOptions
-
- CAPABILITIES - Static variable in class com.streambase.liveview.server.table.plugin.TestTableProvider
-
- CAPABILITIES_FIELD - Static variable in interface com.streambase.liveview.client.Table
-
- CAPABILITIES_FOR_FILTERED_TABLES - Static variable in interface com.streambase.liveview.client.Table
-
- CAPTURE_STRATEGY_DESC_NAME - Static variable in class com.streambase.sb.operator.parameter.SBSimpleBeanInfo
-
The name of the bean that stores the CaptureStrategy.
- CaptureTransformStrategy - Enum in com.streambase.sb
-
Determines the method StreamBase will use to expose capture fields to client code
or dequeuers.
- CaptureType(String) - Constructor for class com.streambase.sb.CompleteDataType.CaptureType
-
- CEP_TABLES_GROUP - Static variable in interface com.streambase.liveview.client.Table
-
- CHARSET_DISPLAY_NAME - Static variable in class com.streambase.sb.operator.parameter.SBSimpleBeanInfo
-
- CHARSET_PROPERTY_NAME - Static variable in class com.streambase.sb.operator.parameter.SBSimpleBeanInfo
-
- CHARSET_PROPOSALS - Static variable in class com.streambase.sb.operator.parameter.SBSimpleBeanInfo
-
- check(DataType...) - Method in class com.streambase.sb.DataType.Checklist
-
- check(Collection<DataType>) - Method in class com.streambase.sb.DataType.Checklist
-
- checkCharsetProps(Operator, boolean, String) - Static method in class com.streambase.sb.operator.parameter.SBSimpleBeanInfo
-
- Checklist() - Constructor for class com.streambase.sb.DataType.Checklist
-
- checkPermission(LiveViewPermission) - Method in interface com.streambase.liveview.client.LiveViewConnection
-
Checks whether the authenticated user has the specified permission.
- checkPermissions(List<LiveViewPermission>) - Method in interface com.streambase.liveview.client.LiveViewConnection
-
Checks whether the authenticated user has the specified permissions.
- checkStatus() - Method in class com.streambase.sb.client.DequeueResult
-
Check and return the status of this DequeueResult.
- 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
-
- checkType(CompleteDataType) - 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
- checkType(Schema.Field, DataType) - Method in class com.streambase.sb.Tuple
-
- checkTypeAndNonNull(Schema.Field, DataType) - Method in class com.streambase.sb.Tuple
-
check the type and make sure it is non null
- checkValidStreamname(String) - Static method in class com.streambase.sb.client.StreamBaseClient
-
- clear() - Method in class com.streambase.sb.Tuple
-
Sets all of this tuple's fields to null values.
- clearEvalCache(String) - Method in class com.streambase.sb.client.StreamBaseAdminClient
-
- clearRetryCount() - Method in interface com.streambase.liveview.server.table.plugin.TableProviderControl
-
This will set the failedRetryCount to zero.
- clearRetryCount() - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- 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
-
- ClientController - Interface in com.streambase.liveview.client.clientcontrol
-
The Interface provides methods to kill Queries, Publishers and Sessions.
- ClientSettings - Class in com.streambase.sb.client
-
- ClientSettings(boolean) - Constructor for class com.streambase.sb.client.ClientSettings
-
Creates a ClientSettings that uses StreamBase default values for all settings
- ClientVersionAware() - Constructor for class com.streambase.liveview.client.LiveViewServerCapability.ClientVersionAware
-
- clone() - Method in class com.streambase.liveview.client.ConnectionConfig
-
- clone() - Method in class com.streambase.sb.ByteArrayView
-
Implement Object.clone, which just delegates to ByteArrayView.copy().
- clone() - Method in class com.streambase.sb.monitor.ModuleInfo
-
- clone() - Method in class com.streambase.sb.monitor.ModuleInfo.QueueInfo
-
- clone() - Method in class com.streambase.sb.monitor.StreamInfo
-
- clone() - Method in class com.streambase.sb.monitor.SystemInfo.GCInfo
-
- clone() - Method in class com.streambase.sb.monitor.ThreadInfo
-
- clone() - Method in class com.streambase.sb.Tuple
-
Clone this tuple, the new tuple will not share any buffers or data with the original
- close() - Method in class com.streambase.liveview.client.AbstractBatchedQueryListener
-
Closes the thread that calls the batch methods periodically
- close() - Method in class com.streambase.liveview.client.DeleteQueryListener
-
- close() - Method in interface com.streambase.liveview.client.LiveViewConnection
-
Closes all queries and open resources with the server.
- close() - Method in interface com.streambase.liveview.client.Query
-
Closes the client and server resources associated with this Query.
- close() - Method in class com.streambase.liveview.client.QueryListenerWrapper
-
- close() - Method in class com.streambase.liveview.client.SnapshotQueryListener
-
- close() - Method in interface com.streambase.liveview.client.SnapshotResult
-
closes any resource associated with the snapshot result
- close() - Method in interface com.streambase.liveview.client.TablePublisher
-
Closes client and server resources held by the publisher
- 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
-
- close(String) - Method in class com.streambase.sb.client.StreamBaseClient
-
Flush all buffers and close the connection to the StreamBase server.
- close() - Method in class com.streambase.sb.feedsim.FeedSimTupleInputStream
-
Close that cleans up the default read() state
- close() - Method in interface com.streambase.sb.monitor.Snapshot.Source
-
- close() - Method in class com.streambase.sb.monitor.StreamBaseMonitor
-
close this monitor
- CLOSED - Static variable in class com.streambase.sb.client.DequeueResult
-
Status code indicating that the connection was closed
- collapse(Tuple) - Method in interface com.streambase.sb.TupleCaptureTransformer
-
Capture all the extra fields in 'in' into their correct capture fields.
- com.streambase.liveview.client - package com.streambase.liveview.client
-
Provides classes and interfaces fundamental to the TIBCO Live Datamart Java API.
- com.streambase.liveview.client.alert - package com.streambase.liveview.client.alert
-
Provides classes and interfaces to set Alerts.
- com.streambase.liveview.client.clientcontrol - package com.streambase.liveview.client.clientcontrol
-
Provides classes and interfaces to control user's interaction with the TIBCO Live Datamart.
- com.streambase.liveview.client.dynamictables - package com.streambase.liveview.client.dynamictables
-
Provides classes and interfaces to configure TIBCO Live Datamart server's dynamic tables.
- com.streambase.liveview.client.serverdatautility - package com.streambase.liveview.client.serverdatautility
-
Provides classes and interfaces to fetch TIBCO Live Datamart server's utility data.
- com.streambase.liveview.server.table.plugin - package com.streambase.liveview.server.table.plugin
-
Provides classes and interfaces to add custom table providers to TIBCO Live Datamart.
- com.streambase.sb - package com.streambase.sb
-
Provides classes and interfaces fundamental to the TIBCO 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.feedsim - package com.streambase.sb.feedsim
-
- 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.
- com.streambase.sb.unittest - package com.streambase.sb.unittest
-
Provides classes and interfaces used to author StreamBase Unit tests.
- compare(Tuple, Tuple) - Method in class com.streambase.sb.unittest.FieldBasedTupleComparator
-
- compare(TupleComparator, CompleteDataType, Object, Object) - Method in class com.streambase.sb.unittest.FieldBasedTupleComparator.CompareFunctor
-
- compare(Tuple, Tuple) - Method in interface com.streambase.sb.unittest.TupleComparator
-
Compare two tuples.
- CompareFunctor() - Constructor for class com.streambase.sb.unittest.FieldBasedTupleComparator.CompareFunctor
-
- compareImpl(TupleComparator, CompleteDataType, Object, Object) - Method in class com.streambase.sb.unittest.FieldBasedTupleComparator.CompareFunctor
-
Compare two values expected and actual, using comparator for recursion as necessary.
- compareImpl(TupleComparator, CompleteDataType, Object, Object) - Method in class com.streambase.sb.unittest.FieldBasedTupleComparator.DoubleCompareFunctor
-
- compareImpl(TupleComparator, CompleteDataType, Object, Object) - Method in class com.streambase.sb.unittest.FieldBasedTupleComparator.IgnoreTimestampCompareFunctor
-
- compareImpl(TupleComparator, CompleteDataType, Object, Object) - Method in class com.streambase.sb.unittest.FieldBasedTupleComparator.ListCompareFunctor
-
- compareImpl(TupleComparator, CompleteDataType, Object, Object) - Method in class com.streambase.sb.unittest.FieldBasedTupleComparator.NaiveObjectCompareFunctor
-
- compareImpl(TupleComparator, CompleteDataType, Object, Object) - Method in class com.streambase.sb.unittest.FieldBasedTupleComparator.RegexCompareFunctor
-
- compareImpl(TupleComparator, CompleteDataType, Object, Object) - Method in class com.streambase.sb.unittest.FieldBasedTupleComparator.TupleCompareFunctor
-
- compareTo(ByteArrayView) - Method in class com.streambase.sb.ByteArrayView
-
compare this ByteArrayView to another lexigraphically
NB: no data is copied when doing this
- compareValues(CompleteDataType, Object, Object) - Method in class com.streambase.sb.unittest.FieldBasedTupleComparator
-
- compareValues(CompleteDataType, Object, Object) - Method in interface com.streambase.sb.unittest.TupleComparator
-
- CompiledTuple - Class in com.streambase.sb
-
Subclass of tuple that indicates a tuple has a compiled representation for better performance.
- CompiledTuple(Schema) - Constructor for class com.streambase.sb.CompiledTuple
-
- compileLVConfs(List<File>, boolean) - Method in class com.streambase.liveview.server.table.plugin.TableProviderManager
-
- CompleteDataType - Class in com.streambase.sb
-
Wraps
DataType with ancillary information about the type (where
appropriate) that's needed to actually use the DataType.
- CompleteDataType(DataType) - Constructor for class com.streambase.sb.CompleteDataType
-
- CompleteDataType.CaptureType - Class in com.streambase.sb
-
- CompleteDataType.FunctionType - Class in com.streambase.sb
-
- CompleteDataType.ListType - Class in com.streambase.sb
-
- CompleteDataType.TupleType - Class in com.streambase.sb
-
- CompositeQueryListener - Class in com.streambase.liveview.client
-
A convenience implementation of
QueryListener that enables
notifications of zero or more listeners.
- CompositeQueryListener(QueryListener...) - Constructor for class com.streambase.liveview.client.CompositeQueryListener
-
Create the composite listener with one or more child listeners.
- ConfigurationChooserPropertyDescriptor - Class in com.streambase.sb.operator.parameter
-
A property descriptor for use by a String-typed Java Operator or Adapter property, for
cases that wish to present to the user a chooser (typically a combo box) that allows
identifying some data out of the server configuration file's adapter-configurations area.
- ConfigurationChooserPropertyDescriptor(String, String, Class<?>) - Constructor for class com.streambase.sb.operator.parameter.ConfigurationChooserPropertyDescriptor
-
Standard constructor
- ConfigurationChooserPropertyDescriptor(String, String, Class<?>, String, String) - Constructor for class com.streambase.sb.operator.parameter.ConfigurationChooserPropertyDescriptor
-
Construct a property descriptor with non-standard read/write method names
- ConfigurationChooserPropertyDescriptor(String, PropertyDescriptor, Class<?>) - Constructor for class com.streambase.sb.operator.parameter.ConfigurationChooserPropertyDescriptor
-
Copy a property descriptor
- CONNECTION - Static variable in interface com.streambase.sb.client.XmlRpcAdmin.ListConnectionTags
-
- connectionClosed(ConnectionClosedEvent) - Method in interface com.streambase.liveview.client.ConnectionListener
-
Connection closed event
- connectionClosed() - Method in interface com.streambase.sb.client.DeMUXStreamBaseClient.DequeueListener
-
This will be called if the connection is closed.
- ConnectionClosedEvent - Class in com.streambase.liveview.client
-
- ConnectionClosedEvent(Object, LiveViewConnection) - Constructor for class com.streambase.liveview.client.ConnectionClosedEvent
-
- ConnectionConfig - Class in com.streambase.liveview.client
-
Connection configuration used to connect to LiveView server.
- ConnectionConfig() - Constructor for class com.streambase.liveview.client.ConnectionConfig
-
- connectionEstablished(LiveViewConnectionControl, boolean) - Method in interface com.streambase.liveview.client.MultiConnectionListener
-
This will be called whenever any connection succeeds, including the very first one.
- connectionEstablished(LiveViewConnectionControl, boolean) - Method in class com.streambase.liveview.client.MultiConnectionListener.MultiConnectionListenerBase
-
- ConnectionListener - Interface in com.streambase.liveview.client
-
A connection listener interface that can be provided to
ConnectionConfig to receive
connection related events on.
- ConnectionMode - Enum in com.streambase.liveview.client
-
- CONNECTIONS_SCHEMA - Static variable in interface com.streambase.sb.Constants
-
- CONNECTIONS_STREAM_NAME - Static variable in interface com.streambase.sb.Constants
-
- ConnectionStatus - Enum in com.streambase.sb.client
-
- ConnectionStatusCallback - Interface in com.streambase.sb.client
-
This interface is used to track connection lifecycle events.
- Constants - Interface in com.streambase.sb
-
Useful constants describing entities in the system container
- Constants.ContainerState - Enum in com.streambase.sb
-
status of a container sent on the control stream as container events
- Constants.LeadershipStatus - Enum in com.streambase.sb
-
Server leadership status.
- consume(DequeueResult) - Method in interface com.streambase.sb.client.DeMUXStreamBaseClient.DequeueListener
-
When you register a subscribe, you will start getting called here with its results
- consume(Tuple) - Method in interface com.streambase.sb.operator.RowConsumer
-
Override this method to consume rows.
- CONTAINER - Static variable in class com.streambase.sb.EntityType
-
Represents a StreamBase container.
- CONTAINER_STATE_START - Static variable in interface com.streambase.sb.Constants
-
- CONTAINER_STATE_STARTING - Static variable in interface com.streambase.sb.Constants
-
constants used in the ContainerState enum
- CONTAINER_STATE_STOPPED - Static variable in interface com.streambase.sb.Constants
-
- CONTAINER_STATE_STOPPING - Static variable in interface com.streambase.sb.Constants
-
- containerNames() - Method in class com.streambase.sb.monitor.Snapshot
-
Return a list of the names of the current containers
- containers - Variable in class com.streambase.sb.monitor.Snapshot
-
- CONTROL_PARAM_LEN - Static variable in interface com.streambase.sb.Constants
-
- CONTROL_SCHEMA - Static variable in interface com.streambase.sb.Constants
-
- CONTROL_STREAM_NAME - Static variable in interface com.streambase.sb.Constants
-
- CONTROL_SUBSYS_LEN - Static variable in interface com.streambase.sb.Constants
-
- convert(QueryType) - Static method in enum com.streambase.liveview.client.LiveViewQueryType
-
- convert(LiveViewQueryType) - Static method in enum com.streambase.liveview.client.LiveViewQueryType
-
- 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.
- copyField(Schema.Field, Tuple, Schema.Field) - Method in class com.streambase.sb.Tuple
-
Copy the field from this tuple to the destination tuple
- copyTuple(Tuple) - Method in class com.streambase.sb.Tuple
-
copy the source tuple to this tuple
- copyTuple(Tuple, Tuple) - Method in class com.streambase.sb.TupleCopier
-
Copy the fields from the sourceTuple to the destTuple.
- CQS_INTERNAL_ID - Static variable in interface com.streambase.liveview.client.LiveViewConnection
-
- create() - Static method in class com.streambase.sb.operator.parameter.UIHints
-
Creates a new
UIHints with all values initialized to default
- CREATE_IF_NULL - Static variable in class com.streambase.sb.Tuple
-
during a get create tuple if it is null
- CREATE_TIME - Static variable in interface com.streambase.liveview.client.Table
-
- createAggregateTable(String, String, QueryConfig, List<List<String>>) - Method in interface com.streambase.liveview.client.TableAdminManager
-
Create a table that is based on an aggregate query against an existing table.
- createAlertRule() - Method in interface com.streambase.liveview.client.alert.AlertManager
-
Creates a new alert rule.
- createArgumentTuple() - Method in interface com.streambase.sb.operator.PreparedQuery
-
Factory for argument tuples for this prepared query.
- createCaptureTransformStrategyDescriptor() - Method in class com.streambase.sb.operator.parameter.SBSimpleBeanInfo
-
- createCharsetPropertyDesc(UIHints, String, Class<?>) - Method in class com.streambase.sb.operator.parameter.SBSimpleBeanInfo
-
Same as calling createCharsetPropertyDesc(hint, desc, clazz, true)
- createCharsetPropertyDesc(UIHints, String, Class<?>, boolean) - Method in class com.streambase.sb.operator.parameter.SBSimpleBeanInfo
-
Creates a property descriptor for character set encoding, with CHARSET_PROPOSALS as the proposals.
- createDummyCatalogedTable(String) - Static method in class com.streambase.liveview.server.table.plugin.TestTableProvider
-
- createExecutor(int) - Method in interface com.streambase.sb.operator.Operator.RuntimeEnvironment
-
Create an ExecutorService.
- createField(DataType, String) - Static method in class com.streambase.sb.Schema
-
Creates a new Field of the given DataType, with the given name.
- createFunctionField(String, Schema, CompleteDataType) - Static method in class com.streambase.sb.Schema
-
Creates a new Field of type FUNCTION, with the given name, argument list and return type.
- createListField(String, CompleteDataType) - Static method in class com.streambase.sb.Schema
-
Creates a new Field of type LIST, with the given name and given element type
- createPublisher(String) - Method in class com.streambase.liveview.server.table.plugin.TestTableProvider.UnsupportedTable
-
- createReadOnlyTuple() - Method in class com.streambase.sb.Tuple
-
Return a new tuple that is guaranteed to be read only
- createRow() - Method in interface com.streambase.sb.operator.TableAccessor
-
- createTable(String, String, Schema, List<List<String>>) - Method in interface com.streambase.liveview.client.TableAdminManager
-
Create a table on the server without any LVConf which represents it.
- createTable(String, String, Schema, String...) - Method in interface com.streambase.liveview.client.TableAdminManager
-
Convenience form of the previous method, used if there is only a primary key, and that key is only a single field.
- createTable(String, String, String, List<List<String>>) - Method in interface com.streambase.liveview.client.TableAdminManager
-
Create a table on the server without any LVConf which represents it.
- createTable(String, String, String, String...) - Method in interface com.streambase.liveview.client.TableAdminManager
-
Convenience form of the previous method, used if there is only a primary key, and that key is only a single field.
- createTable(TableConfig) - Method in interface com.streambase.liveview.client.TableAdminManager
-
Create a table using a TableConfig
- createTable(String, LiveviewConfiguration, boolean) - Method in class com.streambase.liveview.server.table.plugin.TableProviderManager
-
Does pre-checks, saves lvconf file and registers the table in defined state with the services layer
- createTableConfig(String) - Method in interface com.streambase.liveview.client.TableAdminManager
-
Create a TableConfig for making tables with more advanced features
- createTuple() - Method in class com.streambase.sb.Schema
-
Create a Tuple with this schema.
- createTuple(String...) - Method in class com.streambase.sb.Schema
-
Create a Tuple with this schema from the supplied collection of strings
- createTuple(String[], int, int) - Method in class com.streambase.sb.Schema
-
Create a Tuple with this schema from the supplied collection of strings
- createTuple(String[], int, int, String) - Method in class com.streambase.sb.Schema
-
Create a Tuple with this schema from the supplied collection of strings
- createTuple(List<String>, int, int) - Method in class com.streambase.sb.Schema
-
Create a Tuple with this schema from the supplied collection of strings
- createTuple(List<String>, int, int, String) - Method in class com.streambase.sb.Schema
-
Create a Tuple with this schema from the supplied collection of strings
- createTuple(Schema, T) - Method in class com.streambase.sb.unittest.AbstractTupleMaker
-
- createTuple(Schema, String) - Method in class com.streambase.sb.unittest.CSVTupleMaker
-
- createTuple(Schema, String) - Method in class com.streambase.sb.unittest.JSONSingleQuotesTupleMaker
-
- createTuple(Schema, String) - Method in class com.streambase.sb.unittest.JSONTupleMaker
-
- createTuple(Schema, Object[]) - Method in class com.streambase.sb.unittest.ObjectArrayTupleMaker
-
- createTuple(Schema, T) - Method in interface com.streambase.sb.unittest.TupleMaker
-
create a
Tuples from an input object
- createTupleField(String, Schema) - Static method in class com.streambase.sb.Schema
-
Creates a new Field of type TUPLE, with the given name and given schema
- createTuples(Schema, T...) - Method in class com.streambase.sb.unittest.AbstractTupleMaker
-
- createTuples(Schema, Collection<T>) - Method in class com.streambase.sb.unittest.AbstractTupleMaker
-
- createTuples(Schema, T...) - Method in interface com.streambase.sb.unittest.TupleMaker
-
create multiple
Tuples from input objects
- createTuples(Schema, Collection<T>) - Method in interface com.streambase.sb.unittest.TupleMaker
-
create multiple
Tuples from input objects
- createUseDefaultCharsetPropertyDesc(UIHints, Class<?>) - Method in class com.streambase.sb.operator.parameter.SBSimpleBeanInfo
-
Creates a check box property descriptor for users to indicate that they would like to use the
platform's default charset for this operator.
- createWritableTuple() - Method in class com.streambase.sb.Tuple
-
Return a new tuple that is guaranteed to be writable
- CSVTupleMaker - Class in com.streambase.sb.unittest
-
A factory to build
Tuples from CSV formatted
Strings.
- CSVTupleMaker(CSV.FormatInfo) - Constructor for class com.streambase.sb.unittest.CSVTupleMaker
-
- CURRENT_LV_CLIENT_CAPABILITIES_CSV - Static variable in enum com.streambase.liveview.client.LiveViewClientCapability
-
- CURRENT_LV_CLIENT_CAPABILITY - Static variable in enum com.streambase.liveview.client.LiveViewClientCapability
-
- CustomFunctionResolver - Annotation Type in com.streambase.sb.client
-
A Java annotation that can be used on a method, M, that implements a
StreamBase Java custom function.
- cycle - Variable in class com.streambase.sb.monitor.Snapshot
-
- GCInfo(String) - Constructor for class com.streambase.sb.monitor.SystemInfo.GCInfo
-
- get() - Static method in class com.streambase.liveview.server.table.plugin.TableProviderManager
-
- get(int) - Method in class com.streambase.sb.ByteArrayView
-
- getAction() - Method in class com.streambase.liveview.client.LiveViewPermission
-
- getActions() - Method in interface com.streambase.liveview.client.alert.AlertRule
-
This gets the live list of actions, so you could remove or rearrange these, and the changes will be saved if you save the Alert.
- getActionType() - Method in interface com.streambase.liveview.client.alert.AlertRuleAction
-
Get the ActionType, which has both an official and a readable version available.
- getActualSchema() - Method in exception com.streambase.sb.SchemaMismatchException
-
- getAggregateQuery() - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
This method returns the aggregate query for this table.
- getAlertKey() - Method in interface com.streambase.liveview.client.alert.PublishAlertAction
-
Gets the value of the alertKey property.
- getAlertManager() - Method in interface com.streambase.liveview.client.LiveViewConnection
-
- getAlertQueryConfig() - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Gets the value of the alertQueryConfig property.
- getAlertRecipient() - Method in interface com.streambase.liveview.client.alert.PublishAlertAction
-
Gets the value of the alertRecipient property.
- getAlertRule(long) - Method in interface com.streambase.liveview.client.alert.AlertManager
-
Gets the alert rule specified by the id.
- getAlertRules(String) - Method in interface com.streambase.liveview.client.alert.AlertManager
-
Gets all available alert rules from the server for the given user.
- getAlertType() - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Gets the value of alertType property
- getAliasNameFormatter() - Method in class com.streambase.liveview.server.table.plugin.TablePropertiesConfigurationWrapper.FilterdAlias
-
Returns the name formatter with this FilteredAlias instance.
- getAllForContainer(int) - Method in class com.streambase.sb.monitor.StatsUtil.IdentityManager
-
Get the id to name mapping for the whole container that owns the id
- getAllocatedTuple(Schema.Field) - Method in class com.streambase.sb.Tuple
-
Return a reference (not a copy) to the specified nested tuple field.
- getAllocatedTuple(String) - Method in class com.streambase.sb.Tuple
-
Return a reference (not a copy) to the specified nested tuple field.
- getAllocatedTuple(int) - Method in class com.streambase.sb.Tuple
-
Return a reference (not a copy) to the specified nested tuple field.
- getAllStreamProperties(EntityType, CaptureTransformStrategy) - Method in class com.streambase.sb.client.StreamBaseClient
-
Return all the StreamProperties available
- getAllStreamProperties(EntityType) - Method in class com.streambase.sb.client.StreamBaseClient
-
Return all the StreamProperties available.
- getApproximateSize() - Method in class com.streambase.sb.Schema
-
Calculates an estimate for the size of a tuple with this schema, including the header and null mask.
- getApproximateSnapshotOrder() - Method in class com.streambase.liveview.client.QueryConfig
-
The OrderDefinition object set by equivalent setter or setTopN.
- getArgs(SBPropertyDescriptor, Map<String, List<Object>>, SchemaUtil.SchemaProvider) - Method in class com.streambase.sb.operator.parameter.SBPropertyDescriptor.SingleValueSetter
-
- getArgumentSchema() - Method in class com.streambase.sb.CompleteDataType.FunctionType
-
- getArgumentSchema() - Method in class com.streambase.sb.CompleteDataType
-
For function types, return the argument schema.
- getArgumentSchema() - Method in interface com.streambase.sb.Function
-
Returns Schema for the input argument types of the function.
- getAsyncInputPorts() - Method in class com.streambase.sb.operator.Operator
-
Override to indicate to Studio which ports (0-based) might process data
asynchronously, this provides different rendering on the EventFlow canvas
to assist users in understanding their data flow
- getBaseURI() - Method in class com.streambase.sb.client.StreamBaseURI
-
Return a copy of this URI without any params
- getBasicAuthenticationString() - Method in class com.streambase.sb.client.StreamBaseURI
-
Returns a Base64-encoded username + password if authentication
is enabled, or null otherwise.
- getBatchLatency() - Method in class com.streambase.sb.monitor.ModuleInfo.QueueInfo
-
Return a moving average of the time (microseconds) for a batch of tuples to traverse the queue
- getBatchProcessingTime() - Method in class com.streambase.sb.monitor.ModuleInfo.QueueInfo
-
Return the a moving average of the amount of time (microseconds) that it takes
to process a batch of tuples.
- getBatchSize() - Method in class com.streambase.sb.monitor.ModuleInfo.QueueInfo
-
Return a moving average of the size of a batch of tuples
- getBcc() - Method in interface com.streambase.liveview.client.alert.SendEmailAction
-
Gets the value of the bcc property.
- 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.
- getBody() - Method in interface com.streambase.liveview.client.alert.SendEmailAction
-
Gets the value of the body property.
- getBody() - Method in interface com.streambase.sb.Function
-
Returns a string with the StreamBase expression that is the body of this function.
- getBoolean(String) - Method in class com.streambase.sb.Tuple
-
Return the value of a named boolean field.
- getBoolean(int) - Method in class com.streambase.sb.Tuple
-
Return the value of the boolean field at a specified field index.
- getBoolean(Schema.Field) - Method in class com.streambase.sb.Tuple
-
Return the value of a specified boolean field.
- getBuffer() - Method in class com.streambase.sb.client.StreamBaseClient.SerializedTupleBuffer
-
Return a ByteBuffer containing all of the tuples ready to be serialized
also contains empty space at the beginning of the buffer for a network
header
- getCapabilities() - Method in class com.streambase.liveview.client.ConnectionConfig
-
Get the capabilities
- getCapability(Class<T>) - Method in interface com.streambase.liveview.client.LiveViewConnection
-
Returns the object that represents a capability of the connected server,
or throws NoSuchCapabilityException if the type of capability is not
supported by the server.
- getCapture(Schema.Field) - Method in class com.streambase.sb.Tuple
-
Return the value of the named capture field.
- getCapture(String) - Method in class com.streambase.sb.Tuple
-
Return the value of the named capture field.
- getCapture(int) - Method in class com.streambase.sb.Tuple
-
Return the value of the named capture field.
- getCaptureImpl(Schema.Field) - Method in class com.streambase.sb.Tuple
-
- getCaptureName() - Method in class com.streambase.sb.CompleteDataType.CaptureType
-
- getCaptureName() - Method in class com.streambase.sb.CompleteDataType
-
For capture types, return the capture type name.
- getCaptureStrategy() - Method in class com.streambase.sb.operator.Operator
-
Returns the capture transform strategy that this Operator will use.
- getCaptureTransformStrategy() - Method in class com.streambase.sb.StreamProperties
-
- getCaseInsensitiveFieldNames() - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
This method returns the list of case insensitive table field names.
- getCases() - Method in class com.streambase.liveview.client.dynamictables.FieldRule
-
- getCauses() - Method in exception com.streambase.sb.StreamBaseListException
-
Retrieve the List of all causes, never null
- getCc() - Method in interface com.streambase.liveview.client.alert.SendEmailAction
-
Gets the value of the cc property.
- getChangedFields() - Method in class com.streambase.liveview.client.TupleUpdatedEvent
-
Retrieve a list of the fields that changed in this update
- getClazz() - Method in interface com.streambase.liveview.client.alert.ExecuteJavaAction
-
Gets the value of the clazz property.
- getClient() - Method in class com.streambase.sb.monitor.StreamBaseMonitor
-
Get the StreamBaseClient that this monitor is using
- getClientController() - Method in interface com.streambase.liveview.client.LiveViewConnection
-
A ClientController is used to perform actions to control clients.
- getClientCount() - Method in class com.streambase.sb.monitor.SystemInfo
-
Returns the current number of clients
- getClientVersion() - Method in class com.streambase.liveview.client.Version
-
The version of this client library, if known.
- getCode() - Method in enum com.streambase.liveview.client.LiveViewExceptionType
-
Gets the unique identifying code for the exception ENUM
- getCollapsedSchema() - Method in interface com.streambase.sb.TupleCaptureTransformer
-
- getCommand() - Method in interface com.streambase.liveview.client.alert.ExecuteOSCommandAction
-
Gets the value of the command property.
- getCompleteDataType() - Method in class com.streambase.sb.Schema.Field
-
Return the CompleteDataType of the Field
- getConf() - Method in class com.streambase.sb.unittest.BaseTestEnvironment
-
- getConf() - Method in interface com.streambase.sb.unittest.SBTestEnvironment
-
- getConfig() - Method in interface com.streambase.liveview.client.Query
-
Returns a QueryConfig object that contains fully parsed pieces like table, predicate, groupByExprs, etc.
- getConfig() - Method in class com.streambase.liveview.client.QueryListenerWrapper
-
- getConfig() - Method in class com.streambase.liveview.server.table.plugin.TableProviderManager
-
- getConfigs() - Method in class com.streambase.liveview.client.MultiConnectionConfig
-
- getConfigurationBlocksAsXML(String) - Method in interface com.streambase.sb.operator.Operator.ConfigurationAccessor
-
Return all nodes that satisfy the given xpath expression, within the adapter/operator configuration area
of the StreamBase Server's configuration file.
- getConnection() - Method in class com.streambase.liveview.client.ConnectionClosedEvent
-
Get the connection that was closed
- getConnection(String) - Static method in class com.streambase.liveview.client.LiveViewConnectionFactory
-
- getConnection(ConnectionConfig) - Static method in class com.streambase.liveview.client.LiveViewConnectionFactory
-
- getConnection(MultiConnectionConfig, boolean) - Static method in class com.streambase.liveview.client.LiveViewConnectionFactory
-
- getConnectionConfig() - Method in interface com.streambase.liveview.client.LiveViewConnectionControl
-
- getConnectionControls() - Method in interface com.streambase.liveview.client.LiveViewMultiConnection
-
This list will have a one-for-one correspondence with the list of ConnectionConfigs or the list of URIs that were
used to create this LiveViewMultiConnection.
- getConnectionError() - Method in class com.streambase.sb.client.StreamBaseClient
-
If the StreamBaseClient disconnected due to an internal error, return a message corresponding
to the error, otherwise return null.
- getConnectionID() - Method in class com.streambase.sb.client.StreamBaseClient
-
Return the Connection ID for this Client Connection.
- getConnectionMode() - Method in class com.streambase.liveview.client.MultiConnectionConfig
-
- getConnectionMonitor() - Method in class com.streambase.liveview.client.ConnectionConfig
-
The api uses this method to retrieve the progress monitor specified by the user.
- getConnectionState() - Method in interface com.streambase.liveview.client.LiveViewConnectionControl
-
- getConnectionStatus() - Method in class com.streambase.sb.client.StreamBaseClient
-
Return the current connection status of this StreamBaseClient.
- getConnectionURI() - Method in interface com.streambase.liveview.client.LiveViewConnection
-
Retrieves the URI that was used to connect to the server
- getContainer() - Method in class com.streambase.sb.client.StreamBaseURI
-
Returns the container name component of the URI.
- getContainerCount() - Method in class com.streambase.sb.monitor.StatsUtil.IdentityHelper
-
- getContainerCount() - Method in class com.streambase.sb.monitor.StatsUtil.IdentityManager
-
- getContainerName() - Method in class com.streambase.sb.operator.Operator
-
Return the name of this operator's container.
- getContainerName() - Method in class com.streambase.sb.StreamProperties
-
Return the container name part of the name
- getControllableTimeService() - Static method in class com.streambase.sb.unittest.TimeServiceFactory
-
- getControllableTimeService(long) - Static method in class com.streambase.sb.unittest.TimeServiceFactory
-
Return ControllableTimeService instance initialized with the time specified in initTargetTimeMsec
- getCreated() - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Gets the value of the created property.
- getCreated() - Method in class com.streambase.liveview.client.QueryConfig
-
- getCreateTableDir(boolean) - Method in class com.streambase.liveview.server.table.plugin.TableProviderManager
-
- getCreateTime() - Method in interface com.streambase.liveview.client.Table
-
Returns the time when the table was created
- getCronString() - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Gets the value of the cronString property.
- getCurrentConnection() - Method in interface com.streambase.liveview.client.LiveViewMultiConnection
-
LiveViewConnectionControl of the "current" connection, if there is one.
- 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.
- getDataType() - Method in class com.streambase.sb.CompleteDataType
-
Return the data type of the complete type
- getDataType() - Method in class com.streambase.sb.Schema.Field
-
Return the DataType of the Field
- getDefault() - Static method in enum com.streambase.sb.operator.parameter.UIHints.TextWidthHint
-
Encodes the default text width hint when unspecified otherwise.
- getDefaultCase() - Method in class com.streambase.liveview.client.dynamictables.FieldRule
-
- getDeletePredicate() - Method in interface com.streambase.liveview.client.alert.IssueDeleteQueryAction
-
Gets the value of the deletePredicate property.
- getDeltaTuples() - Method in class com.streambase.sb.monitor.StreamInfo
-
Return the number of tuples since the last snapshot
- getDequeueBufferSize() - Method in class com.streambase.sb.client.DeMUXStreamBaseClient
-
- getDequeueClientCount() - Method in class com.streambase.sb.monitor.SystemInfo
-
Returns the current number of dequeuing clients
- getDequeuer(String) - Method in interface com.streambase.sb.unittest.SBServerManager
-
Get the dequeuer for this stream
- getDequeueResultsInterceptor() - Method in class com.streambase.sb.client.StreamBaseClient
-
Get the current dequeue results interceptor, or null if there is no
current processor.
- getDescription() - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Gets the value of the description property.
- getDescription() - Method in interface com.streambase.liveview.client.alert.AlertRuleAction
-
Get the Deescription
- getDescription() - Method in class com.streambase.liveview.client.dynamictables.FieldRule
-
- getDescription() - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
The method returns the description of the Liveview table configured with this TableConfig object.
- getDescription() - Method in class com.streambase.liveview.client.QueryConfig
-
Get the description for this query
- getDescription() - Method in interface com.streambase.liveview.client.Table
-
A description of the table
- getDescription() - Method in class com.streambase.sb.Schema.Field
-
Returns the description currently set for this field.
- getDescription() - Method in class com.streambase.sb.Schema
-
Returns the description currently set for this Schema.
- getDirectionsString() - Method in class com.streambase.liveview.client.OrderDefinition
-
- getDisplayDescription() - Method in class com.streambase.sb.operator.Operator
-
Provides a description for this type of Operator.
- getDisplayName() - Method in class com.streambase.sb.operator.Operator
-
Return the display name of this Operator.
- getDouble(String, double) - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- getDouble(String, double) - Method in interface com.streambase.liveview.server.table.plugin.TableProviderParameters
-
Get the first parameter with this key, interpreted as an double.
- getDouble(String) - Method in class com.streambase.sb.Tuple
-
Return the value of a named double field.
- getDouble(int) - Method in class com.streambase.sb.Tuple
-
Return the value of the double field at a specified field index.
- getDouble(Schema.Field) - Method in class com.streambase.sb.Tuple
-
Return the value of a specified double field.
- getDynamicVariable(String) - Method in class com.streambase.sb.client.StreamBaseClient
-
Get the given dynamic variable
- getDynamicVariables(String) - Method in class com.streambase.sb.client.StreamBaseClient
-
Get a Tuple of all the dynamic variables on the given module
- getDynamicVariables() - Method in class com.streambase.sb.operator.Operator
-
Retrieves a read-only tuple describing the current value of all dynamic variables in the module
this operator is contained in.
- getDynamicVariablesSchema() - Method in class com.streambase.sb.operator.Operator
-
Retrieves a Schema containing information about every dynamic variable available
to the module this operator is contained in.
- getElementType() - Method in class com.streambase.sb.CompleteDataType
-
For list collection types, return the complete type of the list's elements.
- getElementType() - Method in class com.streambase.sb.CompleteDataType.ListType
-
- getElementType() - Method in class com.streambase.sb.Schema.Field
-
Return the element type for this field.
- getEmbeddedServer() - Static method in class com.streambase.sb.unittest.ServerManagerFactory
-
- getEmbeddedServer(SBTestEnvironment) - Static method in class com.streambase.sb.unittest.ServerManagerFactory
-
- getEmbeddedServer(String) - Static method in class com.streambase.sb.unittest.ServerManagerFactory
-
- getEnqueueBufferSize() - Method in class com.streambase.sb.client.StreamBaseClient
-
Return the number of tuples in the enqueue buffer
- getEnqueuer(String) - Method in interface com.streambase.sb.unittest.SBServerManager
-
Get the enqueuer for this stream
- getEnumClass() - Method in class com.streambase.sb.operator.parameter.JavaEnumPropertyDescriptor
-
- getEnv() - Method in class com.streambase.sb.operator.AggregateWindow
-
- getErrorCode() - Method in exception com.streambase.liveview.client.LiveViewException
-
Error code provided by the server
- getErrorSchema() - Static method in class com.streambase.sb.Schema
-
- getErrorType() - Method in exception com.streambase.liveview.client.LiveViewException
-
- getEvalCacheContent(String) - Method in class com.streambase.sb.client.StreamBaseAdminClient
-
- getException() - Method in class com.streambase.liveview.client.DynamicTableState
-
- getException() - Method in class com.streambase.liveview.client.QueryExceptionEvent
-
Get the exception
- getExitStatusTimeoutMS() - Method in class com.streambase.sb.client.ClientSettings
-
ExitStatusTimeoutMS is used as a timeout for how long the client
should wait to get the client's exit status from the server.
- getExpandedSchema() - Method in interface com.streambase.sb.TupleCaptureTransformer
-
- getExpectedSchema() - Method in exception com.streambase.sb.SchemaMismatchException
-
- getExpression() - Method in class com.streambase.sb.operator.parameter.ConfigurationChooserPropertyDescriptor
-
- getExpressionInputPort() - Method in class com.streambase.sb.operator.parameter.SBPropertyDescriptor
-
Return the input port that this property is bound to.
- getExternalServerConnection() - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- getFailedRetryAttempts() - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- getField(int) - Method in class com.streambase.sb.Schema
-
Return a Field object at the given index within the schema
- getField(String) - Method in class com.streambase.sb.Schema
-
Return a Field object with the given field pathname in or under this
schema.
- getField() - Method in exception com.streambase.sb.SchemaValidationException
-
the field that caused the error
- getField(Schema.Field) - Method in class com.streambase.sb.Tuple
-
Return the value of a specified field.
- getField(int) - Method in class com.streambase.sb.Tuple
-
Return the value of the field at a specified field index.
- getField(String) - Method in class com.streambase.sb.Tuple
-
Return the value of a named field.
- getFieldAsString(Schema.Field, Tuple.TupleFormatter) - Method in class com.streambase.sb.Tuple
-
- getFieldCount() - Method in class com.streambase.sb.Schema
-
Return the number of Fields within the Schema.
- getFieldIndex(CharSequence) - Method in class com.streambase.sb.Schema
-
Return the index within the Schema of the Field with the given name
- getFieldIndex(String) - Method in class com.streambase.sb.Schema
-
Return the index within the Schema of the Field with the given name
- getFieldLength(Tuple, Schema.Field) - Method in class com.streambase.sb.TupleUtil.RepMethods
-
- getFieldName() - Method in class com.streambase.liveview.client.dynamictables.Assignment
-
- getFieldRules() - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
This method gets you the list of field rules
FieldRule
- getFields() - Method in class com.streambase.liveview.client.AbstractTable
-
- getFields(boolean) - Method in class com.streambase.liveview.client.AbstractTable
-
- getFields() - Method in class com.streambase.liveview.client.BeginDeleteEvent
-
Get the list of fields that the query tuples will have
- getFields() - Method in class com.streambase.liveview.client.BeginSnapshotEvent
-
Get the list of fields that the query tuples will have
- getFields() - Method in class com.streambase.liveview.client.DeleteQueryListener
-
Retrieves the fields describing the tuples that will be returned.
- getFields() - Method in interface com.streambase.liveview.client.Query
-
Returns a list describing the fields of the tuples that will be returned by this Query.
- getFields() - Method in class com.streambase.liveview.client.QueryConfig
-
Get the fields or null if not specified
- getFields() - Method in class com.streambase.liveview.client.QueryListenerWrapper
-
- getFields() - Method in class com.streambase.liveview.client.SnapshotQueryListener
-
Retrieves the fields describing the tuples that will be returned.
- getFields() - Method in interface com.streambase.liveview.client.SnapshotResult
-
Retrieves the fields describing the tuples that will be returned.
- getFields() - Method in interface com.streambase.liveview.client.Table
-
Returns the fields describing the table columns.
- getFields(boolean) - Method in interface com.streambase.liveview.client.Table
-
Returns the fields describing the table columns.
- getFields() - Method in class com.streambase.sb.Schema
-
Return an array of Field objects corresponding to the fields in the schema.
- getFields() - Method in class com.streambase.sb.Tuple
-
- getFieldsString() - Method in class com.streambase.liveview.client.OrderDefinition
-
- getFieldSubstitutions() - Method in interface com.streambase.liveview.client.alert.LVPublishAlertAction
-
Gets the map of fieldSubstitutions.
- getFieldSubstitutions() - Method in interface com.streambase.liveview.client.alert.PublishAlertAction
-
Gets the map of fieldSubstitutions.
- getFieldSubstitutions() - Method in interface com.streambase.liveview.client.alert.SendTupleAction
-
Gets the map of fieldSubstitutions.
- 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
- getFilter() - Method in class com.streambase.liveview.client.dynamictables.FilteredTableAlias
-
- getFilter() - Method in interface com.streambase.liveview.client.Table
-
Returns the filter on the base table
- getFilteredAliases() - Method in class com.streambase.liveview.server.table.plugin.TablePropertiesConfigurationWrapper
-
- getFilteredTableAliases() - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
This method returns the live list of filtered table alias which you may modify if new filtered tables are to be made based on this table.
- getFormatter() - Method in class com.streambase.liveview.client.dynamictables.FilteredTableAlias
-
- getFreeMemory() - Method in class com.streambase.sb.monitor.SystemInfo
-
Returns the amount of free memory in the StreamBase server process.
- getFullLogicalName(StreamProperties) - Static method in class com.streambase.sb.client.DeMUXStreamBaseClient
-
- getFullyQualifiedName() - Method in class com.streambase.sb.operator.Operator
-
Return the fully qualified name of this operator.
- getFunction(int) - Method in class com.streambase.sb.Tuple
-
Return the value of the function field at a specified field index.
- getFunction(String) - Method in class com.streambase.sb.Tuple
-
Return the value of the named function field.
- getFunction(Schema.Field) - Method in class com.streambase.sb.Tuple
-
Return the value of the given function field.
- getFutureTimestamp(long, TimeUnit) - Method in interface com.streambase.sb.TimeService
-
Get the time stamp of a time point based on the specific time advance
- getGCCount() - Method in class com.streambase.sb.monitor.SystemInfo.GCInfo
-
Returns the total number of collections that have occurred since the JVM started.
- getGCCountDelta() - Method in class com.streambase.sb.monitor.SystemInfo.GCInfo
-
Returns the number of collections that have occurred since the previous Snapshot.
- getGCollectors() - Method in class com.streambase.sb.monitor.SystemInfo
-
Return a collection of information on all the garbage collectors in the JVM
- getGCTimeMS() - Method in class com.streambase.sb.monitor.SystemInfo.GCInfo
-
Returns the approximate accumulated collection elapsed time in milliseconds since the JVM started.
- getGCTimeMSDelta() - Method in class com.streambase.sb.monitor.SystemInfo.GCInfo
-
Returns the approximate collection time in milliseconds for this cycle.
- getGroup() - Method in interface com.streambase.liveview.client.Table
-
A table can be assigned to a logical group.
- getGroupByExprs() - Method in class com.streambase.liveview.client.QueryConfig
-
the group-by expressions set by equivalent setters
- 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.
- getIconResource(Operator.IconKind) - Method in class com.streambase.sb.operator.Operator
-
Clients should override to support custom icons.
- getId() - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Gets the value of the id property.
- getId() - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- getIncludeInternal() - Method in class com.streambase.liveview.client.QueryConfig
-
Is this query set to include internal fields?
- getIndex() - Method in class com.streambase.sb.Schema.Field
-
Return the index of this field within the Schema
- getIndices() - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
This method returns the list of Indices for the table.
- getIndices() - Method in interface com.streambase.liveview.client.Table
-
Returns all the indices for the table.
- getInputPortCount() - Method in class com.streambase.sb.monitor.OperatorInfo
-
Deprecated.
- 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.
- getInputStream() - Method in interface com.streambase.liveview.client.alert.SendTupleAction
-
Gets the value of the inputStream property.
- getInputStreams() - Method in class com.streambase.liveview.client.serverdatautility.StreambaseStreams
-
- getInputTuplesDequeuedDelta() - Method in class com.streambase.sb.monitor.OperatorInfo
-
Deprecated.
- getInputTuplesDequeuedTotal() - Method in class com.streambase.sb.monitor.OperatorInfo
-
Deprecated.
- getInputTuplesEnqueued() - Method in class com.streambase.sb.monitor.OperatorInfo
-
Returns the number of input tuples enqueued on each of this operator's input
streams 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
-
- getInsertAssignments() - Method in class com.streambase.liveview.client.dynamictables.RuleCase
-
- getInsertInitialValue() - Method in class com.streambase.liveview.client.dynamictables.Variable
-
- getInstance() - Method in class com.streambase.liveview.client.LiveViewPermission
-
- getInt(String, int) - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- getInt(String, int) - Method in interface com.streambase.liveview.server.table.plugin.TableProviderParameters
-
Get the first parameter with this key, interpreted as an integer.
- getInt(String) - Method in class com.streambase.sb.Tuple
-
Return the value of a named int field.
- getInt(int) - Method in class com.streambase.sb.Tuple
-
Return the value of the int field at a specified field index.
- getInt(Schema.Field) - Method in class com.streambase.sb.Tuple
-
Return the value of a specified int field.
- getInverse() - Method in enum com.streambase.sb.SchemaUtil.CoercionOptions
-
- getJavaClassname(ExternalServerConnectionType) - Static method in class com.streambase.liveview.server.table.plugin.TableProviderManager
-
- getJaxbQuery(QueryConfig, boolean) - Static method in class com.streambase.liveview.client.QueryConfig
-
- getKey() - Method in class com.streambase.liveview.client.AbstractTupleEvent
-
- getKeyFields() - Method in class com.streambase.liveview.client.AbstractTable
-
- getKeyFields() - Method in interface com.streambase.liveview.client.Query
-
Returns a list of fields describing the primary key for this table.
- getKeyFields() - Method in class com.streambase.liveview.client.QueryListenerWrapper
-
- getKeyFields() - Method in interface com.streambase.liveview.client.Table
-
Returns the schema which describes the key for the records in this table.
- getKeyFieldsCsv() - Method in interface com.streambase.liveview.client.Table
-
Returns the key fields table in the form of CSV.
- getKeyForEvent(AbstractTupleEvent, boolean) - Method in class com.streambase.liveview.client.LiveResult
-
- getKeyFromEvent(AbstractTupleEvent) - Method in class com.streambase.liveview.client.LiveResult
-
- getKeyPassphrase() - Method in class com.streambase.sb.client.StreamBaseURI
-
Return the passphrase for the key within the keystore for the connection.
- getKeys() - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- getKeys() - Method in interface com.streambase.liveview.server.table.plugin.TableProviderParameters
-
Get all the keys that were specified.
- getKeys() - Method in enum com.streambase.sb.monitor.StatsUtil.What
-
- 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.
- getKeyValue() - Method in class com.streambase.liveview.client.AbstractTupleEvent
-
- getLastSuccessfulConnect() - Method in interface com.streambase.liveview.client.LiveViewConnectionControl
-
If the current status is CONNECTED, this will have the time this connection was made.
- getLastUpdated() - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Gets the value of the lastUpdated property.
- getLastUpdated() - Method in class com.streambase.liveview.client.QueryConfig
-
- getLazilyCreatedExceptionsList() - Method in exception com.streambase.liveview.client.ValidationErrorsException
-
- getLeadershipStatus() - Method in class com.streambase.sb.client.DequeueResult
-
Return the leadership status of the server that produced this dequeue result.
- getLeadershipStatus() - Method in class com.streambase.sb.client.StreamBaseAdminClient
-
Get the leadership status of the server.
- getLeadershipStatus() - Method in interface com.streambase.sb.operator.Operator.RuntimeEnvironment
-
return the LeadershipStatus of this server
- getLegacyName() - Method in enum com.streambase.sb.NowImplementation
-
- getLimit() - Method in class com.streambase.liveview.client.QueryConfig
-
Get the limit or -1 if not specified
- getLinkedPropertyNames() - Method in class com.streambase.sb.operator.parameter.ConfigurationChooserPropertyDescriptor
-
- getList(String) - Method in class com.streambase.sb.Tuple
-
Return the value of a named list field.
- getList(int) - Method in class com.streambase.sb.Tuple
-
Return the value of the list field at a specified field index.
- getList(Schema.Field) - Method in class com.streambase.sb.Tuple
-
Return the value of a specified list field.
- getListener() - Method in class com.streambase.liveview.client.ConnectionConfig
-
Get the connection listener
- getListener() - Method in class com.streambase.liveview.client.MultiConnectionConfig
-
- getLocallyDefinedFields() - Method in class com.streambase.sb.Schema
-
- getLocation() - Method in class com.streambase.sb.operator.Operator
-
Return the Operator-wide location, useful for error reporting not associated
to a particular property.
- getLocation(String) - Method in class com.streambase.sb.operator.Operator
-
Return a new location within this Operator, associated with the given property name.
- getLocation() - Method in class com.streambase.sb.Schema.Field
-
- getLogger() - Method in class com.streambase.sb.operator.Operator
-
Retrieves a Logger suitable for logging messages and exceptions
for this Operator.
- getLong(String) - Method in class com.streambase.sb.Tuple
-
Return the value of a named long field.
- getLong(int) - Method in class com.streambase.sb.Tuple
-
Return the value of the long field at a specified field index.
- getLong(Schema.Field) - Method in class com.streambase.sb.Tuple
-
Return the value of a specified long field.
- getLvUri() - Method in interface com.streambase.liveview.client.alert.LVPublishAlertAction
-
Gets the value of the lvUri property.
- getMapperCacheContent(String) - Method in class com.streambase.sb.client.StreamBaseAdminClient
-
- getMaskDisplay() - Method in class com.streambase.sb.operator.parameter.SBPropertyDescriptor
-
- 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
has ever seen.
- getMaxRandomReconnectDelaySeconds() - Method in class com.streambase.liveview.client.MultiConnectionConfig
-
- getMaxTuplesInDequeueQueue() - Method in class com.streambase.sb.client.ClientSettings
-
The dequeue thread stores tuples to be dequeued by a client in a queue.
- getMessage() - Method in exception com.streambase.liveview.client.ValidationErrorsException
-
- getMessage() - Method in exception com.streambase.sb.StreamBaseListException
-
Return the Exceptions message including all the list of all of the causes
- getMessageTemplate() - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Gets the value of the messageTemplate property.
- getMessageTemplate() - Method in interface com.streambase.liveview.client.alert.PublishAlertAction
-
Gets the value of the messageTemplate property.
- getModName(String) - Static method in class com.streambase.sb.monitor.Snapshot
-
Given a queue name, retrieve the module name.
- 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.
- getMultiLine() - Method in class com.streambase.sb.operator.parameter.SBPropertyDescriptor
-
- getMultivalue(String) - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- getMultivalue(String) - Method in interface com.streambase.liveview.server.table.plugin.TableProviderParameters
-
For keys that might appear more than once, this will return all of the values for that key.
- getName() - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Gets the value of the name property.
- getName() - Method in class com.streambase.liveview.client.dynamictables.Variable
-
- getName() - Method in class com.streambase.liveview.client.QueryConfig
-
- getName() - Method in interface com.streambase.liveview.client.Table
-
The name of the table.
- getName() - Method in class com.streambase.sb.CompleteDataType
-
Get the name of this complete type
- getName() - Method in enum com.streambase.sb.DataType
-
Get the name of this DataType.
- getName() - Method in interface com.streambase.sb.Function
-
Returns the name of this function.
- 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 fully qualified name of the operator.
- getName(StatTuplev3) - Method in class com.streambase.sb.monitor.StatsUtil.IdentityHelper
-
- getName(long) - Method in class com.streambase.sb.monitor.StatsUtil.IdentityManager
-
Get the name associated with the ID.
- getName() - Method in class com.streambase.sb.monitor.SystemInfo.GCInfo
-
Get the JVM name for the garbage collector
- 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 or null at runtime.
- getName() - Method in class com.streambase.sb.StreamProperties
-
Return the stream name part of the name
- getNamedSchema(String) - Method in class com.streambase.sb.operator.Operator
-
Retrieves a named schema
- getNamedSchema(String) - Method in interface com.streambase.sb.SchemaUtil.SchemaProvider
-
A request to provide a Schema for the given name.
- getNameFromId(long) - Method in class com.streambase.sb.monitor.StatsUtil.IdentityHelper
-
Stats Stream v3 only.
- getNestedField(String) - Method in class com.streambase.sb.Schema.Field
-
Return a field that identifies a field in a nested tuple field.
- getNestedFields() - Method in class com.streambase.sb.Schema.Field
-
Return an array of fields, each of which identifies a field in a nested tuple field.
- getNowImpl() - Method in class com.streambase.sb.unittest.BaseTestEnvironment
-
- getNowImpl() - Method in interface com.streambase.sb.unittest.SBTestEnvironment
-
- getNullString() - Method in class com.streambase.sb.Tuple.DefaultTupleFormatter
-
This value will be returned by this formatter when any null field value
is asked to be formatted.
- getNumParameters() - Method in class com.streambase.sb.client.StreamBaseURI
-
Return the number of URI parameters
- getNumTasks() - Method in class com.streambase.sb.monitor.ModuleInfo
-
Return the number of tasks on the task queue
- getNumTuples() - Method in class com.streambase.sb.monitor.StreamInfo
-
Return the total number of tuples on the stream since the stream was created
- getOld() - Method in class com.streambase.liveview.client.TupleUpdatedEvent
-
Retrieve the old version of the tuple.
- getOpenTimeoutMS() - Method in class com.streambase.sb.client.ClientSettings
-
OpenTimeoutMS is used as a timeout value for opening a
binary) connection between the client and server.
- getOperatorConfigurationAccessor() - Method in class com.streambase.sb.operator.Operator
-
Provides access to operator and adapter configuration information from the server's configuration file.
- 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.
- getOperatorProperty(String, String) - Method in class com.streambase.sb.client.StreamBaseAdminClient
-
Return the value of the given property on the given Operator.
- getOperatorType(StreamBaseClient, String) - Method in class com.streambase.sb.monitor.Snapshot
-
- getOriginIndex() - Method in exception com.streambase.sb.SchemaUtil.FieldConflictException
-
- getOutputPortCount() - Method in class com.streambase.sb.monitor.OperatorInfo
-
Deprecated.
- 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 for the given output port (zero-based).
- getOutputStreams() - Method in class com.streambase.liveview.client.serverdatautility.StreambaseStreams
-
- getOutputTuplesEnqueued() - Method in class com.streambase.sb.monitor.OperatorInfo
-
Returns the number of output tuples produced by this operator from a each output
port since the StreamBase Server was started.
- 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
-
- getOwner() - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Gets the value of the owner property.
- getOwner() - Method in class com.streambase.liveview.client.QueryConfig
-
- getParam(String) - Method in class com.streambase.sb.client.StreamBaseURI
-
Returns a parameter with a given key, or null if none exists.
- getParameter(String) - Method in class com.streambase.sb.client.StreamBaseURI
-
Returns a parameter with a given key, or null if none exists.
- getParameters() - Method in interface com.streambase.liveview.client.alert.ExecuteJavaAction
-
Gets the map of parameters.
- 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
-
- getParentSchemas() - Method in class com.streambase.sb.Schema
-
- getPassword() - Method in class com.streambase.liveview.client.ConnectionConfig
-
Get the password to connect with
- getPassword() - Method in class com.streambase.sb.client.StreamBaseURI
-
Return the password for the connection.
- getPath() - Method in class com.streambase.sb.feedsim.FeedSimCSVInputStream
-
Returns the path String this object was constructed with.
- 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 of CPU this operator using, the value is Exponentially Weighted Moving Average with alpha 0.75.
- getPercentUser() - Method in class com.streambase.sb.monitor.ThreadInfo
-
Returns the percent of user CPU time used by this thread, in microseconds.
- getPersistedVersion() - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Gets the value of the persistedVersion property.
- getPersistenceFolder() - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
This method returns the name of the folder where this table is persisted.
- getPivotAggExpr() - Method in class com.streambase.liveview.client.QueryConfig
-
Get the pivot aggregate expressions, 'PIVOT' clause
- getPivotField() - Method in class com.streambase.liveview.client.QueryConfig
-
Get the pivot 'FOR' clause
- getPivotValues() - Method in class com.streambase.liveview.client.QueryConfig
-
Get the pivot 'VALUES' clause
- 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.
- getPredicate() - Method in class com.streambase.liveview.client.QueryConfig
-
Get the predicate or null if not specified
- getPredicateFilter() - Method in class com.streambase.liveview.server.table.plugin.TablePropertiesConfigurationWrapper.FilterdAlias
-
Returns the predicate filter with this FilteredAlias instance.
- getPrimaryKeyFields() - Method in interface com.streambase.sb.operator.TableAccessor
-
The fields from the schema which make up the primary key.
- getProcessSize() - Method in class com.streambase.sb.monitor.SystemInfo
-
- getProfilerHits() - Method in class com.streambase.sb.monitor.OperatorInfo
-
- getProfilerMS() - Method in class com.streambase.sb.monitor.OperatorInfo
-
- getProfilerMSDelta() - Method in class com.streambase.sb.monitor.OperatorInfo
-
Number of milliseconds used by the operator, since the previous Snapshot.
- getProfilerUS() - Method in class com.streambase.sb.monitor.OperatorInfo
-
- getProfilerUSDelta() - Method in class com.streambase.sb.monitor.OperatorInfo
-
Number of microseconds used by the operator, since the previous Snapshot.
- getProjectBin() - Method in class com.streambase.liveview.server.table.plugin.TableProviderManager
-
Get the projectBin, which is the writable base directory where all stuff that we write should go.
- getPropertyDescriptors() - Method in class com.streambase.sb.operator.parameter.SBSimpleBeanInfo
-
Use getPropertyDescriptorsChecked rather than getPropertyDescriptors when extending
SBSimpleBeanInfo.
- getPropertyDescriptorsChecked() - Method in interface com.streambase.sb.operator.parameter.SBBeanInfo
-
Returns the property descriptors of an operator or adapter
- getPropertyDescriptorsChecked() - Method in class com.streambase.sb.operator.parameter.SBSimpleBeanInfo
-
- getProposedInputSchemas(String) - Method in class com.streambase.sb.operator.Operator
-
Override to provide schemas that Studio will offer to users to import into their projects.
- getProposedOutputSchemas(String) - Method in class com.streambase.sb.operator.Operator
-
Override to provide schemas that Studio will offer to users to import into their projects.
- getProvider() - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- getQualifiedName() - Method in class com.streambase.sb.StreamProperties
-
Return the fully qualified name of this Stream.
- getQuery() - Method in class com.streambase.liveview.client.QueryClosedEvent
-
Get the closed query
- getQuery() - Method in class com.streambase.liveview.client.QueryConfig
-
Retrieves the string representation of the query.
- getQueryId() - Method in interface com.streambase.liveview.client.Query
-
This will match the queryId on the events.
- getQueryId() - Method in class com.streambase.liveview.client.QueryListenerWrapper
-
- getQueryLanguages() - Method in interface com.streambase.liveview.client.Table
-
Returns the languages that can be used for queries against this table.
- getQueryType() - Method in class com.streambase.liveview.client.QueryConfig
-
Get the type of query
- getQuiescence() - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Gets the value of the quiescence property.
- getQuiescentTimeoutMS() - Method in class com.streambase.sb.client.ClientSettings
-
QuiescentTimeoutMS is a timeout value that is used to determine how long
a client's binary connection will wait for a heartbeat message from a
server.
- getReadable() - Method in enum com.streambase.liveview.client.alert.AlertRuleAction.ActionType
-
- getReadable() - Method in enum com.streambase.liveview.client.LiveViewClientCapability
-
- getReadable() - Method in enum com.streambase.liveview.client.LiveViewTableCapability
-
- getReadable() - Method in enum com.streambase.liveview.client.Table.TableGroup
-
- getReadable() - Method in enum com.streambase.liveview.client.Table.TableStatus
-
- getRealQuery() - Method in class com.streambase.liveview.client.QueryListenerWrapper
-
- getReconnectSleepMS() - Method in class com.streambase.sb.client.ClientSettings
-
How long will a client wait between reconnect attempts when in HA mode
- getRemappedBaseName() - Method in class com.streambase.liveview.server.table.plugin.TablePropertiesConfigurationWrapper
-
Returns the re-mapped name for the current table whose FilteredAlias instances are wrapped in this TablePropertiesConfigurationWrapper instance.
- getResourceContents(String) - Method in interface com.streambase.sb.operator.IResourceReader
-
- getResourceContents(String) - Method in class com.streambase.sb.operator.Operator
-
Returns an open input stream on the contents of the named resource file.
- getResourceFile(String) - Method in interface com.streambase.sb.operator.IResourceReader
-
- getResourceFile(String) - Method in class com.streambase.sb.operator.Operator
-
Returns a File pointing to the regular file or directory
if it exists.
- getResponseOutputSchema() - Method in class com.streambase.liveview.client.SendTupleInfo
-
- getResponseOutputStreamName() - Method in class com.streambase.liveview.client.SendTupleInfo
-
- getRetryCount() - Method in interface com.streambase.liveview.client.LiveViewConnectionControl
-
Valid only if the current state is TRYING_TO_CONNECT.
- getRetryIntervalMillis() - Method in class com.streambase.liveview.client.MultiConnectionConfig
-
- getReturnType() - Method in class com.streambase.sb.CompleteDataType.FunctionType
-
- getReturnType() - Method in class com.streambase.sb.CompleteDataType
-
For function types, return the return type of the function.
- getReturnType() - Method in interface com.streambase.sb.Function
-
Returns the CompleteDataType for the function's return type.
- getReuseTuple() - Method in class com.streambase.sb.operator.Operator
-
Get the state of the input Tuple reuse flag.
- getRowDeleteRule() - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
The rule is a gateway for row to be published.
- getRuntimeEnvironment() - Method in class com.streambase.sb.operator.Operator
-
- getRuntimeInputSchema(int) - Method in class com.streambase.sb.operator.Operator
-
Returns the schema of an input port at runtime.
- getRuntimeOutputSchema(int) - Method in class com.streambase.sb.operator.Operator
-
- getSbUri() - Method in interface com.streambase.liveview.client.alert.SendTupleAction
-
Gets the value of the sbUri property.
- getSbUri() - Method in class com.streambase.liveview.client.SendTupleInfo
-
- getSchema() - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
This method returns the string representation for the schema of the table being configured.
- getSchema() - Method in class com.streambase.liveview.client.QueryListenerWrapper
-
- getSchema() - Method in interface com.streambase.liveview.client.TablePublisher
-
Schema needed to create tuples for the publish method.
- getSchema() - Method in class com.streambase.sb.client.DequeueResult
-
Returns the schema for the tuples dequeued, may return null
- getSchema() - Method in class com.streambase.sb.CompleteDataType
-
For tuple types, return the tuple's schema.
- getSchema() - Method in class com.streambase.sb.CompleteDataType.TupleType
-
- getSchema() - Method in class com.streambase.sb.feedsim.FeedSimTupleInputStream
-
This method must return the Schema of the data to be returned by readTuple()
- getSchema() - Method in interface com.streambase.sb.operator.TableAccessor
-
The schema for rows in this table.
- getSchema() - Method in class com.streambase.sb.Schema.Field
-
Return the schema for this field.
- 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
- getSchema() - Method in interface com.streambase.sb.unittest.Dequeuer
-
Get the
Schema for the associated stream.
Equivalent to
getStreamProperties().getSchema()
- getSchema() - Method in interface com.streambase.sb.unittest.Enqueuer
-
Get the
Schema for the associated stream.
Equivalent to
getStreamProperties().getSchema()
- getSchemaByHash(byte[]) - Method in class com.streambase.sb.client.StreamBaseClient
-
Return the Schema object for the given hash value
- getSchemaByHash(byte[]) - Method in interface com.streambase.sb.SchemaUtil.SchemaProvider
-
request a schema by hash
- getSchemaByName(String) - Method in class com.streambase.sb.client.StreamBaseClient
-
Return the Schema object for the given name.
- getSchemaForCapture(String, int) - Method in class com.streambase.sb.operator.Operator
-
Finds the schema for the given capture name in the context that this operator
is running under.
- getSchemaForStream(String) - Method in class com.streambase.sb.client.StreamBaseClient
-
Return the schema of a stream.
- getSearchKeywords() - Method in class com.streambase.sb.operator.Operator
-
Override to declare strings that assist the user in filtering for this operator
when in Studio.
- getSelectExprs() - Method in class com.streambase.liveview.client.QueryConfig
-
The selectExprs set by the equivalent setters
- getSendTupleInfo(StreamBaseURI, String, String) - Method in interface com.streambase.liveview.client.LiveViewConnection
-
Gets the schemas associated with streams, for the purposes of using SendTupleAction.
- getServerURI() - Method in class com.streambase.sb.client.DequeueResult
-
return the server that produced this DequeueResult.
- getServerUtilityDataProvider() - Method in interface com.streambase.liveview.client.LiveViewConnection
-
- getSetter() - Method in class com.streambase.sb.operator.parameter.JavaEnumPropertyDescriptor
-
- getSeverity() - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Gets the value of the severity property.
- getSharedObject(Object) - Method in interface com.streambase.sb.operator.Operator.SharedObjectManager
-
get the SharedObject from this Container.
- getSharedObjectManager() - Method in interface com.streambase.sb.operator.Operator.RuntimeEnvironment
-
Return the SharedObjectManager
- getSharedObjectState(Object) - Method in interface com.streambase.sb.operator.Operator.SharedObjectManager
-
- getShortDescription() - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
This method gets the short description that is used to describe the table.
- getShortDescription() - Method in interface com.streambase.liveview.client.Table
-
A short description of the table
- getShortDisplayName() - Method in class com.streambase.sb.operator.Operator
-
Return the short display name of this Operator.
- getShortName() - Method in class com.streambase.sb.Schema.Field
-
Return the last (which might be the only) segment of this Field
- getSize() - Method in enum 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
-
Return the size of the field (in bytes) without any header information.
- getSnapshotConcurrency() - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
Snapshot concurrency specifies the number of extra threads used to service the snapshot portion of queries.
- getSnapshotParallelism() - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
Snapshot parallelism determines the number of data regions used in parallel to publish to and scan from tables.
- getStateChangeTimeout() - Method in class com.streambase.sb.operator.Operator
-
- getStatsSchema() - Method in class com.streambase.sb.monitor.StreamBaseMonitor
-
Get the stats schema
- getStatsStreamName() - Method in class com.streambase.sb.monitor.StreamBaseMonitor
-
Get the stats stream name
- getStatus() - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- 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.
- getStatusMessage() - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Gets the value of the statusMessage property.
- getStatusMessage() - Method in class com.streambase.liveview.client.DynamicTableState
-
- getStreambaseStreams(String) - Method in interface com.streambase.liveview.client.serverdatautility.ServerUtilityDataProvider
-
Returns all the input and output streams for a given streambase URI
- getStreamInfo(String) - Method in class com.streambase.sb.monitor.Snapshot
-
Returns information about the specified stream.
- 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, CaptureTransformStrategy) - 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.StreamBaseClient
-
Return the StreamProperties for the given stream name
- getStreamProperties() - Method in class com.streambase.sb.monitor.StreamInfo
-
Returns the StreamProperties of the stream
- getStreamProperties() - Method in interface com.streambase.sb.unittest.Dequeuer
-
- getStreamProperties() - Method in interface com.streambase.sb.unittest.Enqueuer
-
- getStreamPropertiesByHash(String) - Method in class com.streambase.sb.client.StreamBaseClient
-
Return the StreamProperties for the given hash
StreamProperties are cached locally in the client.
- getStreamPropertiesByHash(byte[]) - Method in class com.streambase.sb.client.StreamBaseClient
-
Return the StreamProperties for the given hash
StreamProperties are cached locally in the client.
- getString(String, String) - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- getString(String, String) - Method in interface com.streambase.liveview.server.table.plugin.TableProviderParameters
-
Get the first parameter with this key, trimmed.
- getString(String) - Method in class com.streambase.sb.Tuple
-
Return the value of the named string field.
- getString(int) - Method in class com.streambase.sb.Tuple
-
Return the value of the named string field.
- getString(Schema.Field) - Method in class com.streambase.sb.Tuple
-
Return the value of a specified string field.
- getStringRep() - Method in interface com.streambase.sb.Function
-
Returns a string with the StreamBase expression that creates this function.
- getSubject() - Method in interface com.streambase.liveview.client.alert.SendEmailAction
-
Gets the value of the subject property.
- getSubscribedStreamNames() - Method in class com.streambase.sb.client.StreamBaseClient
-
Returns a Set of names of the Streams this client is currently subscribed
to.
- 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 milliseconds.
- getSystemTimeDeltaUS() - 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 millisecond.
- getSystemTimeTotalUS() - Method in class com.streambase.sb.monitor.ThreadInfo
-
Returns the system time spent by this thread since the StreamBase Server started, in microsecond.
- getTable() - Method in interface com.streambase.liveview.client.alert.IssueDeleteQueryAction
-
Gets the value of the table property.
- getTable(String) - Method in interface com.streambase.liveview.client.LiveViewConnection
-
Retrieve a specific table from the server
- getTable() - Method in class com.streambase.liveview.client.QueryConfig
-
Get the table or null if not specified
- getTable(String) - Method in interface com.streambase.liveview.server.table.plugin.TableProviderControl
-
Find the Table with this ID.
- getTable(String) - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- getTableAccessor(String) - Method in class com.streambase.sb.operator.Operator
-
Get a TableAccessor for a table in the local module by name of that table.
- getTableAccessor(String) - Method in interface com.streambase.sb.unittest.SBServerManager
-
Return a TableAccessor suitable for manipulating this table.
- getTableAccessor(String, CaptureTransformStrategy) - Method in interface com.streambase.sb.unittest.SBServerManager
-
Return a TableAccessor suitable for manipulating this table.
- getTableAdminManager() - Method in interface com.streambase.liveview.client.LiveViewConnection
-
Get the TableAdminManager, which provides an API to administer tables in the server.
- getTableCapabilities() - Method in interface com.streambase.liveview.client.Table
-
Returns the capabilities that this Table supports.
- getTableDeleteRule() - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
- getTableDeleteRules() - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
- getTableFilteredAliases(String) - Method in interface com.streambase.liveview.server.table.plugin.TableNameMapper
-
This will match the name against the selector.
- getTableFilteredAliases(String) - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- getTableName() - Method in interface com.streambase.liveview.client.alert.LVPublishAlertAction
-
Gets the value of the tableName property.
- getTablename() - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
This method the name of the table from the Table Configuration
- getTableName() - Method in class com.streambase.liveview.client.DynamicTableState
-
- getTablePublisher(String) - Method in interface com.streambase.liveview.client.Table
-
- getTablePublisher(String, int, long, TimeUnit) - Method in interface com.streambase.liveview.client.Table
-
Retrieve a publisher instance allowing the client to publish data to the table.
- getTables() - Method in interface com.streambase.liveview.server.table.plugin.TableProviderControl
-
Get a collection of all the CatalogedTables that belong to your TableProvider.
- getTables() - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- getTableSpaceRef() - Method in interface com.streambase.liveview.client.Table
-
Returns the table space reference for the given table.
- getTablesTable() - Method in class com.streambase.liveview.server.table.plugin.TableProviderManager
-
- getTableStatus() - Method in class com.streambase.liveview.client.DynamicTableState
-
- getTableStatus() - Method in interface com.streambase.liveview.client.Table
-
Get the status of the table.
- getTableStatusMessage() - Method in interface com.streambase.liveview.client.Table
-
Returns the table status message.
- getTargetInputSchema() - Method in class com.streambase.liveview.client.SendTupleInfo
-
- getTargetInputStreamName() - Method in class com.streambase.liveview.client.SendTupleInfo
-
- getTargetTime() - Method in class com.streambase.sb.client.StreamBaseAdminClient
-
- getTargetTime() - Method in interface com.streambase.sb.TimeService
-
Get the current time in milliseconds from the perspective of this time service
- getTest() - Method in class com.streambase.liveview.client.dynamictables.RuleCase
-
- getThreadInfo(String) - Method in class com.streambase.sb.monitor.Snapshot
-
Returns information about the specified thread.
- getTimeForTableStartDrop() - Method in class com.streambase.liveview.client.DynamicTableState
-
- getTimeout(TimeUnit) - Method in class com.streambase.sb.unittest.Expecter
-
get the timeout that the expector will use for each call to expect*()
- getTimeoutMillis() - Method in class com.streambase.liveview.client.MultiConnectionConfig
-
The amount of time to consider a connection attempt failed.
- getTimePredicateInMillis() - Method in class com.streambase.liveview.client.QueryConfig
-
Get the time predicate or -1 if not specified
- getTimeRunning() - Method in class com.streambase.sb.monitor.SystemInfo
-
Returns the time that the StreamBase Server has been running, in seconds.
- getTimeService() - Method in interface com.streambase.sb.unittest.SBServerManager
-
Return the current TimeService implementation used by StreamBase server
- getTimestamp() - Method in class com.streambase.sb.monitor.Snapshot
-
Return the time when this snapshot was taken.
- getTimestamp(String) - Method in class com.streambase.sb.Tuple
-
Return the value of a named timestamp field.
- getTimestamp(int) - Method in class com.streambase.sb.Tuple
-
Return the value of the timestamp field at a specified field index.
- getTimestamp(Schema.Field) - Method in class com.streambase.sb.Tuple
-
Return the value of a specified timestamp field.
- getTimestampField() - Method in class com.streambase.liveview.client.QueryConfig
-
Get the value set in setTimeWindow
- getTo() - Method in interface com.streambase.liveview.client.alert.SendEmailAction
-
Gets the value of the to property.
- getTotalInputTuplesEnqueued() - Method in class com.streambase.sb.monitor.OperatorInfo
-
Returns the total number of input tuples enqueued on all of this operator's input
streams since the StreamBase Server was started.
- getTotalMemory() - Method in class com.streambase.sb.monitor.SystemInfo
-
Returns the total amount of memory available for use in the StreamBase
server process.
- getTotalNumberThreads() - Method in class com.streambase.sb.monitor.SystemInfo
-
Return the total number of threads running in the JVM (including non-StreamBase threads)
- getTotalOutputTuplesEnqueued() - 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.
- getTotalProfilerHits() - Method in class com.streambase.sb.monitor.OperatorInfo
-
- getTotalProfilerMS() - Method in class com.streambase.sb.monitor.OperatorInfo
-
- getTotalProfilerUS() - Method in class com.streambase.sb.monitor.OperatorInfo
-
- getTuple() - Method in class com.streambase.liveview.client.AbstractTupleEvent
-
Get the tuple
- getTuple(KeyValue) - Method in class com.streambase.liveview.client.LiveResult
-
Get a tuple from the KeyValue obtained from an Event.
- getTuple(Schema.Field) - Method in class com.streambase.sb.Tuple
-
Return a reference (not a copy) to the specified nested tuple field.
- getTuple(String) - Method in class com.streambase.sb.Tuple
-
Return a reference (not a copy) to the specified nested tuple field.
- getTuple(int) - Method in class com.streambase.sb.Tuple
-
Return a reference (not a copy) to the specified nested tuple field.
- getTupleCaptureTransformer(Schema) - Method in class com.streambase.sb.operator.Operator
-
Get a TupleCaptureTransformer capable of translating tuples with the given schema to the equivalent
schema with all the capture fields expanded out, and translating expanded tuples back into tuples with
the given schema
This method may only be called at runtime; the exact schemas of any capture fields are not fully determined
at typecheck time.
- getTupleCount() - Method in class com.streambase.sb.client.DequeueResult
-
Returns the number of tuples dequeued.
- getTupleCount() - Method in class com.streambase.sb.client.SimpleDequeueResult
-
- getTupleDequeueCount() - Method in class com.streambase.sb.client.StreamBaseClient
-
Returns the number of tuples this client has dequeued from the server.
- getTupleEnqueueCount() - Method in class com.streambase.sb.client.StreamBaseClient
-
Returns the number of tuples this client has actually enqueued to the server.
- getTupleFormatter() - Static method in class com.streambase.sb.Tuple
-
Returns a shared instance of the default tuple field formatter that converts each type
to String using Java default String conversions.
- getTuples() - Method in class com.streambase.liveview.client.LiveResult
-
Retrieves the current tuples in the result
- getTuples(boolean) - Method in class com.streambase.liveview.client.LiveResult
-
Retrieves the current tuples in the result
- getType() - Method in class com.streambase.liveview.client.dynamictables.Variable
-
- getType() - Method in class com.streambase.liveview.client.LiveViewPermission
-
- getType() - Method in class com.streambase.sb.monitor.OperatorInfo
-
Returns the type of the operator.
- getType() - Method in class com.streambase.sb.operator.parameter.JavaTypePropertyDescriptor
-
- getType() - Method in class com.streambase.sb.operator.parameter.ResourceFilePropertyDescriptor
-
- getType() - Method in class com.streambase.sb.Timestamp
-
Return the current type of timestamp
- getTypecheckInputSchema(int) - Method in class com.streambase.sb.operator.Operator
-
Returns the schema of an input port that was set at application typecheck
time.
- getTypecheckOutputSchema(int) - Method in class com.streambase.sb.operator.Operator
-
Return the output schema as set by typecheck.
- getUIHints() - Method in class com.streambase.sb.operator.parameter.SBPropertyDescriptor
-
Retrieves the currently associated
UIHints object for this property
- getUniqueSuffix() - Method in class com.streambase.sb.client.DeMUXStreamBaseClient
-
This manages a threadsafe counter which will give a different value each time it is called.
- getUnmetClientCapabilities() - Method in interface com.streambase.liveview.client.Table
-
Every table might have requiredClientCapabilities which
- getUpdateAssignments() - Method in class com.streambase.liveview.client.dynamictables.RuleCase
-
- getUpdateByContainerId(int) - Method in interface com.streambase.sb.monitor.StatsUtil.IdentityHelper.IdentityUpdater
-
- getUpdateInitialValue() - Method in class com.streambase.liveview.client.dynamictables.Variable
-
- getUri() - Method in class com.streambase.liveview.client.ConnectionConfig
-
Get the uri to connect with
- getUri() - Method in interface com.streambase.liveview.client.LiveViewConnectionControl
-
Convenience method that is the same as getConnectionConfig().getUri()
- getURI() - Method in interface com.streambase.sb.operator.Operator.RuntimeEnvironment
-
Return the URI of this Server.
- getURI() - Method in interface com.streambase.sb.unittest.SBServerManager
-
return the URI of the server
- 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.
- getUsername() - Method in class com.streambase.liveview.client.ConnectionConfig
-
Get the username to connect with
- getUserTimeDelta() - Method in class com.streambase.sb.monitor.ThreadInfo
-
Returns the user time spent by thread since the last Snapshot, in millisecond.
- getUserTimeDeltaUS() - Method in class com.streambase.sb.monitor.ThreadInfo
-
Returns the user time spent by thread since the last Snapshot, in microsecond.
- getUserTimeTotal() - Method in class com.streambase.sb.monitor.ThreadInfo
-
Returns the user time spent by thread since the StreamBase Server started, in millisecond.
- getUserTimeTotalUS() - Method in class com.streambase.sb.monitor.ThreadInfo
-
Returns the user time spent by thread since the StreamBase Server started, in microsecond.
- getValue() - Method in class com.streambase.liveview.client.dynamictables.Assignment
-
- getValue() - Method in enum com.streambase.sb.NowImplementation
-
- getValueAsUniqueString() - Method in class com.streambase.liveview.client.HashableTuple
-
- getValueAsUniqueString() - Method in interface com.streambase.liveview.client.KeyValue
-
Returns an opaque unique String that can be used to identify this tuple.
- getValues() - Method in class com.streambase.sb.operator.parameter.EnumPropertyDescriptor
-
Return the list of allowable values for the property.
- getVariableName() - Method in class com.streambase.liveview.client.dynamictables.Assignment
-
- getVariables() - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
This method is used to get the list of variables
Variable with this Table Configuration
- getVersion() - Method in interface com.streambase.liveview.client.LiveViewConnectionControl
-
If this server has never been successfully connected to, this value will be null.
- getVersion() - Method in class com.streambase.liveview.client.QueryConfig
-
- getVersion() - Static method in class com.streambase.sb.client.StreamBaseClient
-
Get the version of this client, returned in the format specified by Version.INFO_LINE
- getVersionString() - Method in class com.streambase.liveview.client.QueryConfig
-
- getWakeup() - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- getWallClockTimeService() - Static method in class com.streambase.sb.unittest.TimeServiceFactory
-
- getWidth() - Method in enum com.streambase.sb.operator.parameter.UIHints.TextWidthHint
-
Returns the width for this hint.
- getWindowEndTimeExpr() - Method in class com.streambase.liveview.client.QueryConfig
-
Get the value set in setTimeWindow
- getWindowStartTimeExpr() - Method in class com.streambase.liveview.client.QueryConfig
-
Get the value set in setTimeWindow
- getWriteTimeoutMS() - Method in class com.streambase.sb.client.ClientSettings
-
WriteTimeoutMS is used as a timeout for write operations
in a binary connection between the client and server.
- getXmlRpcTimeoutMS() - Method in class com.streambase.sb.client.ClientSettings
-
XmlrpcTimeoutMS is used as a timeout for XMLRPC requests to the
server.
- GOOD - Static variable in class com.streambase.sb.client.DequeueResult
-
Status code indicating a normal dequeue
- gotBegin - Variable in class com.streambase.sb.monitor.Snapshot
-
- GROUP_FIELD - Static variable in interface com.streambase.liveview.client.Table
-
- 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
- SavedWorkspaces() - Constructor for class com.streambase.liveview.client.LiveViewServerCapability.SavedWorkspaces
-
- saveLVConf(String, LiveviewConfiguration, boolean) - Method in class com.streambase.liveview.server.table.plugin.TableProviderManager
-
- SBBeanInfo - Interface in com.streambase.sb.operator.parameter
-
BeanInfos of StreamBase adapters should consider implementing this interface to gain better handling of property
errors.
- SBExpressionPropertyDescriptor - Class in com.streambase.sb.operator.parameter
-
A property descriptor that allows a user to define a property that
supports StreamBase expressions.
- SBExpressionPropertyDescriptor(String, Class<?>, String, String, int) - Constructor for class com.streambase.sb.operator.parameter.SBExpressionPropertyDescriptor
-
Construct a property descriptor with non-standard read/write method names.
- SBExpressionPropertyDescriptor(String, Class<?>, int) - Constructor for class com.streambase.sb.operator.parameter.SBExpressionPropertyDescriptor
-
Construct a property descriptor.
- SBExpressionPropertyDescriptor(PropertyDescriptor, Class<?>, int) - Constructor for class com.streambase.sb.operator.parameter.SBExpressionPropertyDescriptor
-
Copy a property descriptor.
- SBExpressionPropertyType - Annotation Type in com.streambase.sb.operator.parameter
-
A Java annotation to be used on the getter method associated with a
SBExpressionPropertyDescriptor whose type is "non-simple" (e.g., a
list or tuple type).
- sbMonitor - Variable in class com.streambase.sb.monitor.Snapshot
-
- SBPropertyDescriptor - Class in com.streambase.sb.operator.parameter
-
PropertyDescriptor subclass used by StreamBase operators and adapters
to describe a property.
- 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).
- SBServerManager - Interface in com.streambase.sb.unittest
-
- SBSimpleBeanInfo - Class in com.streambase.sb.operator.parameter
-
SimpleBeanInfo subclass used by StreamBase operators and adapters to provide
the set of properties available by the operator or adapter.
- SBSimpleBeanInfo() - Constructor for class com.streambase.sb.operator.parameter.SBSimpleBeanInfo
-
- SBTestEnvironment - Interface in com.streambase.sb.unittest
-
This interface is not expected to be implemented by end-users.
- scheduleRunnable(Date, Runnable) - Method in class com.streambase.sb.operator.Operator
-
Schedules a Runnable object to be run at some future point as part of
the same parallel region as this Operator.
- SCHEMA - Static variable in class com.streambase.sb.EntityType
-
Represents a StreamBase schema.
- Schema - Class in com.streambase.sb
-
Represents a StreamBase schema as a list of
Schema.Fields, and should be used
to create
Tuple objects.
- Schema(String, List<Schema.Field>) - Constructor for class com.streambase.sb.Schema
-
- Schema(Element) - Constructor for class com.streambase.sb.Schema
-
Construct a Schema from an XMLElement
- Schema(String) - Constructor for class com.streambase.sb.Schema
-
Construct a Schema out of XML represented as a String
- Schema(String, Schema.Field...) - Constructor for class com.streambase.sb.Schema
-
- Schema(String, String, Schema.Field...) - Constructor for class com.streambase.sb.Schema
-
- Schema(String, Schema) - Constructor for class com.streambase.sb.Schema
-
Construct a Schema with a new name from another schema
- Schema(Schema) - Constructor for class com.streambase.sb.Schema
-
Construct a Schema from another schema
- Schema.Field - Class in com.streambase.sb
-
Information (name, type, and optionally size) about a field in a Schema.
- SchemaMismatchException - Exception in com.streambase.sb
-
- SchemaMismatchException(LocatedItem, String, Schema, Schema) - Constructor for exception com.streambase.sb.SchemaMismatchException
-
- SchemaTraversal() - Constructor for class com.streambase.sb.SchemaUtil.SchemaTraversal
-
- SchemaUtil.CoercionOptions - Enum in com.streambase.sb
-
- SchemaUtil.CopyOptions - Enum in com.streambase.sb
-
Options used when copying Schemas
- SchemaUtil.FieldConflictException - Exception in com.streambase.sb
-
- SchemaUtil.SchemaProvider - Interface in com.streambase.sb
-
- SchemaUtil.SchemaTraversal<T extends java.lang.Exception> - Class in com.streambase.sb
-
a class that can be used to traverse all nested schemas in a schema
- SchemaValidationException - Exception in com.streambase.sb
-
Exception to indicate validation failures
- SchemaValidationException(Location, String, String) - Constructor for exception com.streambase.sb.SchemaValidationException
-
- SCORE_FAIL - Static variable in class com.streambase.sb.CompleteDataType
-
- SCORE_PASS - Static variable in class com.streambase.sb.CompleteDataType
-
- 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.
- secondaryConnectionLost(LiveViewConnectionControl) - Method in class com.streambase.liveview.client.MultiConnectionListener.MultiConnectionListenerBase
-
- secondaryConnectionLost(LiveViewConnectionControl) - Method in interface com.streambase.liveview.client.MultiConnectionListener
-
This will be called when one of the secondary connections has been lost.
- 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
- SemanticValidationException - Exception in com.streambase.sb
-
- SemanticValidationException(String, ApplicationValidationException) - Constructor for exception com.streambase.sb.SemanticValidationException
-
- SemanticValidationException(LocatedItem, String, Throwable) - Constructor for exception com.streambase.sb.SemanticValidationException
-
- SemanticValidationException(LocatedItem, String) - Constructor for exception com.streambase.sb.SemanticValidationException
-
- SemanticValidationException(LocatedItem, Throwable) - Constructor for exception com.streambase.sb.SemanticValidationException
-
- SendEmailAction - Interface in com.streambase.liveview.client.alert
-
Causes an email to be sent when this alert is triggered.
- sendErrorOutput(String) - Method in class com.streambase.sb.operator.Operator
-
Send an error tuple from this operator's error port.
- sendErrorOutput(Throwable) - Method in class com.streambase.sb.operator.Operator
-
Send an exception via the error output port
- sendErrorOutput(Throwable, int, Tuple) - Method in class com.streambase.sb.operator.Operator
-
Send an exception via the error output port
- sendOutput(int, Tuple) - Method in class com.streambase.sb.operator.Operator
-
Enqueue a Tuple to be sent synchronously to downstream operators.
- sendOutput(int, List<Tuple>) - Method in class com.streambase.sb.operator.Operator
-
Enqueue a List of Tuples to be sent synchronously to downstream operators.
- sendOutputAsync(int, Tuple) - Method in class com.streambase.sb.operator.Operator
-
Enqueue a Tuple to be sent asynchronously to downstream operators.
- sendOutputAsync(int, List<Tuple>) - Method in class com.streambase.sb.operator.Operator
-
Enqueue a List of Tuples to be sent asynchronously to downstream operators.
- SENDTUPLE_ACTION_ENABLED - Static variable in class com.streambase.liveview.client.LiveViewProperties.AlertActions
-
- SendTupleAction - Interface in com.streambase.liveview.client.alert
-
An action which will send a Tuple to a named InputStream
- sendTupleAction(StreamBaseURI, String, Tuple, String, Schema, long, TimeUnit) - Method in interface com.streambase.liveview.client.LiveViewConnection
-
Sends a tuple to an existing StreamBase application.
- SendTupleInfo - Class in com.streambase.liveview.client
-
- SendTupleInfo(StreamBaseURI, String, String, Schema, Schema) - Constructor for class com.streambase.liveview.client.SendTupleInfo
-
- SeparatelyTransmittedExtendedKeys() - Constructor for class com.streambase.liveview.client.LiveViewServerCapability.SeparatelyTransmittedExtendedKeys
-
- serialize(ByteOrderedDataOutput) - Method in class com.streambase.sb.Tuple
-
Serialize this tuple into a ByteOrderedDataOutput
- serialize(ByteOrderedDataOutput, int) - Method in class com.streambase.sb.Tuple
-
Serialize this tuple into a ByteOrderedDataOutput while specifing the
tupleId.
- SERVER_CONF_PATH - Static variable in class com.streambase.sb.unittest.UnitTestProperties
-
A path to a .sbconf file for the test system.
- ServerManagerFactory - Class in com.streambase.sb.unittest
-
- ServerUtilityDataProvider - Interface in com.streambase.liveview.client.serverdatautility
-
The Interface provides methods to fetch server utility data
- setActive(boolean) - Method in interface com.streambase.liveview.client.LiveViewConnectionControl
-
If a connection is set to be inactive, it will stop attempting to connect to the server.
- setAggregateQuery(QueryConfig) - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
This method sets the aggregate query for the table.
- setAlertKey(String) - Method in interface com.streambase.liveview.client.alert.PublishAlertAction
-
Sets the value of the alertKey property.
- setAlertQueryConfig(QueryConfig) - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Sets the value of the alertQueryConfig property.
- setAlertRecipient(String) - Method in interface com.streambase.liveview.client.alert.PublishAlertAction
-
Sets the value of the alertRecipient property.
- setAlertRule(AlertRule) - Method in interface com.streambase.liveview.client.alert.AlertManager
-
Adds if it does not previously exist, or overwrites if it does (matching by id),
the given alert rule onto the server.
- setAlertType(AlertRule.Type) - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Sets the value of alertTypeproperty
- setApproximateSnapshotOrder(OrderDefinition) - Method in class com.streambase.liveview.client.QueryConfig
-
Return the snapshot part of the query in this approximate order,
subject to parallel scan interleaving.
- setBlobBuffer(String, ByteArrayView) - Method in class com.streambase.sb.Tuple
-
Set a named blob field to a copy of a specified blob.
- setBlobBuffer(int, ByteArrayView) - Method in class com.streambase.sb.Tuple
-
Set the blob field at a specified field index to a copy of a specified blob.
- setBlobBuffer(Schema.Field, ByteArrayView) - Method in class com.streambase.sb.Tuple
-
Set a specified blob field to a copy of a specified blob.
- setBody(String) - Method in interface com.streambase.liveview.client.alert.SendEmailAction
-
Sets the value of the body property.
- setBoolean(String, boolean) - Method in class com.streambase.sb.Tuple
-
Set a named boolean field to a specified value.
- setBoolean(int, boolean) - Method in class com.streambase.sb.Tuple
-
Set the boolean field at a specified field index to a specified value.
- setBoolean(Schema.Field, boolean) - Method in class com.streambase.sb.Tuple
-
Set a named boolean field to a specified value.
- setCapabilities(EnumSet<LiveViewClientCapability>) - Method in class com.streambase.liveview.client.ConnectionConfig
-
Set the ClientCapabilities that are supported by this client.
- setCapture(Schema.Field, Tuple) - Method in class com.streambase.sb.Tuple
-
Set a specified capture field to a copy of a specified tuple.
- setCapture(String, Tuple) - Method in class com.streambase.sb.Tuple
-
Set a specified capture field to a copy of a specified tuple.
- setCapture(int, Tuple) - Method in class com.streambase.sb.Tuple
-
Set a specified capture field to a copy of a specified tuple.
- setCaptureStrategy(CaptureTransformStrategy) - Method in class com.streambase.sb.operator.Operator
-
Set the capture transform strategy to use for the inputs and outputs
of this Operator.
- setClazz(String) - Method in interface com.streambase.liveview.client.alert.ExecuteJavaAction
-
Sets the value of the clazz property.
- setClientCapabilities(EnumSet<LiveViewClientCapability>) - Method in class com.streambase.liveview.client.MultiConnectionConfig
-
Declare your client capabilities to be something less than the current default.
- setCommand(String) - Method in interface com.streambase.liveview.client.alert.ExecuteOSCommandAction
-
Sets the value of the command property.
- setCompress(boolean) - Method in class com.streambase.liveview.client.ConnectionConfig
-
Enable or disable compression on this connection
- setConnectionMode(ConnectionMode) - Method in class com.streambase.liveview.client.MultiConnectionConfig
-
- setConnectionMonitor(ProgressMonitor) - Method in class com.streambase.liveview.client.ConnectionConfig
-
Sets the monitor to use by the api
- setConnectionStatus(ConnectionStatus, String) - Method in class com.streambase.sb.client.StreamBaseClient
-
- setCronString(String) - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Sets the value of the cronString property which is a cron expression.
- setDefaultCase(RuleCase) - Method in class com.streambase.liveview.client.dynamictables.FieldRule
-
- setDeletePredicate(String) - Method in interface com.streambase.liveview.client.alert.IssueDeleteQueryAction
-
Sets the value of the deletePredicate property.
- setDeprecated(boolean) - Method in class com.streambase.sb.operator.parameter.SBPropertyDescriptor
-
Set whether the property is deprecated.
- setDequeueQueue(DequeueResultsQueue) - Method in class com.streambase.sb.client.DeMUXStreamBaseClient
-
- setDequeueResultInterceptor(DequeueResult.Interceptor) - Method in class com.streambase.sb.client.DeMUXStreamBaseClient
-
- setDequeueResultInterceptor(DequeueResult.Interceptor) - Method in class com.streambase.sb.client.StreamBaseClient
-
Set the dequeue results interceptor for this client connection.
- setDescription(String) - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Sets the value of the description property.
- setDescription(String) - Method in interface com.streambase.liveview.client.alert.AlertRuleAction
-
Set the Description text
- setDescription(String) - Method in class com.streambase.liveview.client.dynamictables.FieldRule
-
- setDescription(String) - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
This method helps in setting the description for the table using this Table Configuration.
- setDescription(String) - Method in class com.streambase.liveview.client.QueryConfig
-
Configure the description for this query
- setDescription(String) - Method in class com.streambase.sb.Schema.Field
-
Sets this field's description.
- setDescription(String) - Method in class com.streambase.sb.Schema
-
Sets this schema's description.
- setDisplayDescription(String) - Method in class com.streambase.sb.operator.Operator
-
Set a description for this type of Operator.
- setDisplayName(String) - Method in class com.streambase.sb.operator.Operator
-
The display name is the String that's shown in the Operator Name field of
the Properties view, and in the detailed text for this operator in the
Palette view's Details mode.
- setDouble(String, double) - Method in class com.streambase.sb.Tuple
-
Set a named double field to a specified value.
- setDouble(int, double) - Method in class com.streambase.sb.Tuple
-
Set the double field at a specified field index to a specified value.
- setDouble(Schema.Field, double) - Method in class com.streambase.sb.Tuple
-
Set a named double field to a specified value.
- setDynamicVariable(String, Object) - Method in class com.streambase.sb.client.StreamBaseClient
-
Set the given dynamic variable to a new value
- setDynamicVariable(String, Object) - Method in class com.streambase.sb.operator.Operator
-
Sets the value of this module's dynamic variable.
- setEnabled(boolean) - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Sets the value of the enabled property.
- setEnabled(boolean) - Method in interface com.streambase.liveview.client.alert.AlertRuleAction
-
Set the enabled state for this action.
- setEnabled(String, boolean) - Method in interface com.streambase.liveview.server.table.plugin.TableProviderControl
-
Change the enabled state of an existing table.
- setEnabled(String, boolean) - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- setException(LiveViewException) - Method in class com.streambase.liveview.client.DynamicTableState
-
- setExitStatusTimeoutMS(long) - Method in class com.streambase.sb.client.ClientSettings
-
ExitStatusTimeoutMS is used as a timeout for how long the client
should wait to get the client's exit status from the server.
- setField(String, Object) - Method in class com.streambase.sb.Tuple
-
Set the named field to a specified value.
- setField(String, Object, CSV.FormatInfo) - Method in class com.streambase.sb.Tuple
-
Set the field at a specified field name to a specified boxed value.
- setField(int, Object) - Method in class com.streambase.sb.Tuple
-
Set the field at a specified field index to a specified boxed value.
- setField(Schema.Field, Object) - Method in class com.streambase.sb.Tuple
-
Set a specified field to a specified boxed value.
- setField(Schema.Field, Object, CSV.FormatInfo) - Method in class com.streambase.sb.Tuple
-
Set the field at a specified field name to a specified boxed value.
- setFieldName(String) - Method in class com.streambase.liveview.client.dynamictables.Assignment
-
- setFields(Map<String, Object>) - Method in class com.streambase.sb.Tuple
-
Takes a map of field names and values as Objects and sets the corresponding tuple field with the supplied value.
- setFilter(String) - Method in class com.streambase.liveview.client.dynamictables.FilteredTableAlias
-
- setFormatter(String) - Method in class com.streambase.liveview.client.dynamictables.FilteredTableAlias
-
- setFunction(int, Function) - Method in class com.streambase.sb.Tuple
-
Set a specified function field to the given
Function
- setFunction(String, Function) - Method in class com.streambase.sb.Tuple
-
Set a specified function field to the given
Function
- setFunction(Schema.Field, Function) - Method in class com.streambase.sb.Tuple
-
Set a specified function field to the given
Function
- setGroupByExprs(String...) - Method in class com.streambase.liveview.client.QueryConfig
-
Configure group-by
- setGroupByExprs(List<String>) - Method in class com.streambase.liveview.client.QueryConfig
-
Configure group-by
- setIncludeInternal(boolean) - Method in class com.streambase.liveview.client.QueryConfig
-
set to make this query include internal fields, regardless of the state of includeInternal property
if false, use the property (which is set by the URI when connecting)
- setIndices(List<List<String>>) - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
This method is used to set the Indices for the table being configured.
- setInputStream(String) - Method in interface com.streambase.liveview.client.alert.SendTupleAction
-
Sets the value of the inputStream property.
- setInputStreams(List<String>) - Method in class com.streambase.liveview.client.serverdatautility.StreambaseStreams
-
- setInsertInitialValue(String) - Method in class com.streambase.liveview.client.dynamictables.Variable
-
- setInt(String, int) - Method in class com.streambase.sb.Tuple
-
Set the named int field to a specified value.
- setInt(int, int) - Method in class com.streambase.sb.Tuple
-
Set the int field at a specified field index to a specified value.
- setInt(Schema.Field, int) - Method in class com.streambase.sb.Tuple
-
Set a specified int field to a specified value.
- setIsValid(boolean) - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Sets the value of the status property.
- setLeadershipStatus(Constants.LeadershipStatus) - Method in class com.streambase.sb.client.StreamBaseAdminClient
-
Set the leadership status of the server.
- setLimit(int) - Method in class com.streambase.liveview.client.QueryConfig
-
- setLinkedPropertyNames(String...) - Method in class com.streambase.sb.operator.parameter.ConfigurationChooserPropertyDescriptor
-
Declare property names that are being used in the XPath expression as variables
- setList(String, List<?>) - Method in class com.streambase.sb.Tuple
-
Set a named list field to a copy of a specified value.
- setList(int, List<?>) - Method in class com.streambase.sb.Tuple
-
Set the list field at a specified field index to a copy of the specified value.
- setList(Schema.Field, List<?>) - Method in class com.streambase.sb.Tuple
-
Set a specified list field to a copy of a specified value.
- setListener(ConnectionListener) - Method in class com.streambase.liveview.client.ConnectionConfig
-
Set the connection listener
- setListener(MultiConnectionListener) - Method in class com.streambase.liveview.client.MultiConnectionConfig
-
- setLogLevel(Logger, String) - Static method in class com.streambase.sb.operator.Operator
-
Sets the log level of the given logger.
- setLogLevel(Logger, Operator.LogLevel) - Static method in class com.streambase.sb.operator.Operator
-
Sets the log level of the given logger.
- setLong(String, long) - Method in class com.streambase.sb.Tuple
-
Set a named long field to a specified value.
- setLong(int, long) - Method in class com.streambase.sb.Tuple
-
Set the long field at a specified field index to a specified value.
- setLong(Schema.Field, long) - Method in class com.streambase.sb.Tuple
-
Set a specified long field to a specified value.
- setLvUri(String) - Method in interface com.streambase.liveview.client.alert.LVPublishAlertAction
-
Sets the value of the lvUri property.
- setMaskStringDisplay(boolean) - Method in class com.streambase.sb.operator.parameter.SBPropertyDescriptor
-
- setMaskStringDisplay(boolean) - Method in class com.streambase.sb.operator.parameter.UIHints
-
Sets the mask hint, applicable to String property types.
- setMaxRandomReconnectDelaySeconds(int) - Method in class com.streambase.liveview.client.MultiConnectionConfig
-
When any connection with queries is lost, The LiveViewMultiConnection will wait a random amount of time
from 0 to this value in seconds before trying to reconnect those queries to another server.
- setMaxResultSetSize(int) - Method in class com.streambase.liveview.client.QueryConfig
-
Configure the row limit.
- setMaxTuplesInDequeueQueue(int) - Method in class com.streambase.sb.client.ClientSettings
-
The dequeue thread stores tuples to be dequeued by a client in a queue.
- setMessageTemplate(String) - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Sets the value of the messageTemplate property.
- setMessageTemplate(String) - Method in interface com.streambase.liveview.client.alert.PublishAlertAction
-
Sets the value of the messageTemplate property.
- setMultiLine(int) - Method in class com.streambase.sb.operator.parameter.SBPropertyDescriptor
-
- setName(String) - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Sets the value of the name property.
- setName(String) - Method in class com.streambase.liveview.client.dynamictables.Variable
-
- setName(String) - Method in class com.streambase.liveview.client.QueryConfig
-
- setNowImpl(NowImplementation) - Method in class com.streambase.sb.unittest.BaseTestEnvironment
-
- setNowImpl(NowImplementation) - Method in interface com.streambase.sb.unittest.SBTestEnvironment
-
Set the current implementation of now() function
- setNull(String) - Method in class com.streambase.sb.Tuple
-
Set a named field to null.
- setNull(int) - Method in class com.streambase.sb.Tuple
-
Set the field at a specified field index to null.
- setNull(Schema.Field) - Method in class com.streambase.sb.Tuple
-
Set the specified field to null
- setNumLines(int) - Method in class com.streambase.sb.operator.parameter.UIHints
-
Sets the number of lines to display this property as, applicable to String property types.
- setOpenTimeoutMS(long) - Method in class com.streambase.sb.client.ClientSettings
-
OpenTimeoutMS is used as a timeout value for opening a
binary connection between the client and server.
- setOperatorProperty(String, String, String) - Method in class com.streambase.sb.client.StreamBaseAdminClient
-
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).
- setOutputStreams(List<String>) - Method in class com.streambase.liveview.client.serverdatautility.StreambaseStreams
-
- setOwner(String) - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Sets the value of the owner property.
- setOwner(String) - Method in class com.streambase.liveview.client.QueryConfig
-
- 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.
- setPassword(String) - Method in class com.streambase.liveview.client.ConnectionConfig
-
Set the password to connect with
- setPersistedVersion(Integer) - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Sets the value of the persistedVersion property.
- setPersistenceFolder(String) - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
This method is used to set the persistent folder where this table will be persisted.
- setPersistenceRestoreDataOnStart(boolean) - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
The method sets the boolean flag which if true, recovers the data is to be restored after the table is restarted.
- setPivotAggExpr(String) - Method in class com.streambase.liveview.client.QueryConfig
-
Set the pivot aggregate expressions, 'PIVOT' clause
- setPivotField(String) - Method in class com.streambase.liveview.client.QueryConfig
-
Set the pivot 'FOR' clause
- setPivotQuery(String, String, String, String, String...) - Method in class com.streambase.liveview.client.QueryConfig
-
Configure the pivot query
- setPivotValues(String) - Method in class com.streambase.liveview.client.QueryConfig
-
Set the pivot 'VALUES' clause
- 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.
- setPredicate(String) - Method in class com.streambase.liveview.client.QueryConfig
-
Configure the predicate
- setPredicate(String, int) - Method in class com.streambase.liveview.client.QueryConfig
-
Configure the predicate
- setPrimaryIndex(String...) - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
This method is used to set the Primary Indexes from the list of fields passed to this method.
- setProposals(String...) - Method in class com.streambase.sb.operator.parameter.UIHints
-
Set string proposals that will be offered to the user when editing
an associated String property
- setQuery(String, String) - Method in class com.streambase.liveview.client.QueryConfig
-
Configure the table to query and predicate
- setQuery(List<Schema.Field>, String, String) - Method in class com.streambase.liveview.client.QueryConfig
-
Configure the table to query, the predicate and the result fields
- setQuery(List<Schema.Field>, String, String, int) - Method in class com.streambase.liveview.client.QueryConfig
-
Configure the table to query, the predicate and the result fields using a specified row limit
- setQuery(List<Schema.Field>, String, String, int, long) - Method in class com.streambase.liveview.client.QueryConfig
-
Configure the table to query, the predicate and the result fields using a specified row limit and row delay
- setQuery(Query) - Method in class com.streambase.liveview.client.SnapshotQueryListener
-
- setQueryString(String) - Method in class com.streambase.liveview.client.QueryConfig
-
Configure the query using a single string, SQL-like syntax.
- setQueryType(LiveViewQueryType) - Method in class com.streambase.liveview.client.QueryConfig
-
Configure the query type.
- setQuiescence(int) - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Sets the value of the quiescence property.
- 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.
- setQuiescentTimeoutMS(long) - Method in class com.streambase.sb.client.ClientSettings
-
QuiescentTimeoutMS is a timeout value that is used to determine how long
a client's binary) connection will wait for a heartbeat message from a
server.
- setRealQuery(Query) - Method in class com.streambase.liveview.client.QueryListenerWrapper
-
- setReconnectSleepMS(long) - Method in class com.streambase.sb.client.ClientSettings
-
How long will a client wait between reconnect attempts when in HA mode
- setRequired(boolean) - Method in class com.streambase.sb.operator.parameter.SBPropertyDescriptor
-
Set whether the property is required.
- setRetryIntervalMillis(long) - Method in class com.streambase.liveview.client.MultiConnectionConfig
-
This is the wait between retry attempts.
- setReuseTuple(boolean) - Method in class com.streambase.sb.operator.Operator
-
Allow/disallow the runtime to reuse tuples on operator input.
- setRowDeleteRule(String) - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
The rowDeleteRule to set is a gateway for row to be published.
- setRuntimeEnv(Object) - Method in class com.streambase.sb.operator.AggregateWindow
-
Called by internal streambase code to set the runtime environment
- setRuntimeParam(String, String, String) - Method in class com.streambase.sb.client.StreamBaseAdminClient
-
Set a runtime parameter on one, or all, operators.
- setSaveInProject(boolean) - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
The method is used to set the boolean value for the saveInProject flag, which is responsible for saving the tables to start even after the restart of Liveview server.
- setSbUri(String) - Method in interface com.streambase.liveview.client.alert.SendTupleAction
-
Sets the value of the sbUri property.
- setSchema(String) - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
This method is used to set the schema for the table being configured.
- setSchema(Schema) - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
This method is used to set the schema for the table being configured.
- setSchema(Schema) - Method in class com.streambase.liveview.client.QueryListenerWrapper
-
- setSelectExprs(String...) - Method in class com.streambase.liveview.client.QueryConfig
-
Configure the result fields
- setSelectExprs(List<String>) - Method in class com.streambase.liveview.client.QueryConfig
-
Configure the result fields
- setSelectFields(Schema.Field...) - Method in class com.streambase.liveview.client.QueryConfig
-
Configure the result fields
- setSelectFields(List<Schema.Field>) - Method in class com.streambase.liveview.client.QueryConfig
-
Configure the result fields
- setSeverity(int) - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Sets the value of the severity property.
- setShortDescription(String) - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
The shortDescription of the table to be set with Table Configuration.
- setShortDisplayName(String) - Method in class com.streambase.sb.operator.Operator
-
The short display name is the String displayed by Studio as the name of
this operator in the Palette view, and above the operator in the
EventFlow canvas.
- setSnapshotConcurrency(int) - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
Snapshot concurrency specifies the number of extra threads used to service the snapshot portion of queries.
- setSnapshotParallelism(int) - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
The snapshotParallelism value to set to enable data regions equal to the input value.
- setSocketKeepAlive(boolean) - Method in class com.streambase.sb.client.ClientSettings
-
Set SO_KEEPALIVE
- setStartThread(Thread) - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- setStatus(TableProviderStatus) - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- setStatusMessage(String) - Method in interface com.streambase.liveview.client.alert.AlertRule
-
Sets the value of the statusMessage property.
- setStatusMessage(String) - Method in class com.streambase.liveview.client.DynamicTableState
-
- setString(String, CharSequence) - Method in class com.streambase.sb.Tuple
-
Set a named field to a specified value.
- setString(int, CharSequence) - Method in class com.streambase.sb.Tuple
-
Set the string field at a specified field index to a specified value.
- setString(Schema.Field, CharSequence) - Method in class com.streambase.sb.Tuple
-
Set a specified string field to a specified value.
- setSubject(String) - Method in interface com.streambase.liveview.client.alert.SendEmailAction
-
Sets the value of the subject property.
- setSuspendBehavior(int) - Method in class com.streambase.sb.operator.Operator
-
Set the suspend behavior of this Operator.
- setTab(String) - Method in class com.streambase.sb.operator.parameter.UIHints
-
Sets the tab name hint.
- setTable(String) - Method in interface com.streambase.liveview.client.alert.IssueDeleteQueryAction
-
Sets the value of the table property.
- setTable(String) - Method in class com.streambase.liveview.client.QueryConfig
-
Configure the table to query
- setTableColumnNames(String...) - Method in class com.streambase.sb.operator.parameter.UIHints
-
Set column names to use for properties displayed in a user interface Table
- setTableDeleteRule(String) - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
Deprecated.
- setTableDeleteRules(List<String>) - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
The tableDeleteRule to set specifies a condition when the rows present in this table are to be deleted.
- setTableName(String) - Method in interface com.streambase.liveview.client.alert.LVPublishAlertAction
-
Sets the value of the tableName property.
- setTablename(String) - Method in interface com.streambase.liveview.client.dynamictables.TableConfig
-
This method is used to set the name of the table to this Table Configuration
- setTableStatus(Table.TableStatus) - Method in class com.streambase.liveview.client.DynamicTableState
-
- setTcpNoDelay(boolean) - Method in class com.streambase.sb.client.ClientSettings
-
Set TCP_NODELAY
- setTest(String) - Method in class com.streambase.liveview.client.dynamictables.RuleCase
-
- setTextWidth(UIHints.TextWidthHint) - Method in class com.streambase.sb.operator.parameter.UIHints
-
Set the desired width hint for text-field-like controls
- setTimeForTableStartDrop(Long) - Method in class com.streambase.liveview.client.DynamicTableState
-
- setTimeout(int) - Method in class com.streambase.liveview.client.LiveResult
-
setTimeout limits the amount of time to wait for the snapshot to complete.
- setTimeout(long, TimeUnit) - Method in class com.streambase.sb.unittest.Expecter
-
Set the timeout that the expector should assume for each call to expect*()
- setTimeoutMillis(long) - Method in class com.streambase.liveview.client.MultiConnectionConfig
-
The amount of time to consider a connection attempt failed.
- setTimePredicateInMillis(long) - Method in class com.streambase.liveview.client.QueryConfig
-
Set the time predicate.
- setTimeService(TimeService) - Method in interface com.streambase.sb.unittest.SBServerManager
-
Set a TimeService for the StreamBase Server managed by this Manager.
- setTimestamp(String, Timestamp) - Method in class com.streambase.sb.Tuple
-
Set a named timestamp field to a specified value.
- setTimestamp(int, Timestamp) - Method in class com.streambase.sb.Tuple
-
Set the timestamp field at a specified field index to a specified value.
- setTimestamp(Schema.Field, Timestamp) - Method in class com.streambase.sb.Tuple
-
Set a named timestamp field to a specified value.
- setTimeWindow(String, String, String) - Method in class com.streambase.liveview.client.QueryConfig
-
Configures this query as a time-windowed query, using the given start and end time
expressions, against the given timestamp field from the target table.
- setTopN(OrderDefinition, int) - Method in class com.streambase.liveview.client.QueryConfig
-
Return only the top N results according to the order definition.
- setTuple(String, Tuple) - Method in class com.streambase.sb.Tuple
-
Set a named nested tuple field to a specified tuple.
- setTuple(int, Tuple) - Method in class com.streambase.sb.Tuple
-
Set a specified nested tuple field to that of the specified tuple.
- setTuple(Schema.Field, Tuple) - Method in class com.streambase.sb.Tuple
-
Set a specified nested tuple field to that of the specified tuple
NOTE: A copy of the the tuple may be made to convert the given tuple to the appropriate
internal representation.
- setTuple(Tuple, Object, boolean) - Static method in class com.streambase.sb.TupleJSONUtil
-
Set the fields of a tuple based on the contents of a JSON object
- setTuple(Tuple, Object, boolean, String) - Static method in class com.streambase.sb.TupleJSONUtil
-
Set the fields of a tuple based on the contents of a JSON object
- setTuple(Tuple, Object, boolean, String, boolean) - Static method in class com.streambase.sb.TupleJSONUtil
-
Set the fields of a tuple based on the contents of a JSON object
- setTupleFromJSON(Tuple, String) - Static method in class com.streambase.sb.TupleJSONUtil
-
Set the fields of a tuple based on the contents of a JSON string
- setTupleFromJSON(Tuple, String, String) - Static method in class com.streambase.sb.TupleJSONUtil
-
Set the fields of a tuple based on the contents of a JSON string
- setTupleFromJSON(Tuple, String, String, boolean) - Static method in class com.streambase.sb.TupleJSONUtil
-
Set the fields of a tuple based on the contents of a JSON string
- setTupleFromJSONLoose(Tuple, String) - Static method in class com.streambase.sb.TupleJSONUtil
-
Set the fields of a tuple based on the contents of a JSON string.
- setTupleFromJSONLoose(Tuple, String, String) - Static method in class com.streambase.sb.TupleJSONUtil
-
Set the fields of a tuple based on the contents of a JSON string.
- setTupleFromJSONLoose(Tuple, String, String, boolean) - Static method in class com.streambase.sb.TupleJSONUtil
-
Set the fields of a tuple based on the contents of a JSON string.
- setType(DataType) - Method in class com.streambase.liveview.client.dynamictables.Variable
-
- setUIHints(UIHints) - Method in class com.streambase.sb.operator.parameter.SBPropertyDescriptor
-
Associate a
UIHints object with this property, providing
StreamBase Studio with additional layout and display information for this
property.
- setUpdateInitialValue(String) - Method in class com.streambase.liveview.client.dynamictables.Variable
-
- setUri(String) - Method in class com.streambase.liveview.client.ConnectionConfig
-
Set the uri to connect with.
- setUsername(String) - Method in class com.streambase.liveview.client.ConnectionConfig
-
Set the username to connect with
- setValue(String) - Method in class com.streambase.liveview.client.dynamictables.Assignment
-
- setValues(String[]) - Method in class com.streambase.sb.operator.parameter.EnumPropertyDescriptor
-
Set the list of allowable values for the property.
- setVariableName(String) - Method in class com.streambase.liveview.client.dynamictables.Assignment
-
- setWriteTimeoutMS(long) - Method in class com.streambase.sb.client.ClientSettings
-
WriteTimeoutMS is used as a timeout for write operations
in a binary connection between the client and server.
- setXmlRpcTimeoutMS(long) - Method in class com.streambase.sb.client.ClientSettings
-
XmlrpcTimeoutMS is used as a timeout for XMLRPC requests to the
server.
- SHORT_DESCRIPTION_FIELD - Static variable in interface com.streambase.liveview.client.Table
-
- shouldRun() - Method in class com.streambase.sb.operator.Operator.OperatorThread
-
Implement state request responses of this operator thread.
- 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 interface com.streambase.liveview.server.table.plugin.TableProvider
-
When this is called, you should close threads and do whatever else is necessary to clean up.
- shutdown() - Method in class com.streambase.liveview.server.table.plugin.TableProviderManager
-
- shutdown() - Method in class com.streambase.liveview.server.table.plugin.TestTableProvider
-
- 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 - 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.
- shutdownObject() - Method in interface com.streambase.sb.operator.Operator.SharedObject
-
Shutdown the SharedObject.
- shutdownOperators(List<String>) - Method in class com.streambase.sb.client.StreamBaseAdminClient
-
Shut down the given Operators on the StreamBase server.
- shutdownServer() - Method in interface com.streambase.sb.unittest.SBServerManager
-
Shutdown the server, blocking until the server is finished shutting down
- shutMeDown() - Method in interface com.streambase.liveview.server.table.plugin.TableProviderControl
-
Shut down the associated TableProvider.
- shutMeDown() - Method in class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- SIMPLE_TYPES - Static variable in enum com.streambase.sb.DataType
-
The types that have no parameterization, just values.
- SimpleDequeueResult - Class in com.streambase.sb.client
-
A simple concrete implementation of DequeueResult, primarily intended for use by implementors of
DequeueResult.Interceptor to allow them to construct an alternative DequeueResult.
- SimpleDequeueResult(List<Tuple>, StreamProperties, StreamBaseURI, Constants.LeadershipStatus) - Constructor for class com.streambase.sb.client.SimpleDequeueResult
-
- SingleValueSetter() - Constructor for class com.streambase.sb.operator.parameter.SBPropertyDescriptor.SingleValueSetter
-
- size() - Method in class com.streambase.liveview.client.LiveResult
-
The size of the result
- size() - Method in class com.streambase.sb.operator.Operator
-
Return the "size" of this operator.
- size(boolean) - Method in interface com.streambase.sb.operator.TableAccessor
-
Return the number of rows in the table
- 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
- SM_DEFINED - Static variable in interface com.streambase.liveview.client.Table
-
- SM_DISCOVERD_AT_START - Static variable in interface com.streambase.liveview.client.Table
-
- SM_DYANAMICALLY_ADDED - Static variable in interface com.streambase.liveview.client.Table
-
- SM_FILTERED_TABLE_DISCOVERED_AT_START_TIME - Static variable in interface com.streambase.liveview.client.Table
-
- SM_FILTERED_TABLE_DYNAMICALLY_ADDED - Static variable in interface com.streambase.liveview.client.Table
-
- SM_FILTERED_TABLE_ERROR_PREDICATE_VALIDATION - Static variable in interface com.streambase.liveview.client.Table
-
- SM_LOADING - Static variable in interface com.streambase.liveview.client.Table
-
- SM_REMOVING - Static variable in interface com.streambase.liveview.client.Table
-
- smoothFailover(LiveViewConnectionControl, LiveViewConnectionControl) - Method in class com.streambase.liveview.client.MultiConnectionListener.MultiConnectionListenerBase
-
- smoothFailover(LiveViewConnectionControl, LiveViewConnectionControl) - Method in interface com.streambase.liveview.client.MultiConnectionListener
-
This will be called if the current server has failed, but there is already another server ready to fail over to.
- snapshot(List<TupleAddedEvent>, boolean) - Method in class com.streambase.liveview.client.AbstractBatchedQueryListener
-
This batch method is called one or more times for snapshot results.
- Snapshot - Class in com.streambase.sb.monitor
-
Stores a snapshot of information from a StreamBase application.
- Snapshot(StreamBaseMonitor, boolean) - Constructor for class com.streambase.sb.monitor.Snapshot
-
- Snapshot.Source - Interface in com.streambase.sb.monitor
-
- Snapshot.Status - Enum in com.streambase.sb.monitor
-
- snapshotBegin(BeginSnapshotEvent) - Method in class com.streambase.liveview.client.AbstractBatchedQueryListener
-
Event to indicate the start of the result snapshot.
- snapshotBegin(BeginSnapshotEvent) - Method in class com.streambase.liveview.client.AbstractQueryListener
-
Event to indicate the start of the result snapshot.
- snapshotBegin(BeginSnapshotEvent) - Method in class com.streambase.liveview.client.CompositeQueryListener
-
Event to indicate the start of the result snapshot.
- snapshotBegin(BeginSnapshotEvent) - Method in class com.streambase.liveview.client.DeleteQueryListener
-
- snapshotBegin(BeginSnapshotEvent) - Method in class com.streambase.liveview.client.LiveResult
-
Event to indicate the start of the result snapshot.
- snapshotBegin(BeginSnapshotEvent) - Method in interface com.streambase.liveview.client.QueryListener
-
Event to indicate the start of the result snapshot.
- snapshotBegin(BeginSnapshotEvent) - Method in class com.streambase.liveview.client.QueryListenerWrapper
-
- snapshotBegin(BeginSnapshotEvent) - Method in class com.streambase.liveview.client.SnapshotQueryListener
-
Event to indicate the start of the result snapshot.
- snapshotEnd(EndSnapshotEvent) - Method in class com.streambase.liveview.client.AbstractBatchedQueryListener
-
Event to indicate the query snapshot is complete.
- snapshotEnd(EndSnapshotEvent) - Method in class com.streambase.liveview.client.AbstractQueryListener
-
Event to indicate the query snapshot is complete.
- snapshotEnd(EndSnapshotEvent) - Method in class com.streambase.liveview.client.CompositeQueryListener
-
Event to indicate the query snapshot is complete.
- snapshotEnd(EndSnapshotEvent) - Method in class com.streambase.liveview.client.DeleteQueryListener
-
- snapshotEnd(EndSnapshotEvent) - Method in class com.streambase.liveview.client.LiveResult
-
Event to indicate the query snapshot is complete.
- snapshotEnd(EndSnapshotEvent) - Method in interface com.streambase.liveview.client.QueryListener
-
Event to indicate the query snapshot is complete.
- snapshotEnd(EndSnapshotEvent) - Method in class com.streambase.liveview.client.QueryListenerWrapper
-
- snapshotEnd(EndSnapshotEvent) - Method in class com.streambase.liveview.client.SnapshotQueryListener
-
Event to indicate the query snapshot is complete.
- SnapshotQueryListener - Class in com.streambase.liveview.client
-
A Convenience implementation of
QueryListener that provides a pull based iterator pattern for iterating over snapshot queries.
- SnapshotQueryListener() - Constructor for class com.streambase.liveview.client.SnapshotQueryListener
-
- SnapshotQueryListener(int) - Constructor for class com.streambase.liveview.client.SnapshotQueryListener
-
- snapshotReceived(Snapshot) - Method in interface com.streambase.sb.monitor.MonitorListener
-
Called by a StreamBaseMonitor object when it has received a Snapshot.
- SnapshotResult - Interface in com.streambase.liveview.client
-
A blocking iterator pattern for retrieving
snapshot only results.
- SqlTypecheckException - Exception in com.streambase.sb.operator
-
- SqlTypecheckException(String, Throwable) - Constructor for exception com.streambase.sb.operator.SqlTypecheckException
-
- start() - Method in interface com.streambase.liveview.server.table.plugin.TableProvider
-
You should connect to your server successfully before returning from this call.
- start() - Method in class com.streambase.liveview.server.table.plugin.TestTableProvider
-
- startContainers() - Method in interface com.streambase.sb.unittest.SBServerManager
-
Start all the containers for this server.
- startContainers(Set<String>) - Method in interface com.streambase.sb.unittest.SBServerManager
-
Start all but the specified containers for this server.
- startContainers(Set<String>, boolean) - Method in interface com.streambase.sb.unittest.SBServerManager
-
Start all but the specified containers for this server
- STARTED - Static variable in class com.streambase.sb.operator.Operator.OperatorStates
-
The Operator has been started; resume() has been called.
- startObject() - Method in interface com.streambase.sb.operator.Operator.SharedObject
-
Start the SharedObject.
- startServer() - Method in interface com.streambase.sb.unittest.SBServerManager
-
Start the server, blocking until the server will accept connections
- startTables(String...) - Method in interface com.streambase.liveview.client.TableAdminManager
-
This will start all the tables in the list AND any applications or elements upon which they depend.
- startTables(long, TimeUnit, String...) - Method in interface com.streambase.liveview.client.TableAdminManager
-
Returns a Map
, where the key is tableName and the value is DynamicTableState
DynamicTableState.
- startTables(List<String>) - Method in class com.streambase.liveview.server.table.plugin.TableProviderManager
-
- STAT_SCHEMA - Static variable in interface com.streambase.sb.Constants
-
- STAT_SCHEMA - Static variable in class com.streambase.sb.monitor.StreamBaseMonitor
-
The stats schema.
- STAT_SCHEMA_V3 - Static variable in interface com.streambase.sb.Constants
-
- STAT_SCHEMA_V3 - Static variable in class com.streambase.sb.monitor.StreamBaseMonitor
-
The v3 stats schema.
- STAT_STREAM_NAME - Static variable in interface com.streambase.sb.Constants
-
- STAT_STREAM_NAME_V3 - Static variable in interface com.streambase.sb.Constants
-
- stateChanged(ConnectionStatus, StreamBaseClient, String) - Method in interface com.streambase.sb.client.ConnectionStatusCallback
-
Called when the connection state changes
- StatEncoder(StatsUtil.What, KeyRegistry) - Constructor for class com.streambase.sb.monitor.StatsUtil.StatEncoder
-
- StatsUtil.IdentityHelper - Class in com.streambase.sb.monitor
-
This class manages the identity in client
- StatsUtil.IdentityHelper.IdentityUpdater - Interface in com.streambase.sb.monitor
-
- StatsUtil.IdentityManager - Class in com.streambase.sb.monitor
-
This class manages the identity in server
- StatsUtil.StatEncoder - Class in com.streambase.sb.monitor
-
- StatsUtil.StatEncoder.KeyType - Enum in com.streambase.sb.monitor
-
- StatsUtil.What - Enum in com.streambase.sb.monitor
-
- statTuples - Variable in class com.streambase.sb.monitor.Snapshot
-
- STATUS - Static variable in interface com.streambase.sb.client.XmlRpcAdmin.ListConnectionTags
-
- STATUS_FIELD - Static variable in interface com.streambase.liveview.client.Table
-
- STATUS_MESSAGE_FIELD - Static variable in interface com.streambase.liveview.client.Table
-
- stopContainers() - Method in interface com.streambase.sb.unittest.SBServerManager
-
Stop all containers in this server
- stopNewSessions(boolean) - Method in interface com.streambase.liveview.client.clientcontrol.ClientController
-
Stops accepting new sessions
- STREAM - Static variable in class com.streambase.sb.EntityType
-
Represents a StreamBase stream.
- STREAM_PARAM - Static variable in class com.streambase.sb.client.StreamBaseURI
-
URI parameter used internally (only) as part of container stream connection logic
- StreamBaseAdminClient - Class in com.streambase.sb.client
-
This class is used to send administrative commands to the StreamBase Server
- 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.
- StreamBaseAdminClient(String) - Constructor for class com.streambase.sb.client.StreamBaseAdminClient
-
Create a StreamBaseAdminClient.
- StreamBaseAdminClient(List<StreamBaseURI>) - Constructor for class com.streambase.sb.client.StreamBaseAdminClient
-
Create a StreamBaseAdminClient.
- StreamBaseAdminClient(List<StreamBaseURI>, ClientSettings) - Constructor for class com.streambase.sb.client.StreamBaseAdminClient
-
Create a StreamBaseAdminClient.
- StreamBaseAdminClient.ListConnectionArgument - Enum in com.streambase.sb.client
-
Valid arguments for the listConnection command
- 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 from one or more comma-separated URI strings
- StreamBaseClient() - Constructor for class com.streambase.sb.client.StreamBaseClient
-
Create a StreamBaseClient.
- StreamBaseClient(StreamBaseURI) - Constructor for class com.streambase.sb.client.StreamBaseClient
-
Create a StreamBaseClient, connecting to the server at the provided URI
- StreamBaseClient(List<StreamBaseURI>) - Constructor for class com.streambase.sb.client.StreamBaseClient
-
Create a StreamBaseClient, connecting to the servers at the provided URIs.
- StreamBaseClient(List<StreamBaseURI>, ClientSettings) - Constructor for class com.streambase.sb.client.StreamBaseClient
-
Create a StreamBaseClient, connecting to the servers at the provided URIs.
- StreamBaseClient.ListEntityFlags - Interface in com.streambase.sb.client
-
Flags used by the ListEntities call.
- StreamBaseClient.SerializedTupleBuffer - Class in com.streambase.sb.client
-
A TupleBuffer which contains a byte buffer of serialized tuples
including space for a network header
- StreamBaseClient.TupleBuffer - Class in com.streambase.sb.client
-
Class for abstracting away where tuples come from, Buffers, Collections, and 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
-
- StreamBaseException(LocatedItem, String) - Constructor for exception com.streambase.sb.StreamBaseException
-
- StreamBaseException(LocatedItem, String, Throwable) - Constructor for exception com.streambase.sb.StreamBaseException
-
- StreamBaseException(LocatedItem, Throwable) - Constructor for exception com.streambase.sb.StreamBaseException
-
- StreamBaseIllegalArgumentException - Exception in com.streambase.sb
-
A StreamBase wrapper for IllegalArgumentException for use by methods that want
to throw IAE in a kind of cleaner fashion.
- StreamBaseIllegalArgumentException(StreamBaseException) - Constructor for exception com.streambase.sb.StreamBaseIllegalArgumentException
-
- StreamBaseIllegalArgumentException(String) - Constructor for exception com.streambase.sb.StreamBaseIllegalArgumentException
-
- StreamBaseListException - Exception in com.streambase.sb
-
An exception that contains a list of exceptions
- StreamBaseListException(String) - Constructor for exception com.streambase.sb.StreamBaseListException
-
StreamBaseListException with given message, no location info
- StreamBaseListException(Throwable) - Constructor for exception com.streambase.sb.StreamBaseListException
-
StreamBaseListException with given cause.
- StreamBaseListException(String, Throwable) - Constructor for exception com.streambase.sb.StreamBaseListException
-
StreamBaseListException with given message.
- StreamBaseListException(String, LocatedItem, Throwable) - Constructor for exception com.streambase.sb.StreamBaseListException
-
StreamBaseListException with given message.
- StreamBaseListException(String, LocatedItem) - Constructor for exception com.streambase.sb.StreamBaseListException
-
StreamBaseListException with given message.
- StreamBaseListException(String, List<T>) - Constructor for exception com.streambase.sb.StreamBaseListException
-
StreamBaseListException with given message.
- StreamBaseListException(String, T...) - Constructor for exception com.streambase.sb.StreamBaseListException
-
StreamBaseListException with given message.
- 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.
- StreamBaseMonitor(StreamBaseClient) - Constructor for class com.streambase.sb.monitor.StreamBaseMonitor
-
Create a monitoring object, which will connect to a server with the given
StreamBaseClient object.
- StreamBaseMonitor(String) - Constructor for class com.streambase.sb.monitor.StreamBaseMonitor
-
Create a monitoring object
The given uri can either be a StreamBaseURI or a filename.
- StreamBaseMonitor(StreamBaseClient, String) - Constructor for class com.streambase.sb.monitor.StreamBaseMonitor
-
- 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
-
- StreambaseStreams - Class in com.streambase.liveview.client.serverdatautility
-
Data holder for a list of input streams and a list of output streams.
- StreambaseStreams(List<String>, List<String>) - Constructor for class com.streambase.liveview.client.serverdatautility.StreambaseStreams
-
- StreambaseStreams() - Constructor for class com.streambase.liveview.client.serverdatautility.StreambaseStreams
-
- 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<String, String>) - 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<String, String>) - Constructor for class com.streambase.sb.client.StreamBaseURI
-
Equivalent to StreamBaseURI(host, container, port, false, params)
- StreamBaseURI(String, int, Map<String, String>) - Constructor for class com.streambase.sb.client.StreamBaseURI
-
Equivalent to StreamBaseURI(host, NO_CONTAINER, port, params)
- StreamInfo - Class in com.streambase.sb.monitor
-
Represents information about a stream in a StreamBase Server.
- streamInfos - Variable in class com.streambase.sb.monitor.Snapshot
-
- streamInfos() - Method in class com.streambase.sb.monitor.Snapshot
-
Returns an iterator over all the StreamInfo objects.
- streamNames() - Method in class com.streambase.sb.monitor.Snapshot
-
Returns the set of all stream names.
- 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_TRUNCATED - Static variable in interface com.streambase.sb.Tuple.SetResult
-
was the string truncated when set?
- subscribe(String, String, String, DeMUXStreamBaseClient.DequeueListener) - Method in class com.streambase.sb.client.DeMUXStreamBaseClient
-
This is the only subscribe operation that is supported by the DeMUXStreamBaseClient
- subscribe(String) - Method in class com.streambase.sb.client.DeMUXStreamBaseClient
-
- subscribe(String, CaptureTransformStrategy) - Method in class com.streambase.sb.client.DeMUXStreamBaseClient
-
- subscribe(StreamProperties) - Method in class com.streambase.sb.client.DeMUXStreamBaseClient
-
- subscribe(String, String, String) - Method in class com.streambase.sb.client.DeMUXStreamBaseClient
-
- subscribe(String, CaptureTransformStrategy, String, String) - Method in class com.streambase.sb.client.DeMUXStreamBaseClient
-
- subscribe(StreamProperties, String, String) - Method in class com.streambase.sb.client.DeMUXStreamBaseClient
-
- subscribe(String) - Method in class com.streambase.sb.client.StreamBaseClient
-
Subscribe to a stream
- subscribe(String, CaptureTransformStrategy) - 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(String, CaptureTransformStrategy, 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(String) - Method in interface com.streambase.sb.unittest.SBServerManager
-
Subscribes to a stream.
- subscribeAll() - Method in interface com.streambase.sb.unittest.SBServerManager
-
Subscribes to all streams
- SUBSCRIPTIONS - Static variable in interface com.streambase.sb.client.XmlRpcAdmin.ListConnectionTags
-
- SUBSCRIPTIONS_SCHEMA - Static variable in interface com.streambase.sb.Constants
-
- SUBSCRIPTIONS_STREAM_NAME - Static variable in interface com.streambase.sb.Constants
-
- subTask(String) - Method in class com.streambase.liveview.client.NullProgressMonitor
-
This implementation does nothing.
- subTask(String) - Method in interface com.streambase.liveview.client.ProgressMonitor
-
The server calls this with the name of sub tasks
- suspend(String) - Method in class com.streambase.sb.client.StreamBaseAdminClient
-
Suspend (pause) a container or operator within a StreamBase Server
- suspend() - Method in class com.streambase.sb.operator.Operator
-
suspend() will be called when an operator suspends, before any registered
runnables are suspended.
- 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.
- suspendObject() - Method in interface com.streambase.sb.operator.Operator.SharedObject
-
Suspend the SharedObject.
- suspendOperators(List<String>) - Method in class com.streambase.sb.client.StreamBaseAdminClient
-
Suspend (pause) the given Operators on the StreamBase Server
- SYS_TABLES_GROUP - Static variable in interface com.streambase.liveview.client.Table
-
- sysInfo - Variable in class com.streambase.sb.monitor.Snapshot
-
- SYSTEM_CONTAINER - Static variable in class com.streambase.sb.client.StreamBaseURI
-
The system container ("system")
- SYSTEM_CONTAINER_NAME - Static variable in interface com.streambase.sb.Constants
-
- SYSTEM_PREFIX - Static variable in interface com.streambase.sb.Constants
-
- SystemInfo - Class in com.streambase.sb.monitor
-
Represents system-level information.
- SystemInfo() - Constructor for class com.streambase.sb.monitor.SystemInfo
-
- SystemInfo.GCInfo - Class in com.streambase.sb.monitor
-
Information about GC collectors in the JVM
- tab - Variable in class com.streambase.sb.operator.parameter.UIHints
-
Name to give the tab in which the associated property will be created in, when
displayed in the Properties View of StreamBase Studio.
- Table - Interface in com.streambase.liveview.client
-
An instance of a LiveView table.
- TABLE - Static variable in class com.streambase.sb.EntityType
-
Represents a StreamBase query table.
- Table.TableGroup - Enum in com.streambase.liveview.client
-
ENUM for table groups.
- Table.TableStatus - Enum in com.streambase.liveview.client
-
- TABLE_CONCRETE - Static variable in class com.streambase.sb.EntityType
-
Represents StreamBase query tables that are not references, or placeholders.
- TABLE_SCHEMA_FIELD - Static variable in interface com.streambase.liveview.client.Table
-
- TABLE_SPACE_FIELD - Static variable in interface com.streambase.liveview.client.Table
-
- TableAccessor - Interface in com.streambase.sb.operator
-
A handle for accessing a table.
- TableAdminManager - Interface in com.streambase.liveview.client
-
TableAdminManager is used to start and stop tables and table providers on the server.
- TableAdminManager.TableProviderAPIHelper - Class in com.streambase.liveview.client
-
Utility methods for working with the TableProviderAPI
- tableColumnNames - Variable in class com.streambase.sb.operator.parameter.UIHints
-
Set a hint for the associated table property to be displayed with the following
column names.
- TableConfig - Interface in com.streambase.liveview.client.dynamictables
-
TableConfig is used to configure all properties of the table under construction.
- TableListListener - Interface in com.streambase.liveview.client
-
Create an instance of this if you want to be informed of changes to the Table List.
- TableNameMapper - Interface in com.streambase.liveview.server.table.plugin
-
This class contains the table name selector and remapping information that was declared in the LVConf or the Service Call
- TablePropertiesConfigurationWrapper - Class in com.streambase.liveview.server.table.plugin
-
- TablePropertiesConfigurationWrapper(String) - Constructor for class com.streambase.liveview.server.table.plugin.TablePropertiesConfigurationWrapper
-
The constructor accepts the re-mapped name for the table corresponding to the original table name.
- TablePropertiesConfigurationWrapper.FilterdAlias - Class in com.streambase.liveview.server.table.plugin
-
FilteredAlias is used as a place holder for the formatter used to format table name and predicate filter.
- TableProvider - Interface in com.streambase.liveview.server.table.plugin
-
Implement this interface to add a custom TableProvider to LiveView.
- TableProviderAPIHelper() - Constructor for class com.streambase.liveview.client.LiveViewConnection.TableProviderAPIHelper
-
Deprecated.
- TableProviderAPIHelper() - Constructor for class com.streambase.liveview.client.TableAdminManager.TableProviderAPIHelper
-
- TableProviderControl - Interface in com.streambase.liveview.server.table.plugin
-
When implementing a TableProvider, you should hold on to the TableProviderControl that is passed to you
in your initialize method.
- TableProviderControlImpl - Class in com.streambase.liveview.server.table.plugin
-
- TableProviderControlImpl(String, TableProvider, TableProviderManager, ExternalServerConnectionType, int) - Constructor for class com.streambase.liveview.server.table.plugin.TableProviderControlImpl
-
- TableProviderManager - Class in com.streambase.liveview.server.table.plugin
-
- tableProviderMap - Variable in class com.streambase.liveview.server.table.plugin.TableProviderManager
-
- TableProviderParameters - Interface in com.streambase.liveview.server.table.plugin
-
This contains the arguments that were passed to your Table in the LVConf or the Web Service
- TableProviderStatus - Enum in com.streambase.liveview.server.table.plugin
-
Constants representing different status of a TableProvider.
- TablePublisher - Interface in com.streambase.liveview.client
-
An instance of a publisher for publishing tuples into a table.
- TABLES_TABLE_NAME - Static variable in interface com.streambase.liveview.client.Table
-
A special group used to identify system tables in LiveView.
- 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.
- TestTableProvider - Class in com.streambase.liveview.server.table.plugin
-
This is just for testing the addition and removal of Tables.
- TestTableProvider() - Constructor for class com.streambase.liveview.server.table.plugin.TestTableProvider
-
- TestTableProvider.UnsupportedTable - Class in com.streambase.liveview.server.table.plugin
-
- textWidthHint - Variable in class com.streambase.sb.operator.parameter.UIHints
-
Set a hint for text-field like properties to have a relative width.
- 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.
- thrInfos - Variable in class com.streambase.sb.monitor.Snapshot
-
- THROW_ON_NULL - Static variable in class com.streambase.sb.Tuple
-
during a get throw an exception on null
- throwable - Variable in class com.streambase.sb.client.DequeueResult
-
- TICKS_PER_MICROSECOND - Static variable in class com.streambase.sb.monitor.Snapshot
-
- TICKS_PER_MILLISECOND - Static variable in class com.streambase.sb.monitor.Snapshot
-
- TIMEOUT - Static variable in class com.streambase.sb.client.DequeueResult
-
Status code indicating a timeout during dequeue
- TimeService - Interface in com.streambase.sb
-
This interface defines a contract that enables users to provide custom implementations of time used by StreamBase server
It must be implemented by all Time Service classes.
- TimeServiceFactory - Class in com.streambase.sb.unittest
-
Contains static methods for creating concrete
TimeService
- TimeServiceFactory() - Constructor for class com.streambase.sb.unittest.TimeServiceFactory
-
- 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.
- 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
-
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
- toHumanString(SchemaUtil.SchemaProvider) - Method in class com.streambase.sb.CompleteDataType.CaptureType
-
- toHumanString(SchemaUtil.SchemaProvider) - Method in class com.streambase.sb.CompleteDataType.FunctionType
-
- toHumanString(SchemaUtil.SchemaProvider) - Method in class com.streambase.sb.CompleteDataType.ListType
-
- toHumanString() - Method in class com.streambase.sb.CompleteDataType
-
Return a String describing the type suitable for error messages.
- toHumanString(SchemaUtil.SchemaProvider) - Method in class com.streambase.sb.CompleteDataType
-
Return a String describing the type suitable for error messages.
- toHumanString(SchemaUtil.SchemaProvider) - Method in class com.streambase.sb.CompleteDataType.TupleType
-
- toHumanString() - Method in class com.streambase.sb.Schema
-
Return a description of the Schema in using a SSQL style format
- toHumanString() - Method in class com.streambase.sb.StreamProperties
-
- toInt() - Method in enum com.streambase.sb.Constants.ContainerState
-
get the integer value of this status
- toInt() - Method in enum com.streambase.sb.Constants.LeadershipStatus
-
Convert the leadership status to integer
- toJSONListString(Tuple, String) - Static method in class com.streambase.sb.TupleJSONUtil
-
Return the JSON string representation of the supplied tuple.
- toJSONListString(Tuple) - Static method in class com.streambase.sb.TupleJSONUtil
-
Return the JSON string representation of the supplied tuple.
- toJSONMapString(Tuple, String) - Static method in class com.streambase.sb.TupleJSONUtil
-
Return the JSON string representation of the supplied tuple.
- toJSONMapString(Tuple) - Static method in class com.streambase.sb.TupleJSONUtil
-
Return the JSON string representation of the supplied tuple.
- toJSONMapStringSingleQuote(Tuple) - Static method in class com.streambase.sb.TupleJSONUtil
-
Return the single quote JSON string representation of the supplied tuple.
- toJSONString(Tuple, EnumSet<TupleJSONUtil.Options>) - Static method in class com.streambase.sb.TupleJSONUtil
-
Convert a tuple to its JSON representation.
- toJSONString(Tuple, EnumSet<TupleJSONUtil.Options>, String) - Static method in class com.streambase.sb.TupleJSONUtil
-
Convert a tuple to its JSON representation.
- toJSONString(Collection<Tuple>) - Static method in class com.streambase.sb.TupleJSONUtil
-
- toMapView() - Method in class com.streambase.sb.Tuple
-
Returns a view on this Tuple that implements the Map<String, Object> interface.
- 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
- toSsqlStyleString() - Method in class com.streambase.sb.Schema
-
Deprecated.
- toString() - Method in enum com.streambase.liveview.client.alert.AlertRule.Type
-
- toString() - Method in class com.streambase.liveview.client.DynamicTableState
-
- toString() - Method in enum com.streambase.liveview.client.LiveViewClientCapability
-
- toString() - Method in enum com.streambase.liveview.client.LiveViewPermission.Action
-
- toString() - Method in class com.streambase.liveview.client.LiveViewPermission
-
- toString() - Method in enum com.streambase.liveview.client.LiveViewPermission.Type
-
- toString() - Method in enum com.streambase.liveview.client.LiveViewTableCapability
-
- toString() - Method in enum com.streambase.liveview.client.OrderDefinition.Direction
-
- toString() - Method in class com.streambase.liveview.client.OrderDefinition
-
Produce a human readable representation of the OrderDefinition
- toString() - Method in class com.streambase.liveview.client.serverdatautility.StreambaseStreams
-
- toString() - Method in class com.streambase.liveview.server.table.plugin.TablePropertiesConfigurationWrapper.FilterdAlias
-
- toString() - Method in class com.streambase.sb.ByteArrayView
-
Formats a ByteArrayView by printing out every byte as a char.
- toString(Collection<StreamBaseURI>) - Static method in class com.streambase.sb.client.StreamBaseURI
-
Create a string representation of a list of uris.
- toString() - Method in class com.streambase.sb.client.StreamBaseURI
-
Returns a string representation of the URI.
- toString() - Method in class com.streambase.sb.CompleteDataType
-
- toString() - Method in enum 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.StreamInfo
-
Returns a string representation of the StreamInfo object.
- toString() - Method in class com.streambase.sb.monitor.ThreadInfo
-
Returns a string representation of the ThreadInfo object.
- toString() - Method in enum com.streambase.sb.operator.parameter.JavaTypePropertyDescriptor.TypeChoice
-
- 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(boolean) - Method in class com.streambase.sb.Tuple
-
Return a string representation of this Tuple.
- 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.
- toStringWithFields() - Method in class com.streambase.sb.Schema
-
Deprecated.
- traverseOrderDefinition(OrderDefinition.OrderDefinitionVisitor) - Method in class com.streambase.liveview.client.OrderDefinition
-
- truncate() - Method in interface com.streambase.sb.operator.TableAccessor
-
Truncate the table, by removing all rows
- tuple - Variable in class com.streambase.liveview.client.AbstractTupleEvent
-
- tuple - Variable in class com.streambase.liveview.client.HashableTuple
-
- Tuple - Class in com.streambase.sb
-
An class that represents a Tuple of StreamBase data.
- Tuple.DefaultTupleFormatter - Class in com.streambase.sb
-
A default formatter that converts each type to String using Java
default String conversions.
- Tuple.SetResult - Interface in com.streambase.sb
-
An interface containing flags returned from certain setXXXX calls
- Tuple.TupleFormatter - Interface in com.streambase.sb
-
This interface is not public API, and should not be implemented by users.
- tupleAdded(TupleAddedEvent) - Method in class com.streambase.liveview.client.AbstractBatchedQueryListener
-
Event when a new tuple is added to the result.
- tupleAdded(TupleAddedEvent) - Method in class com.streambase.liveview.client.AbstractQueryListener
-
Event when a new tuple is added to the result.
- tupleAdded(TupleAddedEvent) - Method in class com.streambase.liveview.client.CompositeQueryListener
-
Event when a new tuple is added to the result.
- tupleAdded(TupleAddedEvent) - Method in class com.streambase.liveview.client.DeleteQueryListener
-
Event when a new tuple is added to the result.
- tupleAdded(TupleAddedEvent) - Method in class com.streambase.liveview.client.LiveResult
-
Event when a new tuple is added to the result.
- tupleAdded(TupleAddedEvent) - Method in interface com.streambase.liveview.client.QueryListener
-
Event when a new tuple is added to the result.
- tupleAdded(TupleAddedEvent) - Method in class com.streambase.liveview.client.QueryListenerWrapper
-
- tupleAdded(TupleAddedEvent) - Method in class com.streambase.liveview.client.SnapshotQueryListener
-
Event when a new tuple is added to the result.
- TupleAddedEvent - Class in com.streambase.liveview.client
-
The event dispatched when a new Tuple is added to a query result.
- TupleAddedEvent(Object, Long, Tuple) - Constructor for class com.streambase.liveview.client.TupleAddedEvent
-
Deprecated.
- TupleAddedEvent(Object, Long, Tuple, Tuple, List<TupleFieldComparator>) - Constructor for class com.streambase.liveview.client.TupleAddedEvent
-
- TupleCaptureTransformer - Interface in com.streambase.sb
-
A TupleCaptureTransformer represents a way of converting tuples with capture
fields from inside the application to tuples without capture fields, with
all of the fields stored in the capture expanded out to the same level
as the capture field itself.
- TupleComparator - Interface in com.streambase.sb.unittest
-
- TupleCompareFunctor() - Constructor for class com.streambase.sb.unittest.FieldBasedTupleComparator.TupleCompareFunctor
-
- TupleCopier - Class in com.streambase.sb
-
A utility class which copies the fields from one tuple to another.
- TupleCopier(Schema, Schema, boolean) - Constructor for class com.streambase.sb.TupleCopier
-
Create the TupleCopier.
- TupleCopier(Schema, Schema, EnumSet<TupleCopier.Options>) - Constructor for class com.streambase.sb.TupleCopier
-
Create the TupleCopier.
- TupleCopier.Options - Enum in com.streambase.sb
-
Options for this TupleCopier
- tupleCount() - Method in class com.streambase.sb.client.StreamBaseClient.TupleBuffer
-
- 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
-
- TupleJSONUtil - Class in com.streambase.sb
-
Utilities for dealing with tuples represented in JSON format.
- TupleJSONUtil.Options - Enum in com.streambase.sb
-
Options for serializing JSON.
- TupleMaker<T> - Interface in com.streambase.sb.unittest
-
Interface for constructing tuples from data.
- tupleRemoved(TupleRemovedEvent) - Method in class com.streambase.liveview.client.AbstractBatchedQueryListener
-
Event when an existing tuple is removed from the result.
- tupleRemoved(TupleRemovedEvent) - Method in class com.streambase.liveview.client.AbstractQueryListener
-
Event when an existing tuple is removed from the result.
- tupleRemoved(TupleRemovedEvent) - Method in class com.streambase.liveview.client.CompositeQueryListener
-
Event when an existing tuple is removed from the result.
- tupleRemoved(TupleRemovedEvent) - Method in class com.streambase.liveview.client.DeleteQueryListener
-
Event when an existing tuple is removed from the result.
- tupleRemoved(TupleRemovedEvent) - Method in class com.streambase.liveview.client.LiveResult
-
Event when an existing tuple is removed from the result.
- tupleRemoved(TupleRemovedEvent) - Method in interface com.streambase.liveview.client.QueryListener
-
Event when an existing tuple is removed from the result.
- tupleRemoved(TupleRemovedEvent) - Method in class com.streambase.liveview.client.QueryListenerWrapper
-
- tupleRemoved(TupleRemovedEvent) - Method in class com.streambase.liveview.client.SnapshotQueryListener
-
Event when an existing tuple is removed from the result.
- TupleRemovedEvent - Class in com.streambase.liveview.client
-
The event dispatched when an existing Tuple is removed.
- TupleRemovedEvent(Object, Long, Tuple) - Constructor for class com.streambase.liveview.client.TupleRemovedEvent
-
Deprecated.
- TupleRemovedEvent(Object, Long, Tuple, Tuple, List<TupleFieldComparator>) - Constructor for class com.streambase.liveview.client.TupleRemovedEvent
-
- TupleType(Schema) - Constructor for class com.streambase.sb.CompleteDataType.TupleType
-
- tupleUpdated(TupleUpdatedEvent) - Method in class com.streambase.liveview.client.AbstractBatchedQueryListener
-
Event when an existing tuple in the result is updated.
- tupleUpdated(TupleUpdatedEvent) - Method in class com.streambase.liveview.client.AbstractQueryListener
-
Event when an existing tuple in the result is updated.
- tupleUpdated(TupleUpdatedEvent) - Method in class com.streambase.liveview.client.CompositeQueryListener
-
Event when an existing tuple in the result is updated.
- tupleUpdated(TupleUpdatedEvent) - Method in class com.streambase.liveview.client.DeleteQueryListener
-
Event when an existing tuple in the result is updated.
- tupleUpdated(TupleUpdatedEvent) - Method in class com.streambase.liveview.client.LiveResult
-
Event when an existing tuple in the result is updated.
- tupleUpdated(TupleUpdatedEvent) - Method in interface com.streambase.liveview.client.QueryListener
-
Event when an existing tuple in the result is updated.
- tupleUpdated(TupleUpdatedEvent) - Method in class com.streambase.liveview.client.QueryListenerWrapper
-
- tupleUpdated(TupleUpdatedEvent) - Method in class com.streambase.liveview.client.SnapshotQueryListener
-
Event when an existing tuple in the result is updated.
- TupleUpdatedEvent - Class in com.streambase.liveview.client
-
The event dispatched when an existing Tuple is updated.
- TupleUpdatedEvent(Object, Long, Tuple, Tuple, List<Schema.Field>) - Constructor for class com.streambase.liveview.client.TupleUpdatedEvent
-
Deprecated.
- TupleUpdatedEvent(Object, Long, Tuple, Tuple, Tuple, List<Schema.Field>, List<TupleFieldComparator>) - Constructor for class com.streambase.liveview.client.TupleUpdatedEvent
-
- TupleUtil.RepMethods - Class in com.streambase.sb
-
- type - Variable in class com.streambase.sb.CompleteDataType
-
- TYPE_TO_TYPE_SCORE - Static variable in class com.streambase.sb.CompleteDataType
-
- 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() - Method in class com.streambase.sb.operator.Operator
-
The typecheck method is called by Studio and the StreamBase server to ensure that
all the parameters for this operator are correct.
- TypecheckException - Exception in com.streambase.sb.operator
-
May be thrown when an error occurs during an Operator's typecheck() method.
- TypecheckException(String) - Constructor for exception com.streambase.sb.operator.TypecheckException
-
Constructs a TypecheckException with the given message
- TypecheckException(String, Throwable) - Constructor for exception com.streambase.sb.operator.TypecheckException
-
Constructs a TypecheckException with the given message and cause
- TypecheckException(Throwable) - Constructor for exception com.streambase.sb.operator.TypecheckException
-
Constructs a TypecheckException with the given cause and a message of (cause==null ? null : cause.toString())
- TypecheckException(StreamBaseException) - Constructor for exception com.streambase.sb.operator.TypecheckException
-
- TypecheckException(LocatedItem, String, Throwable) - Constructor for exception com.streambase.sb.operator.TypecheckException
-
Constructs a located TypecheckException with the given message and cause.
- TypecheckException(LocatedItem, String) - Constructor for exception com.streambase.sb.operator.TypecheckException
-
Constructs a located TypecheckException with the given message.
- TypecheckException(LocatedItem, Throwable) - Constructor for exception com.streambase.sb.operator.TypecheckException
-
Constructs a TypecheckException with the given cause and a message of (cause==null ? null : cause.toString()).
- typeHint(ResourceFilePropertyDescriptor.TypeHint) - Method in class com.streambase.sb.operator.parameter.ResourceFilePropertyDescriptor
-
- typeNameFor(Class<?>) - Static method in enum com.streambase.sb.DataType
-
Return the type name for the given Class type.
- validateAlertRule(AlertRule) - Method in interface com.streambase.liveview.client.alert.AlertManager
-
Validates the given alert rule.
- validateTablesContainers() - Method in class com.streambase.liveview.server.table.plugin.TableProviderManager
-
- ValidationErrorsException - Exception in com.streambase.liveview.client
-
Used to represent all errors in validating an object.
- ValidationErrorsException() - Constructor for exception com.streambase.liveview.client.ValidationErrorsException
-
- ValidationErrorsException(String) - Constructor for exception com.streambase.liveview.client.ValidationErrorsException
-
- value() - Method in enum com.streambase.liveview.client.LiveViewQueryType
-
- valueOf(String) - Static method in enum com.streambase.liveview.client.alert.AlertRule.Type
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.liveview.client.alert.AlertRuleAction.ActionType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.liveview.client.alert.LiveViewAlertType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.liveview.client.ConnectionMode
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.liveview.client.LiveViewClientCapability
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.liveview.client.LiveViewConnectionControl.ConnectionState
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.liveview.client.LiveViewExceptionType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.liveview.client.LiveViewPermission.Action
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.liveview.client.LiveViewPermission.Type
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.liveview.client.LiveViewQueryLanguage
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.liveview.client.LiveViewQueryType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.liveview.client.LiveViewTableCapability
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.liveview.client.OrderDefinition.Direction
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.liveview.client.Table.TableGroup
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.liveview.client.Table.TableStatus
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.liveview.server.table.plugin.TableProviderStatus
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.CaptureTransformStrategy
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.client.ConnectionStatus
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.client.StreamBaseAdminClient.ListConnectionArgument
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.Constants.ContainerState
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.Constants.LeadershipStatus
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.DataType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.monitor.Snapshot.Status
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.monitor.StatsUtil.StatEncoder.KeyType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.monitor.StatsUtil.What
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.NowImplementation
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.operator.Operator.IconKind
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.operator.Operator.LogLevel
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.operator.Operator.SharedObject.State
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.operator.parameter.JavaTypePropertyDescriptor.TypeChoice
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.operator.parameter.ResourceFilePropertyDescriptor.TypeHint
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.operator.parameter.UIHints.TextWidthHint
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.SchemaUtil.CoercionOptions
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.SchemaUtil.CopyOptions
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.TupleCopier.Options
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.TupleJSONUtil.Options
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.streambase.sb.unittest.Expecter.DequeueSetting
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum com.streambase.liveview.client.alert.AlertRule.Type
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.liveview.client.alert.AlertRuleAction.ActionType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.liveview.client.alert.LiveViewAlertType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.liveview.client.ConnectionMode
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.liveview.client.LiveViewClientCapability
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.liveview.client.LiveViewConnectionControl.ConnectionState
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.liveview.client.LiveViewExceptionType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.liveview.client.LiveViewPermission.Action
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.liveview.client.LiveViewPermission.Type
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.liveview.client.LiveViewQueryLanguage
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.liveview.client.LiveViewQueryType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.liveview.client.LiveViewTableCapability
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.liveview.client.OrderDefinition.Direction
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.liveview.client.Table.TableGroup
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.liveview.client.Table.TableStatus
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.liveview.server.table.plugin.TableProviderStatus
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.CaptureTransformStrategy
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.client.ConnectionStatus
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.client.StreamBaseAdminClient.ListConnectionArgument
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.Constants.ContainerState
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.Constants.LeadershipStatus
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.DataType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.monitor.Snapshot.Status
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.monitor.StatsUtil.StatEncoder.KeyType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.monitor.StatsUtil.What
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.NowImplementation
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.operator.Operator.IconKind
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.operator.Operator.LogLevel
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.operator.Operator.SharedObject.State
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.operator.parameter.JavaTypePropertyDescriptor.TypeChoice
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.operator.parameter.ResourceFilePropertyDescriptor.TypeHint
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.operator.parameter.UIHints.TextWidthHint
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.SchemaUtil.CoercionOptions
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.SchemaUtil.CopyOptions
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.TupleCopier.Options
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.TupleJSONUtil.Options
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.streambase.sb.unittest.Expecter.DequeueSetting
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- Variable - Class in com.streambase.liveview.client.dynamictables
-
Variables can be used in both test and assignment expressions in the FieldRules.
- Variable(String, DataType, String, String) - Constructor for class com.streambase.liveview.client.dynamictables.Variable
-
- VARIABLE_SIZE - Static variable in enum com.streambase.sb.DataType
-
- Version - Class in com.streambase.liveview.client
-
Provides information about the StreamBase LiveView Client Library.
- Version() - Constructor for class com.streambase.liveview.client.Version
-
- 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
- visitField(Schema.Field, String) - Method in class com.streambase.sb.SchemaUtil.SchemaTraversal
-
This method will be called for each and every field in the schema, including
nested fields and fields in lists of tuples
- visitSchema(Schema, String) - Method in class com.streambase.sb.SchemaUtil.SchemaTraversal
-
This method will be called for each and every schema