Uses of Class
com.streambase.sb.client.StreamBaseClient
Package
Description
Provides classes and interfaces used to communicate with a Streaming server.
Provides classes and interfaces to monitor the behavior of a running Streaming server.
-
Uses of StreamBaseClient in com.streambase.sb.client
Modifier and TypeClassDescriptionclass
This is a StreamBaseClient that is intended for use by several independent queries.Modifier and TypeMethodDescriptionvoid
ConnectionStatusCallback.stateChanged
(ConnectionStatus state, StreamBaseClient streamBaseClient, String additionalInfo) Called when the connection state changesModifierConstructorDescription(package private)
TupleConnection
(StreamBaseURI uri, StreamBaseClient client, TupleConnections connections, long clientReadTimeout) Constructor(package private)
TupleConnections
(StreamBaseClient client, boolean haModeOn) Constructor -
Uses of StreamBaseClient in com.streambase.sb.monitor
Modifier and TypeMethodDescriptionStreamBaseMonitor.getClient()
Get theStreamBaseClient
that this monitor is usingModifier and TypeMethodDescriptionSnapshot.getOperatorType
(StreamBaseClient sbClient, String name) Get operator type(package private) Snapshot.Status
Snapshot.readNextMonitorSnap
(StreamBaseClient sbClient, Snapshot.Source source) Read the next monitor snapshot, return Status if we are done or not(package private) Snapshot.Status
Snapshotv3.readNextMonitorSnap
(StreamBaseClient sbClient, Snapshot.Source source) ModifierConstructorDescriptionStreamBaseMonitor
(StreamBaseClient client) Create a monitoring object, which will connect to a server with the given StreamBaseClient object.StreamBaseMonitor
(StreamBaseClient sbClient, String streamName) Constructor