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 StreamPropertiesSBUtils. newStreamProperties(String xmlstring, ByteOrder order)static StreamPropertiesSBUtils. 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 StreamPropertiesDequeueResult. propsMethods in com.streambase.sb.client that return StreamProperties Modifier and Type Method Description StreamPropertiesDequeueResult. getStreamProperties()Return the StreamProperties for this DequeueResult.StreamPropertiesStreamBaseClient. getStreamProperties(String streamName)Return the StreamProperties for the given stream nameStreamPropertiesStreamBaseClient. getStreamProperties(String streamName, CaptureTransformStrategy strategy)Return the StreamProperties for the given stream nameStreamPropertiesXmlRpcAdmin. getStreamProperties(long timeoutMS, String streamName)StreamPropertiesXmlRpcAdmin. getStreamProperties(long timeoutMS, String streamName, CaptureTransformStrategy strategy)StreamPropertiesStreamBaseClient. getStreamPropertiesByHash(byte[] hash)Return the StreamProperties for the given hash StreamProperties are cached locally in the client.StreamPropertiesStreamBaseClient. getStreamPropertiesByHash(String hashHexString)Return the StreamProperties for the given hash StreamProperties are cached locally in the client.StreamPropertiesXmlRpcAdmin. getStreamPropertiesByHash(long timeoutMS, byte[] hash)StreamPropertiesStreamBaseClient.TupleBuffer. props()get stream properties for this BufferStreamPropertiesDeMUXStreamBaseClient. resubscribe(StreamProperties props, String logicalstream, String predicate)StreamPropertiesDeMUXStreamBaseClient. resubscribe(String streamname, String logicalstream, String predicate)StreamPropertiesStreamBaseClient. resubscribe(StreamProperties props, String logicalstream, String predicate)Resubscribe to a stream with a predicate.StreamPropertiesStreamBaseClient. resubscribe(String streamname, String logicalstream, String predicate)Resubscribe to a stream with a predicate.StreamPropertiesDeMUXStreamBaseClient. subscribe(StreamProperties props)StreamPropertiesDeMUXStreamBaseClient. subscribe(StreamProperties props, String logicalstream, String predicate)StreamPropertiesDeMUXStreamBaseClient. subscribe(String streamname)StreamPropertiesDeMUXStreamBaseClient. subscribe(String streamName, CaptureTransformStrategy strategy)StreamPropertiesDeMUXStreamBaseClient. subscribe(String streamName, CaptureTransformStrategy strategy, String logicalstream, String predicate)StreamPropertiesDeMUXStreamBaseClient. subscribe(String streamname, String logicalstream, String predicate)StreamPropertiesDeMUXStreamBaseClient. subscribe(String streamname, String logicalstream, String predicate, DeMUXStreamBaseClient.DequeueListener listener)This is the only subscribe operation that is supported by the DeMUXStreamBaseClientStreamPropertiesStreamBaseClient. subscribe(StreamProperties props)Subscribe to a streamStreamPropertiesStreamBaseClient. subscribe(StreamProperties props, String logicalstream, String predicate)Subscribe to a stream with a predicate.StreamPropertiesStreamBaseClient. subscribe(String streamname)Subscribe to a streamStreamPropertiesStreamBaseClient. subscribe(String streamName, CaptureTransformStrategy strategy)Subscribe to a streamStreamPropertiesStreamBaseClient. subscribe(String streamName, CaptureTransformStrategy strategy, String logicalstream, String predicate)Subscribe to a stream with a predicate.StreamPropertiesStreamBaseClient. 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 StringStreamBaseClient. assureNameStartsWithContainer(StreamProperties base, String logicalName)Ensure name starts with containerbooleanStreamBaseClient.TupleBuffer. canDequeue(StreamProperties props)Can dequeue?booleanStreamBaseClient.TupleBuffer. canEnqueue(StreamProperties props)Can enqueue?voidStreamBaseClient. enqueue(StreamProperties props, Tuple tuple)Enqueue a single Tuple onto a stream.voidStreamBaseClient. enqueue(StreamProperties props, Collection<Tuple> tuples)Enqueue a collection of Tuples onto a stream.voidXmlRpcAdmin. enqueue(long timeoutMS, StreamProperties props, Collection<String> tuples)voidStreamBaseClient. flushBuffer(StreamProperties props)Deprecated.useStreamBaseClient.flushAllBuffers()to preserve inter-stream orderingprotected static StringDeMUXStreamBaseClient. getFullLogicalName(StreamProperties streamProperties)booleanDeMUXStreamBaseClient. isSubscribed(StreamProperties stream)booleanStreamBaseClient. isSubscribed(StreamProperties stream)Return status if we are subscribed to the given streamStreamPropertiesDeMUXStreamBaseClient. resubscribe(StreamProperties props, String logicalstream, String predicate)StreamPropertiesStreamBaseClient. resubscribe(StreamProperties props, String logicalstream, String predicate)Resubscribe to a stream with a predicate.StreamPropertiesDeMUXStreamBaseClient. subscribe(StreamProperties props)StreamPropertiesDeMUXStreamBaseClient. subscribe(StreamProperties props, String logicalstream, String predicate)StreamPropertiesStreamBaseClient. subscribe(StreamProperties props)Subscribe to a streamStreamPropertiesStreamBaseClient. subscribe(StreamProperties props, String logicalstream, String predicate)Subscribe to a stream with a predicate.voidDeMUXStreamBaseClient. unsubscribe(StreamProperties logicalProps)voidStreamBaseClient. unsubscribe(StreamProperties logicalProps)Unsubscribe from the given stream name.voidXmlRpcAdmin. unsubscribe(long timeoutMS, StreamProperties props, String logicalstream, List<com.streambase.sb.client.TupleConnections.StreamTupleConnection> connections)protected voidStreamBaseClient. 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, Constants.LeadershipStatus leadershipStatus) -
Uses of StreamProperties in com.streambase.sb.monitor
Methods in com.streambase.sb.monitor that return StreamProperties Modifier and Type Method Description StreamPropertiesStreamInfo. 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 StreamPropertiesDequeuer. getStreamProperties()Get theStreamPropertiesfor the associated stream.StreamPropertiesEnqueuer. getStreamProperties()Get theStreamPropertiesfor the associated stream.
-