Uses of Class
com.streambase.sb.StreamProperties
-
Packages that use StreamProperties Package Description com.streambase.sb Provides classes and interfaces fundamental to the TIBCO StreamBase Java API.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
Methods in com.streambase.sb that return StreamProperties Modifier and Type Method Description static StreamProperties
SBUtils. newStreamProperties(String xmlstring, ByteOrder order)
static StreamProperties
SBUtils. newStreamProperties(Element element, ByteOrder order)
-
Uses of StreamProperties in com.streambase.sb.client
Fields in com.streambase.sb.client declared as StreamProperties Modifier and Type Field Description protected StreamProperties
DequeueResult. props
Stream propertiesMethods in com.streambase.sb.client that return StreamProperties Modifier and Type Method Description StreamProperties
DequeueResult. getStreamProperties()
Return the StreamProperties for this DequeueResult.StreamProperties
StreamBaseClient. getStreamProperties(String streamName)
Return the StreamProperties for the given stream nameStreamProperties
StreamBaseClient. getStreamProperties(String streamName, CaptureTransformStrategy strategy)
Return the StreamProperties for the given stream nameStreamProperties
XmlRpcAdmin. getStreamProperties(long timeoutMS, String streamName)
StreamProperties
XmlRpcAdmin. getStreamProperties(long timeoutMS, String streamName, CaptureTransformStrategy strategy)
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
XmlRpcAdmin. getStreamPropertiesByHash(long timeoutMS, byte[] hash)
StreamProperties
StreamBaseClient.TupleBuffer. props()
get stream properties for this BufferStreamProperties
DeMUXStreamBaseClient. resubscribe(StreamProperties props, String logicalstream, String predicate)
StreamProperties
DeMUXStreamBaseClient. resubscribe(String streamname, String logicalstream, String predicate)
StreamProperties
StreamBaseClient. resubscribe(StreamProperties props, String logicalStream, String predicate)
Resubscribe to a stream with a predicate.StreamProperties
StreamBaseClient. resubscribe(String streamname, String logicalstream, String predicate)
Resubscribe to a stream with a predicate.StreamProperties
DeMUXStreamBaseClient. subscribe(StreamProperties props)
StreamProperties
DeMUXStreamBaseClient. subscribe(StreamProperties props, String logicalstream, String predicate)
StreamProperties
DeMUXStreamBaseClient. subscribe(String streamname)
StreamProperties
DeMUXStreamBaseClient. subscribe(String streamName, CaptureTransformStrategy strategy)
StreamProperties
DeMUXStreamBaseClient. subscribe(String streamName, CaptureTransformStrategy strategy, String logicalstream, String predicate)
StreamProperties
DeMUXStreamBaseClient. subscribe(String streamname, String logicalstream, String predicate)
StreamProperties
DeMUXStreamBaseClient. subscribe(String streamname, String logicalstream, String predicate, DeMUXStreamBaseClient.DequeueListener listener)
This is the only subscribe operation that is supported by the DeMUXStreamBaseClientStreamProperties
StreamBaseClient. subscribe(StreamProperties props)
Subscribe to a streamStreamProperties
StreamBaseClient. subscribe(StreamProperties props, String logicalStream, String predicate)
Subscribe to a stream with a predicate.StreamProperties
StreamBaseClient. subscribe(String streamname)
Subscribe to a streamStreamProperties
StreamBaseClient. subscribe(String streamName, CaptureTransformStrategy strategy)
Subscribe to a streamStreamProperties
StreamBaseClient. subscribe(String streamName, CaptureTransformStrategy strategy, String logicalstream, String predicate)
Subscribe to a stream with a predicate.StreamProperties
StreamBaseClient. subscribe(String streamname, String logicalstream, String predicate)
Subscribe to a stream with a predicate.StreamProperties[]
StreamBaseClient. typecheck(String application)
Typecheck (validate) the given StreamBase Application.StreamProperties[]
StreamBaseClient. typecheck(String application, boolean full)
Typecheck (validate) the given StreamBase Application.StreamProperties[]
XmlRpcAdmin. typecheck(long timeoutMS, String application, boolean full)
Methods in com.streambase.sb.client that return types with arguments of type StreamProperties Modifier and Type Method Description Set<StreamProperties>
StreamBaseClient. getAllStreamProperties(EntityType type)
Return all the StreamProperties available.Set<StreamProperties>
StreamBaseClient. getAllStreamProperties(EntityType type, CaptureTransformStrategy strategy)
Return all the StreamProperties availableMethods in com.streambase.sb.client with parameters of type StreamProperties Modifier and Type Method Description protected static String
StreamBaseClient. assureNameStartsWithContainer(StreamProperties base, String logicalName)
Ensure name starts with containerboolean
StreamBaseClient.TupleBuffer. canDequeue(StreamProperties props)
Can dequeue?boolean
StreamBaseClient.TupleBuffer. canEnqueue(StreamProperties props)
Can enqueue?void
StreamBaseClient. enqueue(StreamProperties props, Tuple tuple)
Enqueue a single Tuple onto a stream.void
StreamBaseClient. enqueue(StreamProperties props, Collection<Tuple> tuples)
Enqueue a collection of Tuples onto a stream.void
XmlRpcAdmin. enqueue(long timeoutMS, StreamProperties props, Collection<String> tuples)
void
StreamBaseClient. flushBuffer(StreamProperties props)
Deprecated.useStreamBaseClient.flushAllBuffers()
to preserve inter-stream orderingprotected 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 streamStreamProperties
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
DeMUXStreamBaseClient. subscribe(StreamProperties props, String logicalstream, String predicate)
StreamProperties
StreamBaseClient. subscribe(StreamProperties props)
Subscribe to a streamStreamProperties
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.void
XmlRpcAdmin. unsubscribe(long timeoutMS, StreamProperties props, String logicalstream, List<com.streambase.sb.client.TupleConnections.StreamTupleConnection> connections)
protected void
StreamBaseClient. unsubscribeInternal(StreamProperties logicalProps)
Un-subscribe from streamConstructors in com.streambase.sb.client with parameters of type StreamProperties Constructor Description SimpleDequeueResult(List<Tuple> tuples, StreamProperties props, StreamBaseURI server)
Constructor -
Uses of StreamProperties in com.streambase.sb.monitor
Methods in com.streambase.sb.monitor that return StreamProperties Modifier and Type Method 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 Description StreamProperties
Dequeuer. getStreamProperties()
Get theStreamProperties
for the associated stream.StreamProperties
Enqueuer. getStreamProperties()
Get theStreamProperties
for the associated stream.
-