Uses of Class
com.streambase.sb.StreamProperties

Packages that use StreamProperties

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.

Uses of StreamProperties in com.streambase.sb.client

Fields in com.streambase.sb.client declared as StreamProperties

Modifier and Type	Field and Description
protected StreamProperties	DequeueResult.props

Methods in com.streambase.sb.client that return StreamProperties

Modifier and Type	Method and Description
StreamProperties	DequeueResult.getStreamProperties() Return the StreamProperties for this DequeueResult.
StreamProperties	StreamBaseClient.getStreamProperties(String streamName) Return the StreamProperties for the given stream name
StreamProperties	StreamBaseClient.getStreamProperties(String streamName, CaptureTransformStrategy strategy) Return the StreamProperties for the given stream name
StreamProperties	StreamBaseClient.getStreamPropertiesByHash(byte[] hash) Return the StreamProperties for the given hash StreamProperties are cached locally in the client.
StreamProperties	StreamBaseClient.getStreamPropertiesByHash(String hashHexString) Return the StreamProperties for the given hash StreamProperties are cached locally in the client.
StreamProperties	StreamBaseClient.TupleBuffer.props() get stream properties for this Buffer
StreamProperties	DeMUXStreamBaseClient.resubscribe(StreamProperties props, String logicalstream, String predicate)
StreamProperties	StreamBaseClient.resubscribe(StreamProperties props, String logicalstream, String predicate) Resubscribe to a stream with a predicate.
StreamProperties	DeMUXStreamBaseClient.resubscribe(String streamname, String logicalstream, String predicate)
StreamProperties	StreamBaseClient.resubscribe(String streamname, String logicalstream, 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, String logicalstream, String predicate)
StreamProperties	StreamBaseClient.subscribe(StreamProperties props, String logicalstream, String predicate) Subscribe to a stream with a predicate.
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamname)
StreamProperties	StreamBaseClient.subscribe(String streamname) Subscribe to a stream
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamName, CaptureTransformStrategy strategy)
StreamProperties	StreamBaseClient.subscribe(String streamName, CaptureTransformStrategy strategy) Subscribe to a stream
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamName, CaptureTransformStrategy strategy, String logicalstream, String predicate)
StreamProperties	StreamBaseClient.subscribe(String streamName, CaptureTransformStrategy strategy, String logicalstream, String predicate) Subscribe to a stream with a predicate.
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamname, String logicalstream, String predicate)
StreamProperties	StreamBaseClient.subscribe(String streamname, String logicalstream, String predicate) Subscribe to a stream with a predicate.
StreamProperties	DeMUXStreamBaseClient.subscribe(String streamname, String logicalstream, String predicate, DeMUXStreamBaseClient.DequeueListener listener) This is the only subscribe operation that is supported by the DeMUXStreamBaseClient
StreamProperties[]	StreamBaseClient.typecheck(String application) Typecheck (validate) the given StreamBase Application.
StreamProperties[]	StreamBaseClient.typecheck(String application, boolean full) Typecheck (validate) the given StreamBase Application.

Methods in com.streambase.sb.client that return types with arguments of type StreamProperties

Modifier and Type	Method and Description
Set<StreamProperties>	StreamBaseClient.getAllStreamProperties(EntityType type) Return all the StreamProperties available.
Set<StreamProperties>	StreamBaseClient.getAllStreamProperties(EntityType type, CaptureTransformStrategy strategy) Return all the StreamProperties available

Methods in com.streambase.sb.client with parameters of type StreamProperties

Modifier and Type	Method and Description
protected static String	StreamBaseClient.assureNameStartsWithContainer(StreamProperties base, String logicalName)
boolean	StreamBaseClient.TupleBuffer.canDequeue(StreamProperties props)
boolean	StreamBaseClient.TupleBuffer.canEnqueue(StreamProperties props)
void	StreamBaseClient.enqueue(StreamProperties props, 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 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, String logicalstream, String predicate)
StreamProperties	StreamBaseClient.resubscribe(StreamProperties props, String logicalstream, 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, String logicalstream, String predicate)
StreamProperties	StreamBaseClient.subscribe(StreamProperties props, String logicalstream, 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)

Constructors in com.streambase.sb.client with parameters of type StreamProperties

Constructor and Description
SimpleDequeueResult(List<Tuple> tuples, StreamProperties props, StreamBaseURI server, Constants.LeadershipStatus leadershipStatus)

Uses of StreamProperties in com.streambase.sb.monitor

Methods in com.streambase.sb.monitor that return StreamProperties

Modifier and Type	Method and Description
StreamProperties	StreamInfo.getStreamProperties() Returns the StreamProperties of the stream

Uses of StreamProperties in com.streambase.sb.unittest

Methods in com.streambase.sb.unittest that return StreamProperties

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.