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
StreamProperties	TupleConnections.StreamTupleConnection._props
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	Admin.getStreamProperties(long timeoutMS, String streamName) Return the StreamProperties for the given name.
StreamProperties	HAAdmin.getStreamProperties(long timeoutMS, String streamName)
StreamProperties	Admin.getStreamProperties(long timeoutMS, String streamName, CaptureTransformStrategy strategy) Return the StreamProperties for the given name.
StreamProperties	HAAdmin.getStreamProperties(long timeoutMS, String streamName, CaptureTransformStrategy strategy) Return the StreamProperties for the given name
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	Admin.getStreamPropertiesByHash(long timeoutMS, byte[] hash) Return the StreamProperties for the given hash
StreamProperties	HAAdmin.getStreamPropertiesByHash(long timeoutMS, byte[] hash) Return the StreamProperties for the given hash
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
(package private) StreamProperties	SubscriptionEntry.props()
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[]	Admin.typecheck(long timeoutMS, String application, boolean full) Typecheck (validate) the given StreamBase Application.
StreamProperties[]	HAAdmin.typecheck(long timeoutMS, String application, boolean full) Typecheck (validate) the given StreamBase Application.
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
(package private) void	TupleConnections.addConnection(StreamBaseURI uri, StreamProperties props)
protected static String	StreamBaseClient.assureNameStartsWithContainer(StreamProperties base, String logicalName) Ensure name starts with container
boolean	StreamBaseClient.TupleBuffer.canDequeue(StreamProperties props) Can dequeue?
boolean	StreamBaseClient.TupleBuffer.canEnqueue(StreamProperties props) Can enqueue?
void	Admin.enqueue(long timeoutMS, StreamProperties props, Collection<String> tuples) Enqueue a list of CSV encoded tuples using connectionless XMLRPC
void	HAAdmin.enqueue(long timeoutMS, StreamProperties props, Collection<String> tuples)
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
(package private) List<TupleConnections.StreamTupleConnection>	TupleConnections.getConnections(StreamProperties props) Return an unmodifable list of List<StreamConnection>
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
(package private) void	SubscriptionEntry.resetProperties(StreamProperties newProps)
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	Admin.unsubscribe(long timeoutMS, StreamProperties props, String logicalstream, List<TupleConnections.StreamTupleConnection> connections) UnSubscribe to an output stream.
void	HAAdmin.unsubscribe(long timeoutMS, StreamProperties props, String logicalstream, List<TupleConnections.StreamTupleConnection> connections) UnSubscribe to an output stream.
void	DeMUXStreamBaseClient.unsubscribe(StreamProperties logicalProps)
void	StreamBaseClient.unsubscribe(StreamProperties logicalProps) Unsubscribe from the given stream name.
protected void	StreamBaseClient.unsubscribeInternal(StreamProperties logicalProps) Un-subscribe from stream

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

Constructor and Description
SerializedTupleBuffer(StreamProperties props) Constructor
SimpleDequeueResult(List<Tuple> tuples, StreamProperties props, StreamBaseURI server, Constants.LeadershipStatus leadershipStatus)
StreamTupleConnection(StreamProperties props, TupleConnection connection)
SubscriptionEntry(StreamProperties props, String logicalName, String predicate)
TupleBuffer(StreamProperties props) Constructor

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

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

Constructor and Description
StreamInfo(StreamProperties props)

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.