Index (Java Application API for IBM Streams)

A B C D E F G H I J K L M N O P R S T U V W X _

A

AbstractConnection - Class in com.ibm.streamsx.rest.internal: This class represents an abstract connection.
AbstractConnection(boolean) - Constructor for class com.ibm.streamsx.rest.internal.AbstractConnection: Connection to a REST API
AbstractTestClass - Class in com.ibm.streamsx.topology.tester.junit: Test class providing utilities for testing of topologies.
AbstractTestClass() - Constructor for class com.ibm.streamsx.topology.tester.junit.AbstractTestClass
accept(File) - Method in class com.ibm.streamsx.topology.file.DirectoryWatcher
accept(T) - Method in interface com.ibm.streamsx.topology.function.Consumer
accept(T, int) - Method in interface com.ibm.streamsx.topology.function.ObjIntConsumer
action(String, String, JsonObject) - Method in class com.ibm.streamsx.rest.build.Build
ActiveVersion - Class in com.ibm.streamsx.rest: Basic class to hold the ActiveVersion JSON structure
ActiveVersion() - Constructor for class com.ibm.streamsx.rest.ActiveVersion
add(Tuple) - Method in class com.ibm.streamsx.topology.tester.spl.ExpectedTuples: Add a tuple to expected list.
addAsTuple(Object...) - Method in class com.ibm.streamsx.topology.tester.spl.ExpectedTuples: Add a tuple to expected list.
addClassDependency(Class<?>) - Method in class com.ibm.streamsx.topology.Topology: Ensures that a class file is loaded into the application's runtime.
addClassLibraries(String[]) - Method in interface com.ibm.streamsx.topology.function.FunctionContext: Add class libraries to the functional class loader.
addFileDependency(String, String) - Method in class com.ibm.streamsx.topology.Topology: Add file or directory tree location to directory dstDirName in the application bundle, making it available to the topology's SPL operators at runtime - e.g., an operator configuration file in "etc" in the application directory.
addJarDependency(String) - Method in class com.ibm.streamsx.topology.Topology: Includes a jar file, specified by the location String, into the application runtime.
addJobControlPlane() - Method in class com.ibm.streamsx.topology.Topology: Add job control plane to this topology.
addResourceTags(String...) - Method in interface com.ibm.streamsx.topology.context.Placeable: Add required resource tags for this topology element for distributed submission.
addSourceInfo(JsonObject, Class<?>) - Static method in interface com.ibm.streamsx.topology.spi.builder.SourceInfo: Add source level information to invokeInfo as the property "sourcelocation".
addSubmissionParameter(String, boolean) - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig
addSubmissionParameter(String, String) - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig
addSubmissionParameter(String, Number) - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig
addToConfig(Map<String, Object>) - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig
addToolkit(TopologyElement, File) - Static method in class com.ibm.streamsx.topology.spl.SPL: Add a dependency on an SPL toolkit.
addToolkitDependency(TopologyElement, String, String) - Static method in class com.ibm.streamsx.topology.spl.SPL: Add a logical dependency on an SPL toolkit.
aggregate(Function<List<T>, A>) - Method in interface com.ibm.streamsx.topology.TWindow: Declares a stream that containing tuples that represent an aggregation of this window.
aggregate(Function<List<T>, A>, long, TimeUnit) - Method in interface com.ibm.streamsx.topology.TWindow: Declares a stream that containing tuples that represent an aggregation of this window.
all(Condition<?>...) - Static method in interface com.ibm.streamsx.topology.tester.Condition: Return a condition that is true if all conditions are valid.
allowInsecureHosts() - Method in interface com.ibm.streamsx.rest.build.BuildService
allowInsecureHosts(boolean) - Method in class com.ibm.streamsx.rest.internal.AbstractConnection
allowInsecureHosts(boolean) - Method in class com.ibm.streamsx.rest.StreamsConnection: This function is used to disable checking the trusted certificate chain and should never be used in production environments
AnalyticsServiceProperties - Interface in com.ibm.streamsx.topology.context: Configuration properties for the Streaming Analytics service on IBM Cloud.
and(Condition<?>...) - Method in interface com.ibm.streamsx.topology.tester.Condition: Return a condition that is true if this AND all conditions are valid.
APP_DIR - Static variable in interface com.ibm.streamsx.topology.context.ContextProperties: Location of the generated application directory when creating a Streams application bundle.
ApplicationBundle - Class in com.ibm.streamsx.rest: An object describing an IBM Streams Domain
ApplicationBundle() - Constructor for class com.ibm.streamsx.rest.ApplicationBundle
apply(Executor) - Method in class com.ibm.streamsx.rest.internal.ICP4DAuthenticator
apply(Executor) - Method in class com.ibm.streamsx.rest.internal.StandaloneAuthenticator: Get the contents for an Authentication header.
apply(T1, T2) - Method in interface com.ibm.streamsx.topology.function.BiFunction
apply(T) - Method in interface com.ibm.streamsx.topology.function.Function
apply(String) - Method in class com.ibm.streamsx.topology.json.JSONStreams.DeserializeJSON
apply(JSONObject) - Method in class com.ibm.streamsx.topology.json.JSONStreams.SerializeJSON
apply(JSONAble) - Method in class com.ibm.streamsx.topology.json.JSONStreams.ToJSON
apply(T) - Method in class com.ibm.streamsx.topology.logic.Identity: Returns the input value.
apply(Long) - Method in class com.ibm.streamsx.topology.streams.BeaconStreams.BeaconFunction
apply(C) - Method in class com.ibm.streamsx.topology.streams.CollectionStreams.FlattenCollection: Just returns the collection, TStream.multiTransform(Function) will actually perform the flattening.
apply(M) - Method in class com.ibm.streamsx.topology.streams.CollectionStreams.FlattenMap
applyAsInt(T) - Method in interface com.ibm.streamsx.topology.function.ToIntFunction: Apply the function to the tuple and return an int.
Artifact - Class in com.ibm.streamsx.rest.build: An object describing an IBM Streams build artifact.
Artifact() - Constructor for class com.ibm.streamsx.rest.build.Artifact
assertTesterType() - Method in class com.ibm.streamsx.topology.tester.junit.AbstractTestClass
asType(Class<T>) - Method in interface com.ibm.streamsx.topology.TStream: Return a strongly typed reference to this stream.
atLeastTupleCount(TStream<?>, long) - Method in interface com.ibm.streamsx.topology.tester.Tester: Return a condition that evaluates if stream has submitted at least expectedCount number of tuples.
AUTH_BASIC - Static variable in interface com.ibm.streamsx.rest.internal.RestUtils
AUTH_BEARER - Static variable in interface com.ibm.streamsx.rest.internal.RestUtils
autonomous() - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Return a stream matching this stream whose subsequent processing will execute in an autonomous region.
autonomous() - Method in interface com.ibm.streamsx.topology.TStream: Return a stream matching this stream whose subsequent processing will execute in an autonomous region.

B

BaseImage - Class in com.ibm.streamsx.rest.build: This class describes an image from the build pool.
beacon(TopologyElement) - Static method in class com.ibm.streamsx.topology.streams.BeaconStreams: Creates an infinite source stream of tuples with no delay between each tuple.
beacon(TopologyElement, long) - Static method in class com.ibm.streamsx.topology.streams.BeaconStreams: Creates a source stream of count tuples with no delay between each tuple.
BeaconFunction() - Constructor for class com.ibm.streamsx.topology.streams.BeaconStreams.BeaconFunction
BeaconStreams - Class in com.ibm.streamsx.topology.streams: Utilities for beacon streams.
BeaconStreams() - Constructor for class com.ibm.streamsx.topology.streams.BeaconStreams
BeaconStreams.BeaconFunction - Class in com.ibm.streamsx.topology.streams
BeaconTuple - Class in com.ibm.streamsx.topology.tuple: Tuple type issued by a beacon stream.
BeaconTuple(long) - Constructor for class com.ibm.streamsx.topology.tuple.BeaconTuple: Create a BeaconTuple with the current time.
BeaconTuple(long, long) - Constructor for class com.ibm.streamsx.topology.tuple.BeaconTuple: Create a BeaconTuple.
BiFunction<T1,T2,R> - Interface in com.ibm.streamsx.topology.function: A function that is passed two arguments and returns a value.
BLOB - Static variable in interface com.ibm.streamsx.topology.spl.SPLSchemas: SPL schema used by TStream<com.ibm.streams.operator.types.Blob> streams.
Build - Class in com.ibm.streamsx.rest.build: An object describing an IBM Streams build.
Build() - Constructor for class com.ibm.streamsx.rest.build.Build
build(File, String, JsonObject) - Method in interface com.ibm.streamsx.rest.StreamingAnalyticsService: Submit an archive to build against Streaming Analytics service.
BUILD_SERVICE_URL - Static variable in interface com.ibm.streamsx.topology.context.ContextProperties: Set URL for remote build service.
buildAndSubmitJob(File, JsonObject, String, JsonObject) - Method in interface com.ibm.streamsx.rest.StreamingAnalyticsService: Submit an archive to build and run on the Streaming Analytics service.
buildAndSubmitJob(File, JsonObject, String) - Method in interface com.ibm.streamsx.rest.StreamingAnalyticsService: Submit an archive to build and run on the Streaming Analytics service.
Builder - Class in com.ibm.streamsx.topology.spi.builder
Builder() - Constructor for class com.ibm.streamsx.topology.spi.builder.Builder
builder() - Method in class com.ibm.streamsx.topology.Topology
builder() - Method in interface com.ibm.streamsx.topology.TopologyElement: Get the underlying OperatorGraph.
BuildPool - Class in com.ibm.streamsx.rest.build: This class describes a build pool URL: /streams/rest/buildpools
BuildPool() - Constructor for class com.ibm.streamsx.rest.build.BuildPool
BuildService - Interface in com.ibm.streamsx.rest.build: Access to a IBM Streams build service.
BuildType - Enum in com.ibm.streamsx.rest.internal: Build types for the build service.

C

cancel() - Method in class com.ibm.streamsx.rest.Job: Cancels this job.
checkMaximumVersion(String, int...) - Method in class com.ibm.streamsx.topology.tester.junit.AbstractTestClass: Only run a test at a specific maximum version or lower.
checkMinimumVersion(String, int...) - Method in class com.ibm.streamsx.topology.tester.junit.AbstractTestClass: Only run a test at a specific minimum version or higher.
checkpointPeriod(long, TimeUnit) - Method in class com.ibm.streamsx.topology.Topology: Checkpoint the state of the graph periodically.
checkStatus(boolean) - Method in interface com.ibm.streamsx.rest.StreamingAnalyticsService: Check the status of this Streaming Analytics Service.
CollectionStreams - Class in com.ibm.streamsx.topology.streams: Utilities for streams tuples that are collections of values.
CollectionStreams() - Constructor for class com.ibm.streamsx.topology.streams.CollectionStreams
CollectionStreams.FlattenCollection<C extends java.util.Collection<T>,T> - Class in com.ibm.streamsx.topology.streams: Function that flattens a collection when passed to TStream.multiTransform(Function).
CollectionStreams.FlattenMap<M extends java.util.Map<K,V>,K,V> - Class in com.ibm.streamsx.topology.streams
colocate(Placeable<?>...) - Method in interface com.ibm.streamsx.topology.context.Placeable: Colocate this element with other topology elements so that at runtime they all execute within the same processing element (PE or operating system process).
colocate(Placeable<?>...) - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Colocate this element with other topology elements so that at runtime they all execute within the same processing element (PE or operating system process).
com.ibm.streamsx.rest - package com.ibm.streamsx.rest: Java bindings for the REST APIs of IBM Streams and Streaming Analytics service.
com.ibm.streamsx.rest.build - package com.ibm.streamsx.rest.build: Java binding for the Build REST APIs of IBM Cloud Pak for Data.
com.ibm.streamsx.rest.internal - package com.ibm.streamsx.rest.internal
com.ibm.streamsx.rest.internal.icp4d - package com.ibm.streamsx.rest.internal.icp4d
com.ibm.streamsx.topology - package com.ibm.streamsx.topology: Java application API for IBM Streams.
com.ibm.streamsx.topology.consistent - package com.ibm.streamsx.topology.consistent: At least once processing using consistent regions.
com.ibm.streamsx.topology.context - package com.ibm.streamsx.topology.context: Context for executing IBM Streams Java topologies.
com.ibm.streamsx.topology.context.local - package com.ibm.streamsx.topology.context.local
com.ibm.streamsx.topology.file - package com.ibm.streamsx.topology.file: File related streams.
com.ibm.streamsx.topology.function - package com.ibm.streamsx.topology.function: Classes that provide the mechanisms to implement functional transformations on streams.
com.ibm.streamsx.topology.inet - package com.ibm.streamsx.topology.inet: Network access to streaming data.
com.ibm.streamsx.topology.jobconfig - package com.ibm.streamsx.topology.jobconfig
com.ibm.streamsx.topology.json - package com.ibm.streamsx.topology.json: JSON streams.
com.ibm.streamsx.topology.logic - package com.ibm.streamsx.topology.logic: Utilities and implementations of functional logic.
com.ibm.streamsx.topology.messaging.kafka - package com.ibm.streamsx.topology.messaging.kafka: Support for integrating with the Apache Kafka messaging system http://kafka.apache.org.
com.ibm.streamsx.topology.messaging.mqtt - package com.ibm.streamsx.topology.messaging.mqtt: Support for integrating with the MQTT messaging system http://mqtt.org.
com.ibm.streamsx.topology.spi - package com.ibm.streamsx.topology.spi: SPI for adding extensions to the functional api.
com.ibm.streamsx.topology.spi.builder - package com.ibm.streamsx.topology.spi.builder
com.ibm.streamsx.topology.spi.runtime - package com.ibm.streamsx.topology.spi.runtime
com.ibm.streamsx.topology.spl - package com.ibm.streamsx.topology.spl: Integration between Streams SPL and Java applications.
com.ibm.streamsx.topology.streams - package com.ibm.streamsx.topology.streams: Utilities to create and transform streams.
com.ibm.streamsx.topology.tester - package com.ibm.streamsx.topology.tester: Support for testing of topologies.
com.ibm.streamsx.topology.tester.junit - package com.ibm.streamsx.topology.tester.junit
com.ibm.streamsx.topology.tester.spl - package com.ibm.streamsx.topology.tester.spl
com.ibm.streamsx.topology.tuple - package com.ibm.streamsx.topology.tuple: Interfaces for tuple types.
compareTo(BeaconTuple) - Method in class com.ibm.streamsx.topology.tuple.BeaconTuple
COMPILE_INSTALL_DIR - Static variable in interface com.ibm.streamsx.topology.context.ContextProperties: Override IBM Streams install directory for bundle compilation, defaults to $STREAMS_INSTALL.
complete(Tester, Condition<?>, long, TimeUnit) - Method in class com.ibm.streamsx.topology.tester.junit.AbstractTestClass: Test a topology that may run forever.
complete(StreamsContext<?>) - Method in interface com.ibm.streamsx.topology.tester.Tester: Submit the topology for this tester and wait for it to complete.
complete(StreamsContext<?>, Condition<?>, long, TimeUnit) - Method in interface com.ibm.streamsx.topology.tester.Tester: Submit the topology for this tester and wait for it to complete, or reach an end condition.
complete(StreamsContext<?>, Map<String, Object>, Condition<?>, long, TimeUnit) - Method in interface com.ibm.streamsx.topology.tester.Tester
completeAndTestStringOutput(StreamsContext<?>, TStream<?>, long, TimeUnit, String...) - Method in interface com.ibm.streamsx.topology.tester.Tester
completeAndTestStringOutput(StreamsContext<?>, Map<String, Object>, TStream<?>, long, TimeUnit, String...) - Method in interface com.ibm.streamsx.topology.tester.Tester
Condition<T> - Interface in com.ibm.streamsx.topology.tester: A test condition on a stream or application under test.
config(boolean) - Method in class com.ibm.streamsx.rest.internal.ICP4DAuthenticator
config(boolean, boolean) - Method in class com.ibm.streamsx.rest.internal.ICP4DAuthenticator
config(boolean) - Method in class com.ibm.streamsx.rest.internal.StandaloneAuthenticator: Configure the authenticator and create service definition information.
CONFIG - Static variable in interface com.ibm.streamsx.topology.context.JobProperties: Configuration for a submitted application.
CONFIG - Static variable in interface com.ibm.streamsx.topology.spi.builder.Properties.Graph: Graph wide configuration.
CONNECT_TIMEOUT_MILLISECONDS - Static variable in interface com.ibm.streamsx.rest.internal.RestUtils
connectTo(BOperatorInvocation, boolean, BInputPort) - Method in interface com.ibm.streamsx.topology.TStream: Internal method.
ConsistentRegionConfig - Class in com.ibm.streamsx.topology.consistent: Immutable consistent region configuration.
ConsistentRegionConfig() - Constructor for class com.ibm.streamsx.topology.consistent.ConsistentRegionConfig: Create a ConsistentRegionConfig.Trigger.OPERATOR_DRIVEN consistent region configuration.
ConsistentRegionConfig(int) - Constructor for class com.ibm.streamsx.topology.consistent.ConsistentRegionConfig: Create a ConsistentRegionConfig.Trigger.PERIODIC consistent region configuration.
ConsistentRegionConfig.Trigger - Enum in com.ibm.streamsx.topology.consistent: Defines how the drain-checkpoint cycle of a consistent region is triggered.
constants(List<T>) - Method in class com.ibm.streamsx.topology.Topology: Create a stream containing all the tuples in data.
consume(InputStream) - Method in interface com.ibm.streamsx.rest.internal.InputStreamConsumer: consumes the input stream.
Consumer<T> - Interface in com.ibm.streamsx.topology.function: A function that takes an argument and returns nothing.
contains(TStream<String>, String) - Static method in class com.ibm.streamsx.topology.streams.StringStreams: Create a filtered stream that contains String tuples containing a specific term.
contents(SPLStream) - Method in class com.ibm.streamsx.topology.tester.spl.ExpectedTuples: Create a condition for stream having the tuples ExpectedTuples.getTuples() in the same order.
ContextProperties - Interface in com.ibm.streamsx.topology.context: Properties that can be specified when submitting the topology to a context.
convert(Function<Tuple, T>) - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Convert SPL tuples into Java objects.
convertStream(TStream<T>, BiFunction<T, OutputTuple, OutputTuple>, StreamSchema) - Static method in class com.ibm.streamsx.topology.spl.SPLStreams: Convert a Stream to an SPLStream.
create(int, String) - Static method in exception com.ibm.streamsx.rest.RESTException: Customized exception that can provide more information on REST errors
createBasicAuth(JsonObject) - Static method in interface com.ibm.streamsx.rest.internal.RestUtils: Create an encoded Basic auth header for the given credentials.
createBasicAuth(String, String) - Static method in interface com.ibm.streamsx.rest.internal.RestUtils: Create an encoded Basic auth header for the given userName and authToken
createBearerAuth(String) - Static method in interface com.ibm.streamsx.rest.internal.RestUtils: Create an encoded Bearer auth header for the given token.
createBuild(String, JsonObject) - Method in interface com.ibm.streamsx.rest.build.BuildService: Submit an archive to build using the IBM Streams build service.
createCustomMetric(String, String, String, LongSupplier) - Method in interface com.ibm.streamsx.topology.function.FunctionContext: Create a custom metric.
createExecutor() - Static method in interface com.ibm.streamsx.rest.internal.RestUtils
createExecutor(boolean) - Static method in interface com.ibm.streamsx.rest.internal.RestUtils
createHttpClient() - Static method in interface com.ibm.streamsx.rest.internal.RestUtils
createHttpClient(boolean) - Static method in interface com.ibm.streamsx.rest.internal.RestUtils
createInstance(String, String, String) - Static method in class com.ibm.streamsx.rest.StreamsConnection: Create a connection to IBM Streams REST API.
createJobRun(JobDescription, String, JsonArray) - Method in interface com.ibm.streamsx.rest.internal.icp4d.ICP4DService: Creates a Job run for a job description
createJobRun(JobDescription, String, JsonArray) - Method in class com.ibm.streamsx.rest.internal.icp4d.ICP4DServiceImpl: Creates a Job run for a job description via REST.
createList(AbstractConnection, String, Class<A>) - Static method in class com.ibm.streamsx.rest.build.Element
createNullValue() - Static method in class com.ibm.streamsx.topology.spl.SPL: Create an SPL value wrapper object for an SPL null value.
createSubmissionParameter(Topology, String, Object, boolean) - Static method in class com.ibm.streamsx.topology.spl.SPL: Create a submission parameter with or without a default value.
createSubmissionParameter(String, Class<T>) - Method in class com.ibm.streamsx.topology.Topology: Create a submission parameter without a default value.
createSubmissionParameter(String, T) - Method in class com.ibm.streamsx.topology.Topology: Create a submission parameter with a default value.
createValue(T, Type.MetaType) - Static method in class com.ibm.streamsx.topology.spl.SPL: Create an SPL value wrapper object for the specified SPL MetaType.
csvCompressedReader(TStream<String>, StreamSchema, FileSPLStreams.Compression) - Static method in class com.ibm.streamsx.topology.spl.FileSPLStreams: Create an SPLStream using the spl.adapter::FileSource operator that reads CSV records from compressed files with names delivered by fileNames.
csvReader(TStream<String>, StreamSchema) - Static method in class com.ibm.streamsx.topology.spl.FileSPLStreams: Create an SPLStream using the spl.adapter::FileSource operator that reads CSV records from files with names delivered by fileNames.

D

DATA_DIRECTORY - Static variable in interface com.ibm.streamsx.topology.context.JobProperties: Location of the submitted application's data directory.
delete() - Method in class com.ibm.streamsx.rest.build.Build
delete() - Method in class com.ibm.streamsx.rest.build.Toolkit: Delete this toolkit in the build service.
Dependency(String, String) - Constructor for class com.ibm.streamsx.rest.build.Toolkit.Dependency
DeploymentSpace - Class in com.ibm.streamsx.rest.internal.icp4d: This class represents a Deployment space REST resource from the /v2/spaces API
DeploymentSpace() - Constructor for class com.ibm.streamsx.rest.internal.icp4d.DeploymentSpace
DeploymentSpace.Entity - Class in com.ibm.streamsx.rest.internal.icp4d: entity substructure
DeploymentSpace.MetaData - Class in com.ibm.streamsx.rest.internal.icp4d: metadata substructure
deserialize(TStream<String>) - Static method in class com.ibm.streamsx.topology.json.JSONStreams: Declare a stream of JSON objects from a stream of serialized JSON tuples.
deserialize(InputStream) - Method in interface com.ibm.streamsx.topology.spi.runtime.TupleSerializer
DeserializeJSON() - Constructor for class com.ibm.streamsx.topology.json.JSONStreams.DeserializeJSON
DirectoryWatcher - Class in com.ibm.streamsx.topology.file
DirectoryWatcher() - Constructor for class com.ibm.streamsx.topology.file.DirectoryWatcher
directoryWatcher(TopologyElement, String) - Static method in class com.ibm.streamsx.topology.file.FileStreams: Creates a stream of absolute newly created file names from watching directory.
DirectoryZipInputStream - Class in com.ibm.streamsx.rest.internal: Given a path to a directory, this class creates an InputStream containing the contents of the directory, zipped.
DirectoryZipInputStream() - Constructor for class com.ibm.streamsx.rest.internal.DirectoryZipInputStream
Domain - Class in com.ibm.streamsx.rest: An object describing an IBM Streams Domain
Domain() - Constructor for class com.ibm.streamsx.rest.Domain
download(File) - Method in class com.ibm.streamsx.rest.build.Artifact
drainTimeout(long) - Method in class com.ibm.streamsx.topology.consistent.ConsistentRegionConfig: Return a new configuration changing drainTimeout.

E

Element - Class in com.ibm.streamsx.rest.build: IBM Streams element.
Element() - Constructor for class com.ibm.streamsx.rest.build.Element
Element - Class in com.ibm.streamsx.rest: IBM Streams element.
Element() - Constructor for class com.ibm.streamsx.rest.Element
Element.ElementArray<E extends Element> - Class in com.ibm.streamsx.rest.build: internal usage to get the list of processing elements
ElementArray() - Constructor for class com.ibm.streamsx.rest.build.Element.ElementArray
endlessSource(Supplier<T>) - Method in class com.ibm.streamsx.topology.Topology: Declare an endless source stream.
endlessSourceN(Function<Long, T>) - Method in class com.ibm.streamsx.topology.Topology: Declare an endless source stream.
endLowLatency() - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Return a TStream that is no longer guaranteed to run in the same process as the calling stream.
endLowLatency() - Method in interface com.ibm.streamsx.topology.TStream: Return a TStream that is no longer guaranteed to run in the same process as the calling stream.
endParallel() - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Ends a parallel region by merging the channels into a single stream.
endParallel() - Method in interface com.ibm.streamsx.topology.TStream: Ends a parallel region by merging the channels into a single stream.
Entity() - Constructor for class com.ibm.streamsx.rest.internal.icp4d.DeploymentSpace.Entity
Entity() - Constructor for class com.ibm.streamsx.rest.internal.icp4d.JobDescription.Entity
equals(Object) - Method in class com.ibm.streamsx.topology.consistent.ConsistentRegionConfig
equals(Object) - Method in class com.ibm.streamsx.topology.tuple.BeaconTuple
equals(Object) - Method in class com.ibm.streamsx.topology.tuple.SimpleMessage
ExpectedTuples - Class in com.ibm.streamsx.topology.tester.spl: List of expected tuples.
ExpectedTuples(StreamSchema) - Constructor for class com.ibm.streamsx.topology.tester.spl.ExpectedTuples: Create an initially empty ExpectedTuples.

F

failed() - Method in interface com.ibm.streamsx.topology.tester.Condition: Has the condition failed.
FileSPLStreams - Class in com.ibm.streamsx.topology.spl: Creation of SPLStreams that relate to files.
FileSPLStreams() - Constructor for class com.ibm.streamsx.topology.spl.FileSPLStreams
FileSPLStreams.Compression - Enum in com.ibm.streamsx.topology.spl
FileStreams - Class in com.ibm.streamsx.topology.file: Utilities for file system related streams.
FileStreams() - Constructor for class com.ibm.streamsx.topology.file.FileStreams
filter(Predicate<Tuple>) - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Declare a new stream that filters tuples from this stream.
filter(Predicate<T>) - Method in interface com.ibm.streamsx.topology.TStream: Declare a new stream that filters tuples from this stream.
finalizeGraph(StreamsContext<?>) - Method in class com.ibm.streamsx.topology.Topology: Resolves the jar dependencies, sets the respective parameters.
first(BiFunction<T, U, R>) - Static method in class com.ibm.streamsx.topology.logic.Logic: Wrap a BiFunction instance that operators on a single value for the second parameter (type U) as a BiFunction that takes an List.
flatMap(Function<T, Iterable>) - Method in interface com.ibm.streamsx.topology.TStream: Declare a new stream that maps tuples from this stream into one or more (or zero) tuples of a different type U.
flatten(TStream<C>) - Static method in class com.ibm.streamsx.topology.streams.CollectionStreams: ' Flatten a stream containing collections into a stream containing the individual elements.
flattenArray(TStream<JSONObject>, String, String...) - Static method in class com.ibm.streamsx.topology.json.JSONStreams: Declare a stream that flattens an array present in the input tuple.
FlattenCollection() - Constructor for class com.ibm.streamsx.topology.streams.CollectionStreams.FlattenCollection
flattenMap(TStream<M>) - Static method in class com.ibm.streamsx.topology.streams.CollectionStreams
FlattenMap() - Constructor for class com.ibm.streamsx.topology.streams.CollectionStreams.FlattenMap
FORCE_REMOTE_BUILD - Static variable in interface com.ibm.streamsx.topology.context.ContextProperties: Flag to be supplied to force the compilation to occur on the build service associated with a Streaming Analytics service.
forEach(Consumer<T>) - Method in interface com.ibm.streamsx.topology.TStream: Sink (terminate) this stream.
fromPath(Path) - Static method in class com.ibm.streamsx.rest.internal.DirectoryZipInputStream: Create an InputStream from a directory, containing the contents of the directory, zipped.
fromProperties(Map<String, ? extends Object>) - Static method in class com.ibm.streamsx.topology.jobconfig.JobConfig: Create a JobConfig from a configuration map.
Function<T,R> - Interface in com.ibm.streamsx.topology.function: A function that is passed an argument and returns a value.
FunctionContainer - Interface in com.ibm.streamsx.topology.function: Container for a function executing in a IBM Streams application.
FunctionContext - Interface in com.ibm.streamsx.topology.function: Context for a function executing in a IBM Streams application.

G

get() - Method in interface com.ibm.streamsx.topology.function.Supplier
get() - Method in class com.ibm.streamsx.topology.logic.Value: Return the constant value.
getActiveVersion() - Method in class com.ibm.streamsx.rest.Instance: Gets information about the IBM Streams Installation that was used to start this instance
getApplication() - Method in class com.ibm.streamsx.rest.internal.icp4d.JobRunConfiguration: get the link to the SAB; note that the build is deleted when topology.keepArtifacts is not set to True.
getApplicationConfiguration(String) - Method in interface com.ibm.streamsx.topology.function.FunctionContainer: Get the application configuration specified by name.
getApplicationConsoleURL() - Method in class com.ibm.streamsx.rest.Instance: Streams application console URL.
getApplicationName() - Method in class com.ibm.streamsx.rest.Job: Gets the name of the streams processing application that this job is running
getArchitecture() - Method in class com.ibm.streamsx.rest.ActiveVersion
getArtifacts() - Method in class com.ibm.streamsx.rest.build.Build
getAsJson() - Method in class com.ibm.streamsx.rest.RESTErrorMessage: Gets the json object of this error message
getAsset_id() - Method in class com.ibm.streamsx.rest.internal.icp4d.JobDescription.MetaData
getAssetId() - Method in class com.ibm.streamsx.rest.internal.icp4d.JobDescription: Returns the asset_id of the job, something like "19561431-e6bd-4bfa-8f71-630821ed4e14" Convenience method for getMetadata().getAsset_id();
getAuthenticator() - Method in class com.ibm.streamsx.rest.StreamsConnection
getAuthorization() - Method in class com.ibm.streamsx.rest.internal.AbstractConnection: Returns the Authorization header without the Authorization: keyword.
getAuthorization() - Method in class com.ibm.streamsx.rest.internal.icp4d.ICP4DServiceImpl: Returns the Authorization header without the Authorization: keyword.
getBaseImages() - Method in interface com.ibm.streamsx.rest.build.BuildService: Gets a list of baseImages for EDGE applications available in the build service.
getBuildVersion() - Method in class com.ibm.streamsx.rest.ActiveVersion
getChannel() - Method in interface com.ibm.streamsx.topology.function.FunctionContext: Get the index of the parallel channel the function is on.
getComposite() - Method in class com.ibm.streamsx.rest.JobSubmitParameters
getConfig() - Method in class com.ibm.streamsx.topology.messaging.kafka.KafkaConsumer: Get the connector's KafkaConsumer configuration information.
getConfig() - Method in class com.ibm.streamsx.topology.messaging.kafka.KafkaProducer: Get the connector's KafkaProducer configuration information.
getConfig() - Method in class com.ibm.streamsx.topology.messaging.mqtt.MqttStreams: Get the connector's configuration information.
getConfig() - Method in class com.ibm.streamsx.topology.tester.junit.AbstractTestClass
getConfig() - Method in class com.ibm.streamsx.topology.Topology
getConfiguredHost() - Method in interface com.ibm.streamsx.topology.function.FunctionContainer: Get the host this container is executing on.
getContainer() - Method in interface com.ibm.streamsx.topology.function.FunctionContext: Get the container hosting a function
getCreationTime() - Method in class com.ibm.streamsx.rest.build.Build: Gets the time in milliseconds when this domain was created.
getCreationTime() - Method in class com.ibm.streamsx.rest.Domain: Gets the time in milliseconds when this domain was created.
getCreationTime() - Method in class com.ibm.streamsx.rest.Instance: Gets the time in milliseconds when this instance was created
getCreationUser() - Method in class com.ibm.streamsx.rest.build.Build: Gets the user ID that created this build.
getCreationUser() - Method in class com.ibm.streamsx.rest.Domain: Gets the user ID that created this instance.
getCreationUser() - Method in class com.ibm.streamsx.rest.Instance: Gets the user ID that created this instance
getCurrentWorkingPath() - Method in class com.ibm.streamsx.rest.ProcessingElement: Gets the current working path of the processing element
getCustomMetricNames() - Method in interface com.ibm.streamsx.topology.function.FunctionContext: Get the set of custom metric names created in this context.
getDataDirectory() - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig: Get the data directory.
getDefaultDomainId() - Static method in class com.ibm.streamsx.topology.context.StreamsContextFactory: Get the default Streams domain identifier.
getDefaultInstanceId() - Static method in class com.ibm.streamsx.topology.context.StreamsContextFactory: Get the default Streams instance identifier.
getDefaultStreamsInstall() - Static method in class com.ibm.streamsx.topology.context.StreamsContextFactory: Get the default Streams install location.
getDefaultTesterType() - Method in class com.ibm.streamsx.topology.tester.junit.AbstractTestClass
getDefaultTimeout() - Method in class com.ibm.streamsx.topology.tester.junit.AbstractTestClass
getDefaultValue() - Method in class com.ibm.streamsx.rest.JobSubmitParameters
getDependencies() - Method in class com.ibm.streamsx.rest.build.Toolkit: Gets a list of dependencies of this toolkit.
getDependencyResolver() - Method in class com.ibm.streamsx.topology.Topology: Internal use only.
getDescription() - Method in class com.ibm.streamsx.rest.internal.icp4d.DeploymentSpace.Entity
getDescription() - Method in class com.ibm.streamsx.rest.internal.icp4d.JobDescription.MetaData
getDescription() - Method in class com.ibm.streamsx.rest.Metric: Gets the description for this metric
getDirectory() - Method in class com.ibm.streamsx.topology.file.DirectoryWatcher
getDisplayName() - Method in class com.ibm.streamsx.rest.Resource: Get the display name for this resource.
getDomain() - Method in class com.ibm.streamsx.rest.Instance: Get the Streams domain for this instance.
getDomainId() - Method in interface com.ibm.streamsx.topology.function.FunctionContainer: Return the IBM Streams domain identifier for this container.
getDrainTimeout() - Method in class com.ibm.streamsx.topology.consistent.ConsistentRegionConfig: Get the drain timeout for this configuration.
getEditionName() - Method in class com.ibm.streamsx.rest.ActiveVersion
getElement() - Method in interface com.ibm.streamsx.rest.Result: Get the element associated with the request.
getEmbedded() - Static method in class com.ibm.streamsx.topology.context.StreamsContextFactory: Get an EMBEDDED context.
getEncoding() - Method in class com.ibm.streamsx.topology.file.TextFileReader
getEntity() - Method in class com.ibm.streamsx.rest.internal.icp4d.DeploymentSpace
getEntity() - Method in class com.ibm.streamsx.rest.internal.icp4d.JobDescription
getExecutor() - Method in class com.ibm.streamsx.rest.internal.AbstractConnection: access to the Executor.
getFailureReason() - Method in class com.ibm.streamsx.rest.build.Build
getFullProductVersion() - Method in class com.ibm.streamsx.rest.ActiveVersion
getGsonResponse(Executor, String, String) - Static method in interface com.ibm.streamsx.rest.internal.RestUtils: Gets a JSON response to an HTTP GET call
getGsonResponse(Executor, String, URL) - Static method in interface com.ibm.streamsx.rest.internal.RestUtils
getHealth() - Method in class com.ibm.streamsx.rest.Instance: Gets the summarized status of jobs in this instance
getHealth() - Method in class com.ibm.streamsx.rest.Job: Gets the health indicator for this job
getHealth() - Method in class com.ibm.streamsx.rest.ProcessingElement: Gets the health indicator for this processing element
getId() - Method in class com.ibm.streamsx.rest.build.Artifact: Gets the IBM Streams unique identifier for this build artifact.
getId() - Method in class com.ibm.streamsx.rest.build.BaseImage
getId() - Method in class com.ibm.streamsx.rest.build.Build: Gets the IBM Streams unique identifier for this build.
getId() - Method in class com.ibm.streamsx.rest.build.Toolkit: Gets the id of this toolkit.
getId() - Method in class com.ibm.streamsx.rest.Domain: Gets the IBM Streams unique identifier for this domain.
getId() - Method in class com.ibm.streamsx.rest.Instance: Gets the IBM Streams unique identifier for this instance
getId() - Method in class com.ibm.streamsx.rest.internal.icp4d.DeploymentSpace: Convenience method for getMetadata().getId().
getId() - Method in class com.ibm.streamsx.rest.internal.icp4d.DeploymentSpace.MetaData
getId() - Method in class com.ibm.streamsx.rest.Job: Gets the id of this job
getId() - Method in class com.ibm.streamsx.rest.ProcessingElement: Gets the id of this processing element
getId() - Method in class com.ibm.streamsx.rest.Resource: Get the unique Streams identifier for this resource.
getId() - Method in interface com.ibm.streamsx.rest.Result: Get the object identifier associated with the request.
getId() - Method in interface com.ibm.streamsx.topology.function.FunctionContainer: Get the runtime identifier for this container.
getImageDigest() - Method in class com.ibm.streamsx.rest.build.Artifact
getIndex() - Method in class com.ibm.streamsx.rest.build.Toolkit: Gets the index of this toolkit.
getIndexWithinJob() - Method in class com.ibm.streamsx.rest.Operator: Gets the index of this operator within the Job
getIndexWithinJob() - Method in class com.ibm.streamsx.rest.ProcessingElement: Gets the index of this processing element within the Job
getIndexWithinOperator() - Method in class com.ibm.streamsx.rest.InputPort: Gets the index of this input port within the Operator
getIndexWithinOperator() - Method in class com.ibm.streamsx.rest.OutputPort: Gets the index of this output port within the operator
getIndexWithinPE() - Method in class com.ibm.streamsx.rest.PEInputPort: Gets the index of this input port within the processing element
getIndexWithinPE() - Method in class com.ibm.streamsx.rest.PEOutputPort: Gets the index of this output port within the processing element
getInputPorts() - Method in class com.ibm.streamsx.rest.Operator: Gets a list of input ports for this operator
getInputPorts() - Method in class com.ibm.streamsx.rest.ProcessingElement: Gets a list of processing element input ports for this processing element
getInstance() - Method in class com.ibm.streamsx.rest.ResourceAllocation: Obtain the Instance this resource is allocated to.
getInstance() - Method in interface com.ibm.streamsx.rest.StreamingAnalyticsService: Gets the IBM Streams Instance object for the Streaming Analytics service.
getInstance(String) - Method in class com.ibm.streamsx.rest.StreamsConnection: Gets a specific instance identified by the instanceId at this IBM Streams connection
getInstanceId() - Method in interface com.ibm.streamsx.topology.function.FunctionContainer: Return the IBM Streams instance identifier for this container.
getInstances() - Method in class com.ibm.streamsx.rest.StreamsConnection: Gets a list of instances that are available to this IBM Streams connection
getInvocationName() - Method in interface com.ibm.streamsx.topology.context.Placeable: Return the invocation name of this element.
getIpAddress() - Method in class com.ibm.streamsx.rest.Resource: Get the IP address for this resource.
getJob(String) - Method in class com.ibm.streamsx.rest.Instance: Gets the Job for a given jobId in this instance
getJob() - Method in class com.ibm.streamsx.rest.internal.icp4d.JobDescription.Entity
getJobGroup() - Method in class com.ibm.streamsx.rest.Job: Gets the group this job belongs to
getJobGroup() - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig: Get the job group.
getJobId() - Method in class com.ibm.streamsx.rest.internal.icp4d.JobRunConfiguration
getJobId() - Method in interface com.ibm.streamsx.topology.function.FunctionContainer: Get the runtime identifier for this container's running job.
getJobName() - Method in interface com.ibm.streamsx.topology.function.FunctionContainer: Return the name of this job.
getJobName() - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig: Get the job name.
getJobs() - Method in class com.ibm.streamsx.rest.Instance: Gets a list of jobs that this instance knows about
getJobs() - Method in class com.ibm.streamsx.rest.ResourceAllocation: Gets a list of jobs running on this resource in this instance.
getJobsRestUrl() - Method in interface com.ibm.streamsx.rest.internal.icp4d.ICP4DService: Returns the REST URl for the jobs REST API, for example https://host.com/v2/jobs
getJobsRestUrl() - Method in class com.ibm.streamsx.rest.internal.icp4d.ICP4DServiceImpl
getJSON(TopologyElement, String, long, TimeUnit) - Static method in class com.ibm.streamsx.topology.inet.HTTPStreams: Periodically poll a web service using HTTP GET for application/json data.
getJsonValue() - Method in enum com.ibm.streamsx.rest.internal.BuildType
getKey() - Method in class com.ibm.streamsx.topology.tuple.BeaconTuple: Get the key (sequence identifier) of this tuple.
getKey() - Method in interface com.ibm.streamsx.topology.tuple.Keyable: Returns the partition key for this tuple.
getKey() - Method in interface com.ibm.streamsx.topology.tuple.Message: Get the message key for this object.
getKey() - Method in class com.ibm.streamsx.topology.tuple.SimpleMessage
getLastTimeRetrieved() - Method in class com.ibm.streamsx.rest.Metric: Gets the Epoch time when the metric was most recently retrieved
getLaunchCount() - Method in class com.ibm.streamsx.rest.ProcessingElement: Gets the number of times this processing element was started manually or automatically because of failures
getLogicalName() - Method in class com.ibm.streamsx.rest.Operator: The logical name of this operator.
getLogMessages() - Method in class com.ibm.streamsx.rest.build.Build
getMaxChannels() - Method in interface com.ibm.streamsx.topology.function.FunctionContext: Get the total number of parallel channels for the parallel region that the function is in.
getMaxConsecutiveResetAttempts() - Method in class com.ibm.streamsx.topology.consistent.ConsistentRegionConfig: Get the maximum number of consecutive reset attempts.
getMessage() - Method in class com.ibm.streamsx.rest.RESTErrorMessage: Gets the error message
getMessage() - Method in interface com.ibm.streamsx.topology.tuple.Message: Get the message content for this object.
getMessage() - Method in class com.ibm.streamsx.topology.tuple.SimpleMessage
getMessageId() - Method in class com.ibm.streamsx.rest.RESTErrorMessage: Gets the id of this error message
getMetadata() - Method in class com.ibm.streamsx.rest.internal.icp4d.DeploymentSpace
getMetaData() - Method in class com.ibm.streamsx.rest.internal.icp4d.JobDescription
getMetricKind() - Method in class com.ibm.streamsx.rest.Metric: Describes the kind of metric that has been retrieved
getMetrics() - Method in class com.ibm.streamsx.rest.build.Build
getMetrics() - Method in class com.ibm.streamsx.rest.InputPort: Gets the metrics for this input port
getMetrics() - Method in class com.ibm.streamsx.rest.Operator: Gets a list of metrics for this operator
getMetrics() - Method in class com.ibm.streamsx.rest.OutputPort: Gets the metrics for this output port
getMetrics() - Method in class com.ibm.streamsx.rest.PEInputPort: Gets the metrics for this processing element input port
getMetrics() - Method in class com.ibm.streamsx.rest.PEOutputPort: Gets the metrics for this output port
getMetrics() - Method in class com.ibm.streamsx.rest.ProcessingElement: Gets a list of metrics for this processing element
getMetrics() - Method in class com.ibm.streamsx.rest.Resource: Gets the metrics for this resource.
getMetricType() - Method in class com.ibm.streamsx.rest.Metric: Describes the type of metric that has been retrieved
getMinimumOSBaseVersion() - Method in class com.ibm.streamsx.rest.ActiveVersion
getMinimumOSPatchVersion() - Method in class com.ibm.streamsx.rest.ActiveVersion
getMinimumOSVersion() - Method in class com.ibm.streamsx.rest.ActiveVersion
getName() - Method in class com.ibm.streamsx.rest.build.Artifact: Gets the name for this build artifact.
getName() - Method in class com.ibm.streamsx.rest.build.BaseImage
getName() - Method in class com.ibm.streamsx.rest.build.Build: Gets the name for this build.
getName() - Method in class com.ibm.streamsx.rest.build.BuildPool
getName() - Method in class com.ibm.streamsx.rest.build.Toolkit.Dependency: Gets the name of the dependent toolkit.
getName() - Method in class com.ibm.streamsx.rest.build.Toolkit: Gets the name of this toolkit.
getName() - Method in class com.ibm.streamsx.rest.InputPort: Gets the name for this input port
getName() - Method in class com.ibm.streamsx.rest.internal.icp4d.DeploymentSpace.Entity
getName() - Method in class com.ibm.streamsx.rest.internal.icp4d.DeploymentSpace: Convenience method for getEntity().getName().
getName() - Method in class com.ibm.streamsx.rest.internal.icp4d.JobDescription: Returns the name of the job.
getName() - Method in class com.ibm.streamsx.rest.internal.icp4d.JobDescription.MetaData
getName() - Method in class com.ibm.streamsx.rest.Job: Gets the name of this job
getName() - Method in class com.ibm.streamsx.rest.JobSubmitParameters
getName() - Method in class com.ibm.streamsx.rest.Metric: Gets the name of this metric
getName() - Method in class com.ibm.streamsx.rest.Operator: Name of this operator
getName() - Method in class com.ibm.streamsx.rest.OutputPort: Gets the name for this output port
getName() - Method in interface com.ibm.streamsx.rest.StreamingAnalyticsService: Get the service name.
getName() - Method in class com.ibm.streamsx.topology.jobconfig.SubmissionParameter
getName() - Method in class com.ibm.streamsx.topology.Topology: Name of this topology.
getNamespace() - Method in class com.ibm.streamsx.topology.Topology: Namespace of this topology.
getOperatorKind() - Method in class com.ibm.streamsx.rest.Operator: SPL primitive operator type for this operator
getOperators() - Method in class com.ibm.streamsx.rest.Job: Gets a list of operators for this job
getOperators() - Method in class com.ibm.streamsx.rest.ProcessingElement: Gets a list of operators for this processing element
getOptionalConnections() - Method in class com.ibm.streamsx.rest.ProcessingElement: Gets the status of optional connections for this processing element.
getOrCreateJobDescription(String, String, String) - Method in interface com.ibm.streamsx.rest.internal.icp4d.ICP4DService: Gets or creates a CP4D job description associated with either a project or a deployment space.
getOrCreateJobDescription(String, String, String) - Method in class com.ibm.streamsx.rest.internal.icp4d.ICP4DServiceImpl: Gets or creates a CP4D job description associated with either a project or a deployment space.
getOrCreateSpace(String) - Method in interface com.ibm.streamsx.rest.internal.icp4d.ICP4DService: Gets or creates a CP4D deployment space.
getOrCreateSpace(String) - Method in class com.ibm.streamsx.rest.internal.icp4d.ICP4DServiceImpl: Gets or creates a CP4D deployment space.
getOsCapabilities() - Method in class com.ibm.streamsx.rest.ProcessingElement: Gets a list of the operating system capabilities
getOutputPorts() - Method in class com.ibm.streamsx.rest.Operator: Gets a list of output ports for this operator
getOutputPorts() - Method in class com.ibm.streamsx.rest.ProcessingElement: Gets a list of processing element output ports for this processing element
getOverrideResourceLoadProtection() - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig
getOwner() - Method in class com.ibm.streamsx.rest.Instance: Gets the user ID that represents the owner of this instance
getOwner_id() - Method in class com.ibm.streamsx.rest.internal.icp4d.JobDescription.MetaData
getParameterKind() - Method in class com.ibm.streamsx.rest.JobSubmitParameters
getPath() - Method in class com.ibm.streamsx.rest.build.Toolkit: Gets the path to the toolkit on the build service.
getPE() - Method in class com.ibm.streamsx.rest.Operator: Get the PE for this operator.
getPendingTracingLevel() - Method in class com.ibm.streamsx.rest.ProcessingElement: Describes a pending change to the granularity of the trace information that is stored for this processing element.
getPeriod() - Method in class com.ibm.streamsx.topology.consistent.ConsistentRegionConfig: Get the trigger period.
getPes() - Method in class com.ibm.streamsx.rest.Instance: Gets a list of processing elements for this instance.
getPes() - Method in class com.ibm.streamsx.rest.Job: Gets a list of processing elements for this job
getPes() - Method in class com.ibm.streamsx.rest.ResourceAllocation: Gets a list of processing elements running on this resource in this instance.
getPrefix() - Method in class com.ibm.streamsx.rest.build.BaseImage
getPreloadApplicationBundles() - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig
getProcessId() - Method in class com.ibm.streamsx.rest.ProcessingElement: Gets the operating system process ID for this processing element
getProductName() - Method in class com.ibm.streamsx.rest.ActiveVersion
getProductVersion() - Method in class com.ibm.streamsx.rest.ActiveVersion
getProductVersion() - Method in class com.ibm.streamsx.rest.Instance: Gets the product version, please note that this is null for Streams version < 5.2
getProject_id() - Method in class com.ibm.streamsx.rest.internal.icp4d.JobDescription.MetaData
getRawResult() - Method in interface com.ibm.streamsx.rest.Result: Get the raw result from the request.
getRegistry() - Method in class com.ibm.streamsx.rest.build.BaseImage
getRelaunchCount() - Method in interface com.ibm.streamsx.topology.function.FunctionContainer: Return the number of times this container has been relaunched.
getRelocatable() - Method in class com.ibm.streamsx.rest.ProcessingElement: Indicates whether or not this processing element can be relocated to a different resource
getRequiredConnections() - Method in class com.ibm.streamsx.rest.ProcessingElement: Status of the required connections for this processing element.
getRequiredProductVersion() - Method in class com.ibm.streamsx.rest.build.Toolkit: Gets the minimum version of IBM Streams required to use this toolkit.
getResetTimeout() - Method in class com.ibm.streamsx.topology.consistent.ConsistentRegionConfig: Get the reset timeout for this configuration.
getResource() - Method in class com.ibm.streamsx.rest.ResourceAllocation: Obtain the Resource object for detailed information on the resource.
getResourceAllocation() - Method in class com.ibm.streamsx.rest.ProcessingElement: Gets the resource allocation for this processing element.
getResourceAllocations() - Method in class com.ibm.streamsx.rest.Instance: Gets a list of resource allocations for this instance.
getResourceAllocations() - Method in class com.ibm.streamsx.rest.Job: Gets a list of resource allocations for this job.
getResourceTags() - Method in class com.ibm.streamsx.rest.ProcessingElement: Gets a list of resource tags for this processing element
getResourceTags() - Method in interface com.ibm.streamsx.topology.context.Placeable: Get the set of resource tags this element requires.
getResourceType() - Method in class com.ibm.streamsx.rest.build.Toolkit: Identifies the Build REST resource type.
getResourceType() - Method in class com.ibm.streamsx.rest.InputPort: Identifies the REST resource type
getResourceType() - Method in class com.ibm.streamsx.rest.Instance: Identifies the REST resource type
getResourceType() - Method in class com.ibm.streamsx.rest.Job: Identifies the REST resource type
getResourceType() - Method in class com.ibm.streamsx.rest.Metric: Identifies the REST resource type
getResourceType() - Method in class com.ibm.streamsx.rest.Operator: Identifies the REST resource type
getResourceType() - Method in class com.ibm.streamsx.rest.OutputPort: Identifies the REST resource type
getResourceType() - Method in class com.ibm.streamsx.rest.PEInputPort: Identifies the REST resource type
getResourceType() - Method in class com.ibm.streamsx.rest.PEOutputPort: Identifies the REST resource type
getResourceType() - Method in class com.ibm.streamsx.rest.ProcessingElement: Identifies the REST resource type
getResourceType() - Method in class com.ibm.streamsx.rest.Resource: Identifies the REST resource type
getResourceType() - Method in class com.ibm.streamsx.rest.ResourceAllocation: Identifies the REST resource type
getResponseString(String) - Method in class com.ibm.streamsx.rest.internal.AbstractConnection: Gets a response to an HTTP call
getResponseString(Executor, String, String) - Static method in interface com.ibm.streamsx.rest.internal.RestUtils: Gets a response to an HTTP GET call as a string
getRestartable() - Method in class com.ibm.streamsx.rest.ProcessingElement: Indicates whether or not this processing element can be restarted
getRestid() - Method in class com.ibm.streamsx.rest.build.BaseImage
getRestid() - Method in class com.ibm.streamsx.rest.build.BuildPool
getResult() - Method in interface com.ibm.streamsx.rest.internal.InputStreamConsumer: Gets the Object created after consuming the InputStream
getResult() - Method in interface com.ibm.streamsx.topology.tester.Condition: Deprecated.
Since 1.11. In most distributed environments specific results cannot be obtained from conditions (such as stream contents) due to network isolation. While the condition will correct report its failed or valid state tests should no longer rely on using this method to perform additional testing. An alternative is to use stringTupleTester to perform a per-tuple check.
getScheduledExecutorService() - Method in interface com.ibm.streamsx.topology.function.FunctionContext: Return a scheduler to execute background tasks.
getSchedulerStatus() - Method in class com.ibm.streamsx.rest.ResourceAllocation: Status of the resource.
getSchema() - Method in interface com.ibm.streamsx.topology.spl.SPLStream: SPL schema of this stream.
getSchema() - Method in class com.ibm.streamsx.topology.tester.spl.ExpectedTuples: Get the schema of the tuples.
getSequence() - Method in class com.ibm.streamsx.topology.tuple.BeaconTuple: Get the sequence identifier of this tuple.
getSize() - Method in class com.ibm.streamsx.rest.build.Artifact
getSpace_id() - Method in class com.ibm.streamsx.rest.internal.icp4d.JobDescription.MetaData
getSpaceIdForName(String) - Method in interface com.ibm.streamsx.rest.internal.icp4d.ICP4DService: Gets the spaceId for a deployment space given by its name.
getSpaceIdForName(String) - Method in class com.ibm.streamsx.rest.internal.icp4d.ICP4DServiceImpl: Gets the spaceId for a deployment space given by its name.
getSpacesRestUrl() - Method in interface com.ibm.streamsx.rest.internal.icp4d.ICP4DService: Returns the REST URl for the spaces REST API, for example https://host.com/v2/spaces
getSpacesRestUrl() - Method in class com.ibm.streamsx.rest.internal.icp4d.ICP4DServiceImpl
getStartedBy() - Method in class com.ibm.streamsx.rest.Job: Identifies the user ID that started this job
getStartTime() - Method in class com.ibm.streamsx.rest.Instance: Gets the time in milliseconds when the instance was started.
getStatus() - Method in class com.ibm.streamsx.rest.build.Build: Gets the status of the build.
getStatus() - Method in class com.ibm.streamsx.rest.Domain: Gets the status of the domain.
getStatus() - Method in class com.ibm.streamsx.rest.Instance: Gets the status of the instance
getStatus() - Method in class com.ibm.streamsx.rest.Job: Describes the status of this job
getStatus() - Method in class com.ibm.streamsx.rest.ProcessingElement: Gets the status of this processing element
getStatus() - Method in class com.ibm.streamsx.rest.Resource: Status of the resource.
getStatus() - Method in class com.ibm.streamsx.rest.ResourceAllocation: Scheduler status of the resource.
getStatusCode() - Method in exception com.ibm.streamsx.rest.RESTException: Gets the error status code for this exception
getStatusReason() - Method in class com.ibm.streamsx.rest.ProcessingElement: Gets additional status for this processing element
getStream() - Method in interface com.ibm.streamsx.topology.spl.SPLInput
getStream() - Method in interface com.ibm.streamsx.topology.spl.SPLWindow: SPL stream for this window.
getStream() - Method in interface com.ibm.streamsx.topology.TWindow: Get this window's stream.
getStreamName() - Method in class com.ibm.streamsx.rest.OutputPort: Identifies the name of the output stream associated with this output port
getStreamsConnection() - Method in class com.ibm.streamsx.rest.Element
getStreamsContext(String) - Static method in class com.ibm.streamsx.topology.context.StreamsContextFactory: Get a StreamsContext from its type name.
getStreamsContext(StreamsContext.Type) - Static method in class com.ibm.streamsx.topology.context.StreamsContextFactory: Get a StreamsContext from its type.
getStreamsErrorMessageAsJson() - Method in exception com.ibm.streamsx.rest.RESTException: Gets the IBM Streams message for this exception as a Json Object
getStreamsErrorMessageId() - Method in exception com.ibm.streamsx.rest.RESTException: Gets the IBM Streams message ID for this exception
getStreamsInstance() - Method in class com.ibm.streamsx.rest.internal.icp4d.JobRunConfiguration: Returns the Streams instance name
getStreamsTracing() - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig
getSubmissionParameters() - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig: Get the submission parameters.
getSubmitParameters() - Method in class com.ibm.streamsx.rest.Job: Gets the list of parameters that were submitted to this job
getSubmitTime() - Method in class com.ibm.streamsx.rest.Job: Gets the Epoch time when this job was submitted
getTag() - Method in class com.ibm.streamsx.rest.build.BaseImage
getTester() - Method in class com.ibm.streamsx.topology.Topology: Get the tester for this topology.
getTesterContext() - Method in class com.ibm.streamsx.topology.tester.junit.AbstractTestClass: Return the default context for tests.
getTesterType() - Method in class com.ibm.streamsx.topology.tester.junit.AbstractTestClass
getThreadFactory() - Method in interface com.ibm.streamsx.topology.function.FunctionContext: Return a ThreadFactory that can be used by the function with the thread context class loader set correctly.
getTime() - Method in class com.ibm.streamsx.topology.tuple.BeaconTuple: Get the time of this tuple.
getTimeUnit() - Method in class com.ibm.streamsx.topology.consistent.ConsistentRegionConfig: Get the time unit for ConsistentRegionConfig.getPeriod(), ConsistentRegionConfig.getDrainTimeout() and ConsistentRegionConfig.getResetTimeout()().
getToolkit(String) - Method in interface com.ibm.streamsx.rest.build.BuildService: Gets a toolkit installed on the IBM Streams build service.
getToolkits() - Method in class com.ibm.streamsx.rest.build.BuildPool
getToolkits() - Method in interface com.ibm.streamsx.rest.build.BuildService: Gets a list of toolkits installed on the IBM Streams build service.
getTopic() - Method in interface com.ibm.streamsx.topology.tuple.Message: Get the message topic for this object.
getTopic() - Method in class com.ibm.streamsx.topology.tuple.SimpleMessage
getTopology() - Method in interface com.ibm.streamsx.topology.tester.Tester: Get the topology for this tester.
getTracing() - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig
getTracingLevel() - Method in class com.ibm.streamsx.rest.ProcessingElement: Gets the granularity of the tracing level for this processing element
getTransportType() - Method in class com.ibm.streamsx.rest.PEInputPort: Gets the transport type for this processing element input port
getTransportType() - Method in class com.ibm.streamsx.rest.PEOutputPort: Gets the transport type for this processing element output port
getTrigger() - Method in class com.ibm.streamsx.topology.consistent.ConsistentRegionConfig: Get the trigger type.
getTupleClass() - Method in interface com.ibm.streamsx.topology.TStream: Class of the tuples on this stream, if known.
getTupleClass() - Method in interface com.ibm.streamsx.topology.TWindow: Class of the tuples in this window.
getTuples() - Method in class com.ibm.streamsx.topology.tester.spl.ExpectedTuples: Get the expected tuples.
getTupleType() - Method in interface com.ibm.streamsx.topology.TStream: Type of the tuples on this stream.
getTupleType() - Method in interface com.ibm.streamsx.topology.TWindow: Type of the tuples in this window.
getType() - Method in class com.ibm.streamsx.rest.build.BuildPool
getType() - Method in interface com.ibm.streamsx.topology.context.StreamsContext: The type of this context.
getUriPath() - Method in class com.ibm.streamsx.rest.internal.icp4d.DeploymentSpace: Convenience method for getMetadata().getUrl().
getURL() - Method in class com.ibm.streamsx.rest.build.Artifact
getUrl() - Method in class com.ibm.streamsx.rest.internal.icp4d.DeploymentSpace.MetaData
getValue() - Method in class com.ibm.streamsx.rest.JobSubmitParameters
getValue() - Method in class com.ibm.streamsx.rest.Metric: Gets the value for this metric
getValue() - Method in class com.ibm.streamsx.topology.jobconfig.SubmissionParameter
getValues() - Method in class com.ibm.streamsx.rest.JobSubmitParameters
getVersion() - Method in class com.ibm.streamsx.rest.build.Toolkit.Dependency: Gets the range of versions of the dependent toolkit.
getVersion() - Method in class com.ibm.streamsx.rest.build.Toolkit: Gets the version of this toolkit.
getVersion() - Method in class com.ibm.streamsx.rest.internal.icp4d.JobDescription.MetaData
getZooKeeperConnectionString() - Method in class com.ibm.streamsx.rest.Domain: Gets the ZooKeeper connection string for this domain.
graph(Topology) - Static method in class com.ibm.streamsx.topology.spi.builder.Builder
GROUP - Static variable in interface com.ibm.streamsx.topology.context.JobProperties: Group name for a submitted application.
group(JsonObject, String, String, String) - Static method in class com.ibm.streamsx.topology.spi.builder.LayoutInfo: Provide a hint that that an operator invocation should be grouped with other operator invocations.
group(JsonObject, JsonObject...) - Static method in class com.ibm.streamsx.topology.spi.builder.LayoutInfo: Group multiple operators together.
gsonFromResponse(HttpResponse) - Static method in interface com.ibm.streamsx.rest.internal.RestUtils

H

hashCode() - Method in class com.ibm.streamsx.topology.consistent.ConsistentRegionConfig
hashCode() - Method in class com.ibm.streamsx.topology.tuple.BeaconTuple
hashCode() - Method in class com.ibm.streamsx.topology.tuple.SimpleMessage
hasSubmissionParameters() - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig: Have any submission parameters been added.
hasTester() - Method in class com.ibm.streamsx.topology.Topology: Has the tester been created for this topology.
HEXES - Static variable in interface com.ibm.streamsx.rest.internal.RestUtils
HEXES_L - Static variable in interface com.ibm.streamsx.rest.internal.RestUtils
hide(JsonObject) - Static method in class com.ibm.streamsx.topology.spi.builder.LayoutInfo: Provide a hint that the operator invocation should be hidden.
HTTPStreams - Class in com.ibm.streamsx.topology.inet: Access to data in web servers or services using HTTP.
HTTPStreams() - Constructor for class com.ibm.streamsx.topology.inet.HTTPStreams

I

ICP4DAuthenticator - Class in com.ibm.streamsx.rest.internal: Authenticator for access of CP4D.
ICP4DService - Interface in com.ibm.streamsx.rest.internal.icp4d: Represents the REST service of the ICP4D platform.
ICP4DServiceImpl - Class in com.ibm.streamsx.rest.internal.icp4d: Abstracts the REST API of the CP4D.
ICP4DServiceImpl(JsonObject, boolean, Function<Executor, String>) - Constructor for class com.ibm.streamsx.rest.internal.icp4d.ICP4DServiceImpl
identifyStreamsxMessagingVer() - Static method in class com.ibm.streamsx.topology.messaging.kafka.Util
Identity<T> - Class in com.ibm.streamsx.topology.logic: Identity unary function that returns its input.
Identity() - Constructor for class com.ibm.streamsx.topology.logic.Identity
identity() - Static method in class com.ibm.streamsx.topology.logic.Logic
Initializable - Interface in com.ibm.streamsx.topology.function: Optional interface that a function can implement to perform initialization.
initialize(OperatorContext) - Method in class com.ibm.streamsx.topology.file.DirectoryWatcher
initialize(OperatorContext) - Method in class com.ibm.streamsx.topology.file.TextFileReader
initialize(FunctionContext) - Method in interface com.ibm.streamsx.topology.function.Initializable: Initialize this function.
InputPort - Class in com.ibm.streamsx.rest: An Input Port of the IBM Streams Operator
InputPort() - Constructor for class com.ibm.streamsx.rest.InputPort
InputStreamConsumer<T> - Interface in com.ibm.streamsx.rest.internal: This class implements a handler that consumes the input stream of a streaming REST response.
Instance - Class in com.ibm.streamsx.rest: An object describing an IBM Streams Instance
Instance() - Constructor for class com.ibm.streamsx.rest.Instance
invocationName(String) - Method in interface com.ibm.streamsx.topology.context.Placeable: Set the invocation name of this placeable.
invocationName(String) - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Set the invocation name of this placeable.
invokeForEach(TStream<T>, String, JsonObject, Consumer<T>, TupleSerializer, Map<String, Object>) - Static method in interface com.ibm.streamsx.topology.spi.builder.Invoker: Invoke a functional for each operator consuming a single stream.
invokeJavaPrimitive(Class<? extends Operator>, SPLInput, StreamSchema, Map<String, ? extends Object>) - Static method in class com.ibm.streamsx.topology.spl.JavaPrimitive: Create an SPLStream from the invocation of an SPL Java primitive operator with a single input port & output port.
invokeJavaPrimitive(TopologyElement, Class<? extends Operator>, List<? extends SPLInput>, List<StreamSchema>, Map<String, ? extends Object>) - Static method in class com.ibm.streamsx.topology.spl.JavaPrimitive: Invoke an SPL Java primitive operator with an arbitrary number of input and output ports.
invokeJavaPrimitiveSink(Class<? extends Operator>, SPLInput, Map<String, ? extends Object>) - Static method in class com.ibm.streamsx.topology.spl.JavaPrimitive: Invocation of a Java primitive operator that consumes a Stream.
invokeJavaPrimitiveSource(TopologyElement, Class<? extends Operator>, StreamSchema, Map<String, ? extends Object>) - Static method in class com.ibm.streamsx.topology.spl.JavaPrimitive: Invocation of a Java primitive source operator to produce a SPL Stream.
invokeOperator(String, SPLInput, StreamSchema, Map<String, ? extends Object>) - Static method in class com.ibm.streamsx.topology.spl.SPL: Create an SPLStream from the invocation of an SPL operator that consumes a stream.
invokeOperator(String, String, SPLInput, StreamSchema, Map<String, ? extends Object>) - Static method in class com.ibm.streamsx.topology.spl.SPL: Create an SPLStream from the invocation of an SPL operator that consumes a stream and produces a stream.
invokeOperator(TopologyElement, String, String, List<? extends SPLInput>, List<StreamSchema>, Map<String, ? extends Object>) - Static method in class com.ibm.streamsx.topology.spl.SPL: Invoke an SPL operator with an arbitrary number of input and output ports.
invokePipe(String, TStream<T>, JsonObject, Consumer<T>, Type, TupleSerializer, TupleSerializer, Map<String, Object>) - Static method in interface com.ibm.streamsx.topology.spi.builder.Invoker: Invoke a functional map operator consuming a single input stream and producing a single output stream.
invokePrimitive(TopologyElement, String, List<TStream<?>>, JsonObject, ObjIntConsumer<Object>, List<Type>, List<TupleSerializer>, List<TupleSerializer>, Map<String, Object>) - Static method in interface com.ibm.streamsx.topology.spi.builder.Invoker: Invoke a functional operator consuming an arbitrary number of input streams and producing an arbitrary number of output streams.
Invoker - Interface in com.ibm.streamsx.topology.spi.builder: This is part of the SPI to allow additional functional style functionality to built using the primitives provided by this toolkit.
invokeSink(String, SPLInput, Map<String, ? extends Object>) - Static method in class com.ibm.streamsx.topology.spl.SPL: Invocation an SPL operator that consumes a Stream.
invokeSink(String, String, SPLInput, Map<String, ? extends Object>) - Static method in class com.ibm.streamsx.topology.spl.SPL: Invocation an SPL operator that consumes a Stream.
invokeSource(Topology, String, JsonObject, Supplier<Iterable<T>>, Type, TupleSerializer, Map<String, Object>) - Static method in interface com.ibm.streamsx.topology.spi.builder.Invoker: Invoke a functional source operator that generates a single stream.
invokeSource(TopologyElement, String, Map<String, Object>, StreamSchema) - Static method in class com.ibm.streamsx.topology.spl.SPL: Invocation an SPL source operator to produce a Stream.
isApplicationResource() - Method in class com.ibm.streamsx.rest.ResourceAllocation: Indicates whether the resource is an application resource.
isExternalClient() - Method in interface com.ibm.streamsx.rest.internal.icp4d.ICP4DService: true if the client is external to the CP4D, false otherwise.
isExternalClient() - Method in class com.ibm.streamsx.rest.internal.icp4d.ICP4DServiceImpl: true if the client is external to the CP4D.
isKeyed() - Method in interface com.ibm.streamsx.topology.TWindow: Is the window keyed.
isOk() - Method in interface com.ibm.streamsx.rest.Result: Was the request successful.
isolate() - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Return a stream whose immediate subsequent processing will execute in a separate operating system process from this stream's processing.
isolate() - Method in interface com.ibm.streamsx.topology.TStream: Return a stream whose immediate subsequent processing will execute in a separate operating system process from this stream's processing.
isPlaceable() - Method in interface com.ibm.streamsx.topology.context.Placeable: Can this element have placement directives applied to it.
isProductVersionAtLeast(int, int) - Method in class com.ibm.streamsx.rest.Instance: Tests if the instance has a minimum major.minor product version.
isRequired() - Method in class com.ibm.streamsx.rest.JobSubmitParameters
isStreamsJob() - Method in class com.ibm.streamsx.rest.internal.icp4d.JobDescription: returns true, if the asset_ref_type of the entity is "streams", i.e.
isSupported(Topology) - Method in interface com.ibm.streamsx.topology.context.StreamsContext: Answers if this StreamsContext supports execution of the topology.
isVerify() - Method in class com.ibm.streamsx.rest.StreamsConnection

J

JAVA_OPS - Static variable in interface com.ibm.streamsx.topology.spi.builder.Properties.Graph.Config: JsonObject mapping operator kind to Java class name.
JAVA_SERIALIZER - Static variable in interface com.ibm.streamsx.topology.spi.runtime.TupleSerializer
JavaPrimitive - Class in com.ibm.streamsx.topology.spl: Integration between Java topologies and SPL Java primitive operators.
JavaPrimitive() - Constructor for class com.ibm.streamsx.topology.spl.JavaPrimitive
Job - Class in com.ibm.streamsx.rest: An object describing an IBM Streams Job submitted within a specified instance
Job() - Constructor for class com.ibm.streamsx.rest.Job
JOB_SUBMISSION - Static variable in interface com.ibm.streamsx.topology.context.ResultProperties: Result of a successful job submission as a JSON object.
JobConfig - Class in com.ibm.streamsx.topology.jobconfig: A job configuration.
JobConfig() - Constructor for class com.ibm.streamsx.topology.jobconfig.JobConfig: An empty job configuration.
JobConfig(String, String) - Constructor for class com.ibm.streamsx.topology.jobconfig.JobConfig: Job configuration with a job name and group.
JobDescription - Class in com.ibm.streamsx.rest.internal.icp4d: This class represents a Job REST resource from the /v2/jobs API of the CP4D.
JobDescription() - Constructor for class com.ibm.streamsx.rest.internal.icp4d.JobDescription
JobDescription.Entity - Class in com.ibm.streamsx.rest.internal.icp4d: entity substructure "entity": { "job": { "asset_ref_type": "streams", "configuration": { "application": "https://cluster.ip/v2/asset_files/jobs/19561431-e6bd-4bfa-8f71-630821ed4e14/View.ConflictingAttributes.sab?space_id=66d50216-6048-4619-81cc-a2f38fa70fdb", "env_type": "streams", "env_variables": [], "streamsInstance": "sample-streams" }, "last_run_initiator": "None", "last_run_status": "None", "last_run_status_timestamp": 0, "last_run_time": "", "space_name": "sample-streams.nbgr55" } }
JobDescription.MetaData - Class in com.ibm.streamsx.rest.internal.icp4d: metadata sub-structure "metadata": { "asset_id": "19561431-e6bd-4bfa-8f71-630821ed4e14", "description": "jobs for test", "name": "python job", "owner_id": "1000330999", "version": 0 }
JobProperties - Interface in com.ibm.streamsx.topology.context: Job properties specific to distributed contexts.
JobRunConfiguration - Class in com.ibm.streamsx.rest.internal.icp4d: This class represents an entity->configuration object of a JobRun REST resource from the /v2/jobs API of the CP4D.
JobRunConfiguration() - Constructor for class com.ibm.streamsx.rest.internal.icp4d.JobRunConfiguration
JobSubmitParameters - Class in com.ibm.streamsx.rest: Holds Submisson Paramters for a Job
JobSubmitParameters() - Constructor for class com.ibm.streamsx.rest.JobSubmitParameters
join(TWindow<U, ?>, BiFunction<T, List, J>) - Method in interface com.ibm.streamsx.topology.TStream: Join this stream with window of type U.
join(Function<T, K>, TWindow<U, K>, BiFunction<T, List, J>) - Method in interface com.ibm.streamsx.topology.TStream: Join this stream with a partitioned window of type U with key type K.
joinLast(Function<? super T, ? extends K>, TStream, Function<? super U, ? extends K>, BiFunction<T, U, J>) - Method in interface com.ibm.streamsx.topology.TStream: Join this stream with the last tuple seen on a stream of type U with partitioning.
joinLast(TStream, BiFunction<T, U, J>) - Method in interface com.ibm.streamsx.topology.TStream: Join this stream with the last tuple seen on a stream of type U.
JSON - Static variable in interface com.ibm.streamsx.topology.json.JSONSchemas: IBM Streams schema used for streams with JSON data.
JSON - Static variable in interface com.ibm.streamsx.topology.spl.SPLSchemas: SPL schema used to publish and subscribe to TStream<JSONObject> streams.
JSONAble - Interface in com.ibm.streamsx.topology.tuple
JSONSchemas - Interface in com.ibm.streamsx.topology.json: SPL schema for JSON.
JSONStreams - Class in com.ibm.streamsx.topology.json: Utilities for JSON streams.
JSONStreams() - Constructor for class com.ibm.streamsx.topology.json.JSONStreams
JSONStreams.DeserializeJSON - Class in com.ibm.streamsx.topology.json: Function to deserialize a String to a JSONObject.
JSONStreams.SerializeJSON - Class in com.ibm.streamsx.topology.json: Function to serialize a JSONObject to a String.
JSONStreams.ToJSON<T extends JSONAble> - Class in com.ibm.streamsx.topology.json: Function to convert a JSONAble tuple to a JSONObject, using JSONAble.toJSON().

K

KafkaConsumer - Class in com.ibm.streamsx.topology.messaging.kafka: A simple connector to an Apache Kafka cluster for consuming Kafka messages -- subscribing to Kafka topics and creating a TStream<Message>.
KafkaConsumer(TopologyElement, Map<String, Object>) - Constructor for class com.ibm.streamsx.topology.messaging.kafka.KafkaConsumer: Create a consumer connector for subscribing to topics.
KafkaProducer - Class in com.ibm.streamsx.topology.messaging.kafka: A simple connector to an Apache Kafka cluster for producing Kafka messages -- publishing a TStream<Message> to Kafka topics.
KafkaProducer(TopologyElement, Map<String, Object>) - Constructor for class com.ibm.streamsx.topology.messaging.kafka.KafkaProducer: Create a producer connector for publishing tuples.
KEEP_ARTIFACTS - Static variable in interface com.ibm.streamsx.topology.context.ContextProperties: Keep any intermediate artifacts.
key(Function<? super T, ? extends U>) - Method in interface com.ibm.streamsx.topology.TWindow: Return a keyed (partitioned) window that has the same configuration as this window with the each tuple's key defined by a function.
key() - Method in interface com.ibm.streamsx.topology.TWindow: Return a keyed (partitioned) window that has the same configuration as this window with each tuple being the key.
Keyable<K> - Interface in com.ibm.streamsx.topology.tuple: A tuple that has a partition key.
kind(JsonObject, String) - Static method in class com.ibm.streamsx.topology.spi.builder.LayoutInfo: Provide a hint that the operator invocation kind should be set to kind instead of its SPL kind.

L

last(long, TimeUnit) - Method in interface com.ibm.streamsx.topology.TStream: Declare a TWindow that continually represents the last time seconds of tuples (in the given time unit) on this stream.
last(Supplier<Integer>) - Method in interface com.ibm.streamsx.topology.TStream: Declare a TWindow that continually represents the last count tuples seen on this stream.
last(int) - Method in interface com.ibm.streamsx.topology.TStream: Declare a TWindow that continually represents the last count tuples seen on this stream.
last() - Method in interface com.ibm.streamsx.topology.TStream: Declare a TWindow that continually represents the last tuple on this stream.
lastSeconds(Supplier<Integer>) - Method in interface com.ibm.streamsx.topology.TStream: Declare a TWindow that continually represents the last time seconds of tuples on this stream.
LayoutInfo - Class in com.ibm.streamsx.topology.spi.builder: Layout hints for the Streams console.
LayoutInfo() - Constructor for class com.ibm.streamsx.topology.spi.builder.LayoutInfo
limitedSource(Supplier<T>, long) - Method in class com.ibm.streamsx.topology.Topology: Declare a limited source stream, where the number of tuples is limited to count.
limitedSourceN(Function<Long, T>, long) - Method in class com.ibm.streamsx.topology.Topology: Declare a limited source stream, where the number of tuples is limited to count.
Logic - Class in com.ibm.streamsx.topology.logic
Logic() - Constructor for class com.ibm.streamsx.topology.logic.Logic
longBeacon(TopologyElement) - Static method in class com.ibm.streamsx.topology.streams.BeaconStreams: Creates an infinite source stream of count tuples with no delay between each tuple.
longBeacon(TopologyElement, long) - Static method in class com.ibm.streamsx.topology.streams.BeaconStreams: Creates a source stream of count tuples with no delay between each tuple.
lowLatency() - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Return a stream that is guaranteed to run in the same process as the calling TStream.
lowLatency() - Method in interface com.ibm.streamsx.topology.TStream: Return a stream that is guaranteed to run in the same process as the calling TStream.

M

main(String[]) - Static method in class com.ibm.streamsx.topology.context.local.StreamsContextSubmit
map(Function<T, U>) - Method in interface com.ibm.streamsx.topology.TStream: Declare a new stream that maps each tuple from this stream into one (or zero) tuple of a different type U.
maxConsecutiveResetAttempts(int) - Method in class com.ibm.streamsx.topology.consistent.ConsistentRegionConfig: Return a new configuration changing maxConsecutiveResetAttempts.
MEMBER_PASSWORD - Static variable in interface com.ibm.streamsx.rest.internal.RestUtils
MEMBER_USERID - Static variable in interface com.ibm.streamsx.rest.internal.RestUtils
Message - Interface in com.ibm.streamsx.topology.tuple: An interface for tuple attributes common to messaging adapters in com.ibm.streamsx.topology.messaging.
MetaData() - Constructor for class com.ibm.streamsx.rest.internal.icp4d.DeploymentSpace.MetaData
MetaData() - Constructor for class com.ibm.streamsx.rest.internal.icp4d.JobDescription.MetaData
Metric - Class in com.ibm.streamsx.rest: An object describing an IBM Streams Metric
Metric() - Constructor for class com.ibm.streamsx.rest.Metric
modify(UnaryOperator<Tuple>) - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Declare a new stream that modifies each tuple from this stream into one (or zero) tuple of the same type T.
modify(UnaryOperator<T>) - Method in interface com.ibm.streamsx.topology.TStream: Declare a new stream that modifies each tuple from this stream into one (or zero) tuple of the same type T.
MqttStreams - Class in com.ibm.streamsx.topology.messaging.mqtt: 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.
MqttStreams(TopologyElement, Map<String, Object>) - Constructor for class com.ibm.streamsx.topology.messaging.mqtt.MqttStreams: Create a MQTT connector for publishing tuples to topics subscribing to topics.
multiTransform(Function<T, Iterable>) - Method in interface com.ibm.streamsx.topology.TStream: Declare a new stream that maps tuples from this stream into one or more (or zero) tuples of a different type U.

N

NAME - Static variable in interface com.ibm.streamsx.topology.context.JobProperties: Name for a submitted application.
newTopology() - Method in class com.ibm.streamsx.topology.tester.junit.AbstractTestClass
notKeyed() - Static method in class com.ibm.streamsx.topology.logic.Logic
numbers(Number...) - Method in class com.ibm.streamsx.topology.Topology: Create a stream of Number tuples.

O

ObjIntConsumer<T> - Interface in com.ibm.streamsx.topology.function
of(JsonObject, boolean) - Static method in interface com.ibm.streamsx.rest.internal.icp4d.ICP4DService: Creates a new ICP4DService instance from the service definition JSON object.
of(String, String, String, String) - Static method in class com.ibm.streamsx.rest.internal.ICP4DAuthenticator
of(JsonObject, boolean) - Static method in class com.ibm.streamsx.rest.internal.ICP4DAuthenticator
of(String, String, String) - Static method in class com.ibm.streamsx.rest.internal.StandaloneAuthenticator: Create an authenticator for a Cloud Pak for Data standalone configuration security service from an endpoint URL.
of(JsonObject) - Static method in class com.ibm.streamsx.rest.internal.StandaloneAuthenticator: Create an authenticator for a Cloud Pak for Data standalone configuration security service from a service definition.
of(JsonElement, String) - Static method in interface com.ibm.streamsx.rest.StreamingAnalyticsService: Access to a Streaming Analytics service from service name and VCAP services.
of(JsonObject) - Static method in interface com.ibm.streamsx.rest.StreamingAnalyticsService: Access to a Streaming Analytics service from a service definition.
of(T) - Static method in class com.ibm.streamsx.topology.logic.Value: Return a constant value Supplier.
ofAuthenticator(String, Function<Executor, String>) - Static method in class com.ibm.streamsx.rest.StreamsConnection
ofEndpoint(String, String, String, String, boolean) - Static method in interface com.ibm.streamsx.rest.build.BuildService
ofEndpoint(String, String, String, String) - Static method in class com.ibm.streamsx.rest.Instance: Connect to a Cloud Pak for Data IBM Streams instance.
ofEndpoint(String, String, String, String, boolean) - Static method in class com.ibm.streamsx.rest.Instance: Connect to a Cloud Pak for Data IBM Streams instance.
ofServiceDefinition(JsonObject, boolean) - Static method in interface com.ibm.streamsx.rest.build.BuildService
Operator - Class in com.ibm.streamsx.rest: An object describing an IBM Streams Operator
Operator() - Constructor for class com.ibm.streamsx.rest.Operator
operator() - Method in interface com.ibm.streamsx.topology.context.Placeable
operator() - Method in interface com.ibm.streamsx.topology.TSink: Internal method.
operatorDriven() - Static method in class com.ibm.streamsx.topology.consistent.ConsistentRegionConfig: Create a ConsistentRegionConfig.Trigger.OPERATOR_DRIVEN consistent region configuration.
output() - Method in interface com.ibm.streamsx.topology.TStream: Internal method.
OutputPort - Class in com.ibm.streamsx.rest: An Output Port of the IBM Streams Operator
OutputPort() - Constructor for class com.ibm.streamsx.rest.OutputPort
OVERRIDE_RESOURCE_LOAD_PROTECTION - Static variable in interface com.ibm.streamsx.topology.context.JobProperties: Optional override for a submitted application.

P

parallel(int) - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Parallelizes the stream into a a fixed number of parallel channels using round-robin distribution.
parallel(Supplier<Integer>, TStream.Routing) - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Parallelizes the stream into width parallel channels.
parallel(Supplier<Integer>, Function<Tuple, ?>) - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Parallelizes the stream into a number of parallel channels using key based distribution.
parallel(int) - Method in interface com.ibm.streamsx.topology.TStream: Parallelizes the stream into a a fixed number of parallel channels using round-robin distribution.
parallel(Supplier<Integer>) - Method in interface com.ibm.streamsx.topology.TStream: Parallelizes the stream into width parallel channels.
parallel(Supplier<Integer>, TStream.Routing) - Method in interface com.ibm.streamsx.topology.TStream: Parallelizes the stream into width parallel channels.
parallel(Supplier<Integer>, Function<T, ?>) - Method in interface com.ibm.streamsx.topology.TStream: Parallelizes the stream into a number of parallel channels using key based distribution.
PAYLOAD - Static variable in class com.ibm.streamsx.topology.json.JSONStreams: JSON key for arrays and values.
PEInputPort - Class in com.ibm.streamsx.rest: An Input Port of the IBM Streams Processing Element
PEInputPort() - Constructor for class com.ibm.streamsx.rest.PEInputPort
PEOutputPort - Class in com.ibm.streamsx.rest: A Output Port of the IBM Streams Processing Element
PEOutputPort() - Constructor for class com.ibm.streamsx.rest.PEOutputPort
periodic(int) - Static method in class com.ibm.streamsx.topology.consistent.ConsistentRegionConfig: Create a ConsistentRegionConfig.Trigger.PERIODIC consistent region configuration.
periodicMultiSource(Supplier<Iterable<T>>, long, TimeUnit) - Method in class com.ibm.streamsx.topology.Topology: Declare a new source stream that calls data.get() periodically.
periodicSource(Supplier<T>, long, TimeUnit) - Method in class com.ibm.streamsx.topology.Topology: Declare a new source stream that calls data.get() periodically.
Placeable<T extends Placeable<T>> - Interface in com.ibm.streamsx.topology.context: Placement directives for a topology element when executing in a distributed runtime.
Predicate<T> - Interface in com.ibm.streamsx.topology.function: A function that tests a tuple.
PRELOAD_APPLICATION_BUNDLES - Static variable in interface com.ibm.streamsx.topology.context.JobProperties: Optionally specify whether to preload the job onto all resources in the instance.
print() - Method in interface com.ibm.streamsx.topology.TStream: Print each tuple on System.out.
process() - Method in class com.ibm.streamsx.topology.file.DirectoryWatcher
process(StreamingInput<Tuple>, Tuple) - Method in class com.ibm.streamsx.topology.file.TextFileReader
ProcessingElement - Class in com.ibm.streamsx.rest: An object describing an IBM Streams Processing Element
ProcessingElement() - Constructor for class com.ibm.streamsx.rest.ProcessingElement
Properties - Interface in com.ibm.streamsx.topology.spi.builder
Properties.Graph - Interface in com.ibm.streamsx.topology.spi.builder
Properties.Graph.Config - Interface in com.ibm.streamsx.topology.spi.builder
publish(TStream<? extends Message>) - Method in class com.ibm.streamsx.topology.messaging.kafka.KafkaProducer: Publish a stream of messages to one or more topics.
publish(TStream<? extends Message>, Supplier<String>) - Method in class com.ibm.streamsx.topology.messaging.kafka.KafkaProducer: Publish a stream of messages to a topic.
publish(TStream<? extends Message>) - Method in class com.ibm.streamsx.topology.messaging.mqtt.MqttStreams: Publish stream tuples to one or more MQTT topics.
publish(TStream<? extends Message>, Supplier<String>) - Method in class com.ibm.streamsx.topology.messaging.mqtt.MqttStreams: Publish stream tuples to one or more MQTT topics.
publish(String) - Method in interface com.ibm.streamsx.topology.TStream: Publish tuples from this stream for consumption by other IBM Streams applications.
publish(Supplier<String>) - Method in interface com.ibm.streamsx.topology.TStream: Publish tuples from this stream for consumption by other IBM Streams applications.
publish(String, boolean) - Method in interface com.ibm.streamsx.topology.TStream: Publish tuples from this stream for consumption by other IBM Streams applications.
publish(Supplier<String>, boolean) - Method in interface com.ibm.streamsx.topology.TStream: Publish tuples from this stream for consumption by other IBM Streams applications.

R

randomHex(int) - Static method in interface com.ibm.streamsx.rest.internal.RestUtils: Create a random string of hexadecimal digits of specified length
refresh() - Method in class com.ibm.streamsx.rest.build.Element: Refresh this element.
refresh() - Method in class com.ibm.streamsx.rest.Element: Refresh this element.
refresh() - Method in class com.ibm.streamsx.rest.Metric
requestGsonResponse(Executor, Request) - Static method in interface com.ibm.streamsx.rest.internal.RestUtils: Gets a JSON response to an HTTP request call
resetConsistentRegions(Integer) - Method in interface com.ibm.streamsx.topology.tester.Tester: Create a condition that randomly resets consistent regions.
resetTimeout(long) - Method in class com.ibm.streamsx.topology.consistent.ConsistentRegionConfig: Return a new configuration changing resetTimeout.
Resource - Class in com.ibm.streamsx.rest: Domain resource information.
Resource() - Constructor for class com.ibm.streamsx.rest.Resource
ResourceAllocation - Class in com.ibm.streamsx.rest: Access to information about a resource that is allocated to a Streams instance.
ResourceAllocation() - Constructor for class com.ibm.streamsx.rest.ResourceAllocation
RESTErrorMessage - Class in com.ibm.streamsx.rest: An object describing an IBM Streams REST api Error Message
RESTErrorMessage(String, String) - Constructor for class com.ibm.streamsx.rest.RESTErrorMessage
RESTException - Exception in com.ibm.streamsx.rest: Exception for REST api wrappers
RESTException(int) - Constructor for exception com.ibm.streamsx.rest.RESTException: Customized exception that can provide more information on REST errors
RESTException(int, String) - Constructor for exception com.ibm.streamsx.rest.RESTException: Customized exception that can provide more information on REST errors
RESTException(String) - Constructor for exception com.ibm.streamsx.rest.RESTException: Customized exception that can provide more information on REST errors
RESTException(String, Exception) - Constructor for exception com.ibm.streamsx.rest.RESTException: Customized exception that can provide more information on REST errors
RestServer - Class in com.ibm.streamsx.topology.inet: Adds a HTTP REST server to a topology to provide external interaction with the application.
RestServer(TopologyElement) - Constructor for class com.ibm.streamsx.topology.inet.RestServer: Create a REST server that will listen on port 8080.
RestServer(TopologyElement, int) - Constructor for class com.ibm.streamsx.topology.inet.RestServer: Create a REST server that will listen on the specified port.
RestUtils - Interface in com.ibm.streamsx.rest.internal
Result<T,R> - Interface in com.ibm.streamsx.rest: Represents a result from a REST request.
ResultProperties - Interface in com.ibm.streamsx.topology.context: Result properties.
retrieveLogTrace(File) - Method in class com.ibm.streamsx.rest.Job: Retrieves the application log and trace files of the job and saves them as a compressed tar file.

S

sample(double) - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Return a stream that is a random sample of this stream.
sample(double) - Method in interface com.ibm.streamsx.topology.TStream: Return a stream that is a random sample of this stream.
SC_OPTIONS - Static variable in interface com.ibm.streamsx.topology.context.ContextProperties: Options to be passed to IBM Streams sc command.
serialize(TStream<JSONObject>) - Static method in class com.ibm.streamsx.topology.json.JSONStreams: Create a stream of serialized JSON objects as String tuples.
serialize(Object, OutputStream) - Method in interface com.ibm.streamsx.topology.spi.runtime.TupleSerializer
SerializeJSON() - Constructor for class com.ibm.streamsx.topology.json.JSONStreams.SerializeJSON
SERVICE_DEFINITION - Static variable in interface com.ibm.streamsx.topology.context.AnalyticsServiceProperties: Definition of a Streaming Analytics service.
SERVICE_NAME - Static variable in interface com.ibm.streamsx.topology.context.AnalyticsServiceProperties: Name of the service to use as a String.
setBuildConfig(Topology, JsonObject) - Static method in interface com.ibm.streamsx.topology.spi.builder.Invoker: Set the build configuration.
setConsistent(ConsistentRegionConfig) - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Set the operator that is the source of this stream to be the start of a consistent region to support at least once and exactly once processing.
setConsistent(ConsistentRegionConfig) - Method in interface com.ibm.streamsx.topology.TStream: Set the operator that is the source of this stream to be the start of a consistent region to support at least once and exactly once processing.
setDataDirectory(String) - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig: Set the data directory.
setDirectory(String) - Method in class com.ibm.streamsx.topology.file.DirectoryWatcher
setEncoding(String) - Method in class com.ibm.streamsx.topology.file.TextFileReader
setFunctionalNamespace(Topology, String) - Static method in interface com.ibm.streamsx.topology.spi.builder.Invoker: Set the functional namespace for Java functional operators for a topology.
setJobGroup(String) - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig: Set the job group.
setJobName(String) - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig: Set the job name.
setOverrideResourceLoadProtection(Boolean) - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig
setParallel(Supplier<Integer>) - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Sets the current stream as the start of a parallel region.
setParallel(Supplier<Integer>) - Method in interface com.ibm.streamsx.topology.TStream: Sets the current stream as the start of a parallel region.
setPreloadApplicationBundles(Boolean) - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig
setProject_id(String) - Method in class com.ibm.streamsx.rest.internal.icp4d.JobDescription.MetaData
setSpace_id(String) - Method in class com.ibm.streamsx.rest.internal.icp4d.JobDescription.MetaData
setTesterType() - Method in class com.ibm.streamsx.topology.tester.junit.AbstractTestClass
setTracing(Level) - Method in class com.ibm.streamsx.topology.jobconfig.JobConfig
setValue(String) - Method in class com.ibm.streamsx.topology.jobconfig.SubmissionParameter
setValue(Number) - Method in class com.ibm.streamsx.topology.jobconfig.SubmissionParameter
SimpleMessage - Class in com.ibm.streamsx.topology.tuple: A Simple implementation of an immutable Message.
SimpleMessage(String) - Constructor for class com.ibm.streamsx.topology.tuple.SimpleMessage: Create a SimpleMessage that lacks a key and topic.
SimpleMessage(String, String) - Constructor for class com.ibm.streamsx.topology.tuple.SimpleMessage: Create a SimpleMessage that lacks a topic.
SimpleMessage(String, String, String) - Constructor for class com.ibm.streamsx.topology.tuple.SimpleMessage: Create a SimpleMessage.
single(TopologyElement) - Static method in class com.ibm.streamsx.topology.streams.BeaconStreams: Produce a source stream declaring a single tuple, with the value 0.
sink(Consumer<T>) - Method in interface com.ibm.streamsx.topology.TStream: Terminate this stream.
skipVersion(String, int...) - Method in class com.ibm.streamsx.topology.tester.junit.AbstractTestClass: Allow a test to be skipped for a specific version.
sortAndSubmit(List<File>) - Method in class com.ibm.streamsx.topology.file.DirectoryWatcher
source(Supplier<Iterable<T>>) - Method in class com.ibm.streamsx.topology.Topology: Declare a new source stream that iterates over the return of Iterable<T> get() from data.
SOURCE_LOCATIONS - Static variable in interface com.ibm.streamsx.topology.spi.builder.SourceInfo
SourceInfo - Interface in com.ibm.streamsx.topology.spi.builder: Add the ability to add source location information to an operator invocation.
SPL - Class in com.ibm.streamsx.topology.spl: Integration between Java topologies and SPL operator invocations.
SPL() - Constructor for class com.ibm.streamsx.topology.spl.SPL
splHandler(SPLStream, T) - Method in interface com.ibm.streamsx.topology.tester.Tester: Deprecated.
Since 1.11. In most distributed environments stream contents cannot be obtained due to network isolation. An alternative is to use stringTupleTester to perform a per-tuple check.
SPLInput - Interface in com.ibm.streamsx.topology.spl: Interface that can be connected to an SPL input port.
split(int, ToIntFunction<T>) - Method in interface com.ibm.streamsx.topology.TStream: Distribute a stream's tuples among n streams as specified by a splitter.
splOK() - Method in class com.ibm.streamsx.topology.tester.junit.AbstractTestClass
SPLSchemas - Interface in com.ibm.streamsx.topology.spl: Interchangeable SPL types.
SPLStream - Interface in com.ibm.streamsx.topology.spl: A SPLStream is a declaration of a continuous sequence of tuples with a defined SPL schema.
SPLStreams - Class in com.ibm.streamsx.topology.spl: Utilities for SPL attribute schema streams.
SPLStreams() - Constructor for class com.ibm.streamsx.topology.spl.SPLStreams
SPLWindow - Interface in com.ibm.streamsx.topology.spl: An SPL window, that has an SPL eviction policy and an SPL trigger policy.
SSL_VERIFY - Static variable in interface com.ibm.streamsx.topology.context.ContextProperties: Set SSL certification verification state.
StandaloneAuthenticator - Class in com.ibm.streamsx.rest.internal: Authenticator which uses the Cloud Pak for Data standalone configuration security service.
startsWith(TStream<String>, String) - Static method in class com.ibm.streamsx.topology.streams.StringStreams: Create a filtered stream that contains String tuples starting with a specific term.
StreamingAnalyticsService - Interface in com.ibm.streamsx.rest: Access to a Streaming Analytics service on IBM Cloud.
STREAMS_ASSET_REF_TYPE - Static variable in class com.ibm.streamsx.rest.internal.icp4d.JobDescription: Streams jobs must have this asset refernce type.
STREAMS_CONNECTION - Static variable in interface com.ibm.streamsx.topology.context.ContextProperties: Deprecated.
Not supported. Use ContextProperties.STREAMS_INSTANCE.
STREAMS_INSTANCE - Static variable in interface com.ibm.streamsx.topology.context.ContextProperties: Instance connection to IBM Streams REST api to be used for submission.
StreamsConnection - Class in com.ibm.streamsx.rest: Connection to IBM Streams.
StreamsContext<T> - Interface in com.ibm.streamsx.topology.context: A StreamsContext provides the ability to turn a Topology into an executable.
StreamsContext.Type - Enum in com.ibm.streamsx.topology.context: Types of the IBM Streams context that a Topology can be executed against.
StreamsContextFactory - Class in com.ibm.streamsx.topology.context: Factory for creating StreamsContext instances.
StreamsContextFactory() - Constructor for class com.ibm.streamsx.topology.context.StreamsContextFactory
StreamsContextSubmit - Class in com.ibm.streamsx.topology.context.local: Given the path of a file containing the JSON representation of a graph, read the file, generate the SPL, and write it to the specified file.
StreamsContextSubmit() - Constructor for class com.ibm.streamsx.topology.context.local.StreamsContextSubmit
STRING - Static variable in interface com.ibm.streamsx.topology.spl.SPLSchemas: SPL schema used by TStream<String> streams.
stringContents(TStream<String>, String...) - Method in interface com.ibm.streamsx.topology.tester.Tester: Return a condition that evaluates if stream has submitted at tuples matching values in the same order.
stringContentsUnordered(TStream<String>, String...) - Method in interface com.ibm.streamsx.topology.tester.Tester: Return a condition that evaluates if stream has submitted at tuples matching values in any order.
strings(String...) - Method in class com.ibm.streamsx.topology.Topology: Create a stream of String tuples.
StringStreams - Class in com.ibm.streamsx.topology.streams: Utilities for streams containing String tuples.
StringStreams() - Constructor for class com.ibm.streamsx.topology.streams.StringStreams
stringToSPLStream(TStream<String>) - Static method in class com.ibm.streamsx.topology.spl.SPLStreams: Represent stream as an SPLStream with schema SPLSchemas.STRING.
stringTupleTester(TStream<String>, Predicate<String>) - Method in interface com.ibm.streamsx.topology.tester.Tester: Return a condition that evaluates if every tuple on stream evaluates to true with tester.
SUBMISSION_PARAMS - Static variable in interface com.ibm.streamsx.topology.context.ContextProperties: Submission parameters to be supplied to the topology when submitted for DISTRIBUTED, STANDALONE or ANALYTIC_SERVICE execution.
SubmissionParameter - Class in com.ibm.streamsx.topology.jobconfig
SubmissionParameter(String, boolean) - Constructor for class com.ibm.streamsx.topology.jobconfig.SubmissionParameter
SubmissionParameter(String, String) - Constructor for class com.ibm.streamsx.topology.jobconfig.SubmissionParameter
SubmissionParameter(String, Number) - Constructor for class com.ibm.streamsx.topology.jobconfig.SubmissionParameter
submit(String, JsonObject) - Method in class com.ibm.streamsx.rest.build.Build
submit() - Method in class com.ibm.streamsx.rest.build.Build
submit(Topology) - Method in interface com.ibm.streamsx.topology.context.StreamsContext: Submit topology to this Streams context.
submit(Topology, Map<String, Object>) - Method in interface com.ibm.streamsx.topology.context.StreamsContext: Submit topology to this Streams context with a specific configuration.
submit(JsonObject) - Method in interface com.ibm.streamsx.topology.context.StreamsContext: Submit a topology} to this Streams context as a JSON object.
submitJob(JsonObject) - Method in class com.ibm.streamsx.rest.ApplicationBundle
submitJob(File, JsonObject) - Method in class com.ibm.streamsx.rest.Instance: Submit a Streams bundle to run on the Streaming Analytics Service.
submitJob(File, JsonObject) - Method in interface com.ibm.streamsx.rest.StreamingAnalyticsService: Submit a Streams bundle to run on the Streaming Analytics Service.
subscribe(Supplier<String>) - Method in class com.ibm.streamsx.topology.messaging.kafka.KafkaConsumer: Subscribe to a topic and create a stream of messages.
subscribe(Supplier<Integer>, Supplier<String>) - Method in class com.ibm.streamsx.topology.messaging.kafka.KafkaConsumer: Subscribe to a topic and create a stream of messages.
subscribe(Supplier<String>) - Method in class com.ibm.streamsx.topology.messaging.mqtt.MqttStreams: Subscribe to a MQTT topic and create a stream of messages.
subscribe(TopologyElement, String, StreamSchema) - Static method in class com.ibm.streamsx.topology.spl.SPLStreams: Subscribe to an SPLStream published by topic.
subscribe(TopologyElement, Supplier<String>, StreamSchema) - Static method in class com.ibm.streamsx.topology.spl.SPLStreams: Subscribe to an SPLStream published by topic.
subscribe(String, Class<T>) - Method in class com.ibm.streamsx.topology.Topology: Declare a stream that is a subscription to topic.
subscribe(Supplier<String>, Class<T>) - Method in class com.ibm.streamsx.topology.Topology: Declare a stream that is a subscription to topic.
suffixFilter(TStream<String>, String...) - Static method in class com.ibm.streamsx.topology.file.FileStreams: Filter a Stream<String> containing file names by suffix values.
Supplier<T> - Interface in com.ibm.streamsx.topology.function: A function that supplies a value.

T

tagOpAsJavaPrimitive(BOperatorInvocation, String, String) - Static method in class com.ibm.streamsx.topology.spl.SPL: Internal method.
test() - Method in interface com.ibm.streamsx.rest.internal.icp4d.ICP4DService: Performs a GET request on the Spaces API to verify it is working
test() - Method in class com.ibm.streamsx.rest.internal.icp4d.ICP4DServiceImpl
test(T) - Method in interface com.ibm.streamsx.topology.function.Predicate: Test tuple against this predicate.
TEST_TRACE_LEVEL - Static variable in interface com.ibm.streamsx.topology.tester.Tester: System property to set the trace level of application under tests.
Tester - Interface in com.ibm.streamsx.topology.tester: A Tester adds the ability to test a topology in a test framework such as JUnit.
TESTER_TYPE - Static variable in interface com.ibm.streamsx.topology.tester.junit.TestProperties
TestProperties - Interface in com.ibm.streamsx.topology.tester.junit
textFileReader(TStream<String>) - Static method in class com.ibm.streamsx.topology.file.FileStreams: Returns a Stream that reads each file named on its input stream, outputting a tuple for each line read.
TextFileReader - Class in com.ibm.streamsx.topology.file
TextFileReader() - Constructor for class com.ibm.streamsx.topology.file.TextFileReader
throttle(long, TimeUnit) - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Throttle a stream by ensuring any tuple is submitted with least delay from the previous tuple.
throttle(long, TimeUnit) - Method in interface com.ibm.streamsx.topology.TStream: Throttle a stream by ensuring any tuple is submitted with least delay from the previous tuple.
ToIntFunction<T> - Interface in com.ibm.streamsx.topology.function: A function that applies a computation to a tuple and returns an int result.
toJSON(TStream<T>) - Static method in class com.ibm.streamsx.topology.json.JSONStreams: Declare a stream of JSON objects from a stream of Java objects that implement JSONAble.
ToJSON() - Constructor for class com.ibm.streamsx.topology.json.JSONStreams.ToJSON
toJSON() - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Transform SPL tuples into JSON.
toJSON() - Method in class com.ibm.streamsx.topology.tuple.BeaconTuple: Creates a JSON object with two attributes: sequence Value of BeaconTuple.getSequence() time Value of BeaconTuple.getTime()
toJSON() - Method in interface com.ibm.streamsx.topology.tuple.JSONAble
Toolkit - Class in com.ibm.streamsx.rest.build: An object describing an IBM Streams Toolkit
Toolkit.Dependency - Class in com.ibm.streamsx.rest.build: A dependency of a toolkit on another toolkit.
TOOLKIT_DIR - Static variable in interface com.ibm.streamsx.topology.context.ContextProperties: Location of the generated toolkit root.
topology() - Method in class com.ibm.streamsx.topology.inet.RestServer: Get the topology for this REST server.
Topology - Class in com.ibm.streamsx.topology: A declaration of a topology of streaming data.
Topology() - Constructor for class com.ibm.streamsx.topology.Topology: Create an new topology with a default name.
Topology(String) - Constructor for class com.ibm.streamsx.topology.Topology: Create an new topology with a given name.
Topology(String, String) - Constructor for class com.ibm.streamsx.topology.Topology: Create an new topology with a given name and namespace.
topology() - Method in class com.ibm.streamsx.topology.Topology: Return this topology.
topology() - Method in interface com.ibm.streamsx.topology.TopologyElement: The topology for this element.
TOPOLOGY_LOGGER - Static variable in class com.ibm.streamsx.topology.Topology: Logger used for the Topology API, name com.ibm.streamsx.topology.
TopologyElement - Interface in com.ibm.streamsx.topology: Any element in a Topology.
toSPL(TStream<JSONObject>) - Static method in class com.ibm.streamsx.topology.json.JSONStreams: Convert a JSON stream to an SPLStream.
toString() - Method in class com.ibm.streamsx.rest.build.Element
toString() - Method in class com.ibm.streamsx.rest.Element
toString() - Method in class com.ibm.streamsx.rest.internal.icp4d.ICP4DServiceImpl
toString() - Method in class com.ibm.streamsx.rest.RESTErrorMessage
toString(TStream<T>) - Static method in class com.ibm.streamsx.topology.streams.StringStreams: Create a stream that converts each input tuple to its String representation using toString().
toString() - Method in class com.ibm.streamsx.topology.tuple.BeaconTuple
toString() - Method in class com.ibm.streamsx.topology.tuple.SimpleMessage
toStringStream() - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Create a TStream<Tuple> from this stream.
toStringStream(SPLStream) - Static method in class com.ibm.streamsx.topology.spl.SPLStreams: Convert an SPLStream to a TStream<String> by taking its first attribute.
toStringStream(SPLStream, String) - Static method in class com.ibm.streamsx.topology.spl.SPLStreams: Convert an SPLStream to a TStream<String> by taking a specific attribute.
toTupleString() - Method in interface com.ibm.streamsx.topology.spl.SPLStream: Create a stream that converts each input tuple on this stream to its SPL character representation representation.
TRACE - Static variable in interface com.ibm.streamsx.rest.internal.RestUtils
TRACING_LEVEL - Static variable in interface com.ibm.streamsx.topology.context.ContextProperties: Trace level for a StreamsContext.Type.DISTRIBUTED or StreamsContext.Type.STANDALONE application.
transform(Function<T, U>) - Method in interface com.ibm.streamsx.topology.TStream: Declare a new stream that transforms each tuple from this stream into one (or zero) tuple of a different type U.
triggerCount(TWindow<Tuple, ?>, int) - Static method in class com.ibm.streamsx.topology.spl.SPLStreams: Convert window to an SPL window with a count based trigger policy.
triggerTime(TWindow<Tuple, ?>, long, TimeUnit) - Static method in class com.ibm.streamsx.topology.spl.SPLStreams: Convert window to an SPL window with a time based trigger policy.
TSink - Interface in com.ibm.streamsx.topology: A handle to the sink of a TStream.
TStream<T> - Interface in com.ibm.streamsx.topology: A TStream is a declaration of a continuous sequence of tuples.
TStream.Routing - Enum in com.ibm.streamsx.topology: Enumeration for routing tuples to parallel channels.
tupleContents(SPLStream, Tuple...) - Method in interface com.ibm.streamsx.topology.tester.Tester: Return a condition that evaluates if stream has submitted at tuples matching values in the same order.
tupleCount(TStream<?>, long) - Method in interface com.ibm.streamsx.topology.tester.Tester: Return a condition that evaluates if stream has submitted exactly expectedCount number of tuples.
TupleSerializer - Interface in com.ibm.streamsx.topology.spi.runtime
TWindow<T,K> - Interface in com.ibm.streamsx.topology: Declares a window of tuples for a TStream.

U

UnaryOperator<T> - Interface in com.ibm.streamsx.topology.function: Specialization of Function where the return type is the same as the argument type.
union(TStream<T>) - Method in interface com.ibm.streamsx.topology.TStream: Create a stream that is a union of this stream and other stream of the same type T.
union(Set<TStream<T>>) - Method in interface com.ibm.streamsx.topology.TStream: Create a stream that is a union of this stream and others streams of the same type T.
uploadArchive(File) - Method in class com.ibm.streamsx.rest.build.Build
uploadArchiveAndBuild(File) - Method in class com.ibm.streamsx.rest.build.Build
uploadBundle(File) - Method in class com.ibm.streamsx.rest.Instance: Upload a Streams application bundle (sab) to the instance.
uploadToolkit(File) - Method in interface com.ibm.streamsx.rest.build.BuildService: Install a toolkit in the build service from a local path.
Util - Class in com.ibm.streamsx.topology.messaging.kafka

V

valid() - Method in interface com.ibm.streamsx.topology.tester.Condition: Test if this condition is valid.
Value<T> - Class in com.ibm.streamsx.topology.logic: A Supplier for a single constant T value.
Value(T) - Constructor for class com.ibm.streamsx.topology.logic.Value: Create a constant value Supplier.
valueOf(String) - Static method in enum com.ibm.streamsx.rest.internal.BuildType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.ibm.streamsx.topology.consistent.ConsistentRegionConfig.Trigger: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.ibm.streamsx.topology.context.StreamsContext.Type: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.ibm.streamsx.topology.spl.FileSPLStreams.Compression: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.ibm.streamsx.topology.TStream.Routing: Returns the enum constant of this type with the specified name.
values() - Static method in enum com.ibm.streamsx.rest.internal.BuildType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.ibm.streamsx.topology.consistent.ConsistentRegionConfig.Trigger: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.ibm.streamsx.topology.context.StreamsContext.Type: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.ibm.streamsx.topology.spl.FileSPLStreams.Compression: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.ibm.streamsx.topology.TStream.Routing: Returns an array containing the constants of this enum type, in the order they are declared.
VCAP_SERVICES - Static variable in interface com.ibm.streamsx.topology.context.AnalyticsServiceProperties: IBM Cloud service definitions.
verifyComplete(Tester, Condition<?>, long, TimeUnit) - Method in class com.ibm.streamsx.topology.tester.junit.AbstractTestClass
verifyComplete(Tester, Condition<?>) - Method in class com.ibm.streamsx.topology.tester.junit.AbstractTestClass
viewer(TWindow<?, ?>, String, String) - Method in class com.ibm.streamsx.topology.inet.RestServer: Declare a HTTP REST view of tuples in a window.
VMARGS - Static variable in interface com.ibm.streamsx.topology.context.ContextProperties: Java virtual machine arguments.

W

waitForHealthy(long, TimeUnit) - Method in class com.ibm.streamsx.rest.Job: Wait for this job to become healthy.
window(TWindow<?, ?>) - Method in interface com.ibm.streamsx.topology.TStream: Declare a TWindow on this stream that has the same configuration as another window.

X

XML - Static variable in interface com.ibm.streamsx.topology.spl.SPLSchemas: SPL schema used by TStream<com.ibm.streams.operator.types.XML> streams.

_

_SPLMM_OPTIONS - Static variable in interface com.ibm.streamsx.topology.context.ContextProperties

A B C D E F G H I J K L M N O P R S T U V W X _