Package | Description |
---|---|
com.streambase.sb.client |
Provides classes and interfaces used to communicate with a StreamBase server.
|
com.streambase.sb.monitor |
Provides classes and interfaces to monitor the behavior of a running StreamBase server.
|
com.streambase.sb.unittest |
Provides classes and interfaces used to author StreamBase Unit tests.
|
Modifier and Type | Field and Description |
---|---|
protected StreamProperties |
DequeueResult.props |
Modifier and Type | Method and Description |
---|---|
StreamProperties |
DequeueResult.getStreamProperties()
Return the StreamProperties for this DequeueResult.
|
StreamProperties |
StreamBaseClient.getStreamProperties(java.lang.String streamName)
Return the StreamProperties for the given stream name
|
StreamProperties |
StreamBaseClient.getStreamProperties(java.lang.String streamName,
CaptureTransformStrategy strategy)
Return the StreamProperties for the given stream name
|
StreamProperties |
StreamBaseClient.getStreamPropertiesByHash(byte[] hash)
Return the StreamProperties for the given hash
StreamProperties are cached locally in the client.
|
StreamProperties |
StreamBaseClient.getStreamPropertiesByHash(java.lang.String hashHexString)
Return the StreamProperties for the given hash
StreamProperties are cached locally in the client.
|
StreamProperties |
StreamBaseClient.TupleBuffer.props()
get stream properties for this Buffer
|
StreamProperties |
DeMUXStreamBaseClient.resubscribe(StreamProperties props,
java.lang.String logicalstream,
java.lang.String predicate) |
StreamProperties |
StreamBaseClient.resubscribe(StreamProperties props,
java.lang.String logicalstream,
java.lang.String predicate)
Resubscribe to a stream with a predicate.
|
StreamProperties |
DeMUXStreamBaseClient.resubscribe(java.lang.String streamname,
java.lang.String logicalstream,
java.lang.String predicate) |
StreamProperties |
StreamBaseClient.resubscribe(java.lang.String streamname,
java.lang.String logicalstream,
java.lang.String predicate)
Resubscribe to a stream with a predicate.
|
StreamProperties |
DeMUXStreamBaseClient.subscribe(StreamProperties props) |
StreamProperties |
StreamBaseClient.subscribe(StreamProperties props)
Subscribe to a stream
|
StreamProperties |
DeMUXStreamBaseClient.subscribe(StreamProperties props,
java.lang.String logicalstream,
java.lang.String predicate) |
StreamProperties |
StreamBaseClient.subscribe(StreamProperties props,
java.lang.String logicalstream,
java.lang.String predicate)
Subscribe to a stream with a predicate.
|
StreamProperties |
DeMUXStreamBaseClient.subscribe(java.lang.String streamname) |
StreamProperties |
StreamBaseClient.subscribe(java.lang.String streamname)
Subscribe to a stream
|
StreamProperties |
DeMUXStreamBaseClient.subscribe(java.lang.String streamName,
CaptureTransformStrategy strategy) |
StreamProperties |
StreamBaseClient.subscribe(java.lang.String streamName,
CaptureTransformStrategy strategy)
Subscribe to a stream
|
StreamProperties |
DeMUXStreamBaseClient.subscribe(java.lang.String streamName,
CaptureTransformStrategy strategy,
java.lang.String logicalstream,
java.lang.String predicate) |
StreamProperties |
StreamBaseClient.subscribe(java.lang.String streamName,
CaptureTransformStrategy strategy,
java.lang.String logicalstream,
java.lang.String predicate)
Subscribe to a stream with a predicate.
|
StreamProperties |
DeMUXStreamBaseClient.subscribe(java.lang.String streamname,
java.lang.String logicalstream,
java.lang.String predicate) |
StreamProperties |
StreamBaseClient.subscribe(java.lang.String streamname,
java.lang.String logicalstream,
java.lang.String predicate)
Subscribe to a stream with a predicate.
|
StreamProperties |
DeMUXStreamBaseClient.subscribe(java.lang.String streamname,
java.lang.String logicalstream,
java.lang.String predicate,
DeMUXStreamBaseClient.DequeueListener listener)
This is the only subscribe operation that is supported by the DeMUXStreamBaseClient
|
StreamProperties[] |
StreamBaseClient.typecheck(java.lang.String application)
Typecheck (validate) the given StreamBase Application.
|
StreamProperties[] |
StreamBaseClient.typecheck(java.lang.String application,
boolean full)
Typecheck (validate) the given StreamBase Application.
|
Modifier and Type | Method and Description |
---|---|
java.util.Set<StreamProperties> |
StreamBaseClient.getAllStreamProperties(EntityType type)
Return all the StreamProperties available.
|
java.util.Set<StreamProperties> |
StreamBaseClient.getAllStreamProperties(EntityType type,
CaptureTransformStrategy strategy)
Return all the StreamProperties available
|
Modifier and Type | Method and Description |
---|---|
protected static java.lang.String |
StreamBaseClient.assureNameStartsWithContainer(StreamProperties base,
java.lang.String logicalName) |
boolean |
StreamBaseClient.TupleBuffer.canDequeue(StreamProperties props) |
boolean |
StreamBaseClient.TupleBuffer.canEnqueue(StreamProperties props) |
void |
StreamBaseClient.enqueue(StreamProperties props,
java.util.Collection<Tuple> tuples)
Enqueue a collection of Tuples onto a stream.
|
void |
StreamBaseClient.enqueue(StreamProperties props,
Tuple tuple)
Enqueue a single Tuple onto a stream.
|
void |
StreamBaseClient.flushBuffer(StreamProperties props)
Deprecated.
use
StreamBaseClient.flushAllBuffers() to preserve inter-stream ordering |
protected static java.lang.String |
DeMUXStreamBaseClient.getFullLogicalName(StreamProperties streamProperties) |
boolean |
DeMUXStreamBaseClient.isSubscribed(StreamProperties stream) |
boolean |
StreamBaseClient.isSubscribed(StreamProperties stream)
Return status if we are subscribed to the given stream
|
StreamProperties |
DeMUXStreamBaseClient.resubscribe(StreamProperties props,
java.lang.String logicalstream,
java.lang.String predicate) |
StreamProperties |
StreamBaseClient.resubscribe(StreamProperties props,
java.lang.String logicalstream,
java.lang.String predicate)
Resubscribe to a stream with a predicate.
|
StreamProperties |
DeMUXStreamBaseClient.subscribe(StreamProperties props) |
StreamProperties |
StreamBaseClient.subscribe(StreamProperties props)
Subscribe to a stream
|
StreamProperties |
DeMUXStreamBaseClient.subscribe(StreamProperties props,
java.lang.String logicalstream,
java.lang.String predicate) |
StreamProperties |
StreamBaseClient.subscribe(StreamProperties props,
java.lang.String logicalstream,
java.lang.String predicate)
Subscribe to a stream with a predicate.
|
void |
DeMUXStreamBaseClient.unsubscribe(StreamProperties logicalProps) |
void |
StreamBaseClient.unsubscribe(StreamProperties logicalProps)
Unsubscribe from the given stream name.
|
protected void |
StreamBaseClient.unsubscribeInternal(StreamProperties logicalProps) |
Constructor and Description |
---|
SimpleDequeueResult(java.util.List<Tuple> tuples,
StreamProperties props,
StreamBaseURI server,
Constants.LeadershipStatus leadershipStatus) |
Modifier and Type | Method and Description |
---|---|
StreamProperties |
StreamInfo.getStreamProperties()
Returns the StreamProperties of the stream
|
Modifier and Type | Method and Description |
---|---|
StreamProperties |
Dequeuer.getStreamProperties()
Get the
StreamProperties for the associated stream. |
StreamProperties |
Enqueuer.getStreamProperties()
Get the
StreamProperties for the associated stream. |