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 directorydstDirName
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 anint
. - 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 leastexpectedCount
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 tuplesExpectedTuples.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 anSPLStream
. - 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 thespl.adapter::FileSource
operator that reads CSV records from compressed files with names delivered byfileNames
. - csvReader(TStream<String>, StreamSchema) - Static method in class com.ibm.streamsx.topology.spl.FileSPLStreams
-
Create an
SPLStream
using thespl.adapter::FileSource
operator that reads CSV records from files with names delivered byfileNames
.
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 (typeU
) as aBiFunction
that takes anList
. - flatMap(Function<T, Iterable<U>>) - 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
forapplication/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()
andConsistentRegionConfig.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<U>, 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<U>, J>) - Method in interface com.ibm.streamsx.topology.TStream
-
Join this stream with a partitioned window of type
U
with key typeK
. - joinLast(Function<? super T, ? extends K>, TStream<U>, 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<U>, 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
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 lasttime
seconds of tuples (in the given timeunit
) on this stream. - last(Supplier<Integer>) - Method in interface com.ibm.streamsx.topology.TStream
-
Declare a
TWindow
that continually represents the lastcount
tuples seen on this stream. - last(int) - Method in interface com.ibm.streamsx.topology.TStream
-
Declare a
TWindow
that continually represents the lastcount
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 lasttime
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 creatingTStream<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<U>>) - 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()
fromdata
. - 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 asplitter
. - 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 aTopology
into an executable. - StreamsContext.Type - Enum in com.ibm.streamsx.topology.context
-
Types of the
IBM Streams context
that aTopology
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 matchingvalues
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 matchingvalues
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
- 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 totrue
withtester
. - 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
orANALYTIC_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 ofBeaconTuple.getSequence()
time
Value ofBeaconTuple.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 usingtoString()
. - 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
orStreamsContext.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 aTStream
. - 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 matchingvalues
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 exactlyexpectedCount
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 typeT
. - 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 typeT
. - 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