All Classes and Interfaces

Class	Description
AbstractTestClass	Test class providing utilities for testing of topologies.
ActiveVersion	Basic class to hold the ActiveVersion JSON structure
ApplicationBundle	An object describing an Streams Domain
BeaconStreams	Utilities for beacon streams.
BeaconStreams.BeaconFunction
BeaconTuple	Tuple type issued by a beacon stream.
BiFunction<T1,T2,R>	A function that is passed two arguments and returns a value.
CollectionStreams	Utilities for streams tuples that are collections of values.
CollectionStreams.FlattenCollection<C extends Collection<T>,T>	Function that flattens a collection when passed to TStream.multiTransform(Function).
CollectionStreams.FlattenMap<M extends Map<K,V>,K,V>
Condition<T>	A test condition on a stream or application under test.
ConsistentRegionConfig	Immutable consistent region configuration.
ConsistentRegionConfig.Trigger	Defines how the drain-checkpoint cycle of a consistent region is triggered.
Consumer<T>	A function that takes an argument and returns nothing.
ContextProperties	Properties that can be specified when submitting the topology to a context.
DirectoryWatcher
Domain	An object describing an Streams Domain
Element	Streams element.
ExpectedTuples	List of expected tuples.
FileSPLStreams	Creation of SPLStreams that relate to files.
FileSPLStreams.Compression
FileStreams	Utilities for file system related streams.
Function<T,R>	A function that is passed an argument and returns a value.
FunctionContainer	Container for a function executing in a Streams application.
FunctionContext	Context for a function executing in a Streams application.
HTTPStreams	Access to data in web servers or services using HTTP.
Identity<T>	Identity unary function that returns its input.
Initializable	Optional interface that a function can implement to perform initialization.
InputPort	An Input Port of the Streams Operator
Instance	An object describing an Streams Instance
JavaPrimitive	Integration between Java topologies and SPL Java primitive operators.
Job	An object describing an Streams Job submitted within a specified instance
JobConfig	A job configuration.
JobProperties	Job properties specific to distributed contexts.
JobSubmitParameters	Holds Submisson Paramters for a Job
JSONAble
JSONSchemas	SPL schema for JSON.
JSONStreams	Utilities for JSON streams.
JSONStreams.DeserializeJSON	Function to deserialize a String to a JSONObject.
JSONStreams.SerializeJSON	Function to serialize a JSONObject to a String.
JSONStreams.ToJSON<T extends JSONAble>	Function to convert a JSONAble tuple to a JSONObject, using JSONAble.toJSON().
KafkaConsumer	A simple connector to an Apache Kafka cluster for consuming Kafka messages -- subscribing to Kafka topics and creating a TStream<Message>.
KafkaProducer	A simple connector to an Apache Kafka cluster for producing Kafka messages -- publishing a TStream<Message> to Kafka topics.
Keyable<K>	A tuple that has a partition key.
Logic
Message	An interface for tuple attributes common to messaging adapters in com.teracloud.streams.topology.messaging.
Metric	An object describing an Streams Metric
MqttStreams	A simple connector to a MQTT broker for publishing TStream<Message> tuples to MQTT topics, and subscribing to MQTT topics and creating TStream<Message> streams.
ObjIntConsumer<T>
Operator	An object describing an Streams Operator
OutputPort	An Output Port of the Streams Operator
PEInputPort	An Input Port of the Streams Processing Element
PEOutputPort	A Output Port of the Streams Processing Element
Placeable<T extends Placeable<T>>	Placement directives for a topology element when executing in a distributed runtime.
Predicate<T>	A function that tests a tuple.
ProcessingElement	An object describing an Streams Processing Element
Resource	Domain resource information.
ResourceAllocation	Access to information about a resource that is allocated to a Streams instance.
RESTErrorMessage	An object describing an Streams REST api Error Message
RESTException	Exception for REST api wrappers
RestServer	Adds a HTTP REST server to a topology to provide external interaction with the application.
Result<T,R>	Represents a result from a REST request.
ResultProperties	Result properties.
SimpleMessage	A Simple implementation of an immutable Message.
SPL	Integration between Java topologies and SPL operator invocations.
SPLInput	Interface that can be connected to an SPL input port.
SPLSchemas	Interchangeable SPL types.
SPLStream	A SPLStream is a declaration of a continuous sequence of tuples with a defined SPL schema.
SPLStreams	Utilities for SPL attribute schema streams.
SPLWindow	An SPL window, that has an SPL eviction policy and an SPL trigger policy.
StreamsConnection	Connection to Streams.
StreamsContext<T>	A StreamsContext provides the ability to turn a Topology into an executable.
StreamsContext.Type	Types of the Streams context that a Topology can be executed against.
StreamsContextFactory	Factory for creating StreamsContext instances.
StringStreams	Utilities for streams containing String tuples.
SubmissionParameter
Supplier<T>	A function that supplies a value.
Tester	A Tester adds the ability to test a topology in a test framework such as JUnit.
TestProperties
TextFileReader
ToIntFunction<T>	A function that applies a computation to a tuple and returns an int result.
Topology	A declaration of a topology of streaming data.
TopologyElement	Any element in a Topology.
TSink	A handle to the sink of a TStream.
TStream<T>	A TStream is a declaration of a continuous sequence of tuples.
TStream.Routing	Enumeration for routing tuples to parallel channels.
TWindow<T,K>	Declares a window of tuples for a TStream.
UnaryOperator<T>	Specialization of Function where the return type is the same as the argument type.
Util
Value<T>	A Supplier for a single constant T value.