Index (IBM InfoSphere Streams Java Operator API)

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

A

AbstractControlVariable<T> - Class in com.ibm.streams.operator.control.variable: Abstract control variable for the Job Control Plane (JCP).
AbstractControlVariable(MBeanNotificationInfo...) - Constructor for class com.ibm.streams.operator.control.variable.AbstractControlVariable
AbstractOperator - Class in com.ibm.streams.operator: An abstract implementation of Operator that may be used by developers to implement their own Operator.
AbstractOperator() - Constructor for class com.ibm.streams.operator.AbstractOperator
AbstractPersistentControlMBean<T> - Class in com.ibm.streams.operator.control: TODO
AbstractPersistentControlMBean(MBeanNotificationInfo...) - Constructor for class com.ibm.streams.operator.control.AbstractPersistentControlMBean
AbstractStreamForwarder<T> - Class in com.ibm.streams.flow.handlers: Forward a stream to another StreamHandler.
AbstractStreamForwarder() - Constructor for class com.ibm.streams.flow.handlers.AbstractStreamForwarder
AbstractWindowOperator - Class in com.ibm.streams.operator.window: Abstract operator that forces all tuple processing to be through window event handling.
AbstractWindowOperator() - Constructor for class com.ibm.streams.operator.window.AbstractWindowOperator
acquirePermit() - Method in interface com.ibm.streams.operator.state.ConsistentRegionContext: Acquire a single submission permit.
add(Timestamp) - Method in class com.ibm.streams.operator.types.Timestamp: Return a Timestamp that is the result of adding the delta Timestamp to this Timestamp.
addAllPortsReadyAction(OperatorContext, NotificationListener) - Static method in class com.ibm.streams.operator.management.OperatorLifeCycle: Register an action to be executed when an operator is notified of port readiness.
addClassLibraries(String[]) - Method in interface com.ibm.streams.operator.OperatorContext: Add class libraries to the operator's class loader.
addHandler(StateHandler) - Method in class com.ibm.streams.operator.state.OrderedStateHandlers
addInput(String, StreamSchema) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation: Declare an input port for this operator.
addInput(String, String) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation: Declare an input port for this operator.
addInput(String) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation: Declare an input port for this operator and generate the name of the port.
addInput(StreamSchema) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation: Declare an input port for this operator and generate the name of the port.
addInput(OutputPortDeclaration) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation: Declare an input port that is connected to an output port.
addOperator(Class<T>) - Method in interface com.ibm.streams.flow.declare.OperatorGraph: Declare an invocation of an Operator in this graph.
addOperator(String, Class<T>) - Method in interface com.ibm.streams.flow.declare.OperatorGraph: Declare an invocation of an Operator in this graph.
addOutput(String, String) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation: Declare an output port for this operator.
addOutput(String, StreamSchema) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation: Declare an output port for this operator.
addOutput(String) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation: Declare an output port for this operator and generate the name of the port.
addOutput(StreamSchema) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation: Declare an output port for this operator and generate the name of the port.
addShutdownAction(OperatorContext, NotificationListener) - Static method in class com.ibm.streams.operator.management.OperatorLifeCycle: Register an action to be executed when an operator is shutdown.
addStreamProperties(Map<String, ?>) - Method in interface com.ibm.streams.operator.StreamingOutput: Add a collection of stream properties to the set for this output port.
addType(Hashtable<String, String>) - Method in enum com.ibm.streams.operator.management.MetricMXBean.MetricType: Add this metric type to objectNameProperties for use in creating an ObjectName.
after(Timestamp) - Method in class com.ibm.streams.operator.types.Timestamp: Is this Timestamp after the specified Timestamp.
ALL_PORTS_READY - Static variable in interface com.ibm.streams.operator.management.OperatorContextMXBean: Notification the operator's ports are ready and it is free to submit tuples.
allPortsReady() - Method in interface com.ibm.streams.flow.javaprimitives.JavaTestableGraph: Asynchronously notify all the operator invocations in the graph that the ports are ready, and the submission of tuples can start.
allPortsReady() - Method in class com.ibm.streams.operator.AbstractOperator: Called once initialization is complete and all input and output ports are connected and ready to process and submit tuples.
allPortsReady() - Method in interface com.ibm.streams.operator.Operator: Called once initialization is complete and all input and output ports are connected and ready to process and submit tuples.
asReadOnlyTuple() - Method in interface com.ibm.streams.operator.OutputTuple: Get an immutable version of this tuple.
asReadOnlyTuple() - Method in interface com.ibm.streams.operator.Tuple: Get an immutable version of this tuple.
assign(Tuple) - Method in interface com.ibm.streams.operator.OutputTuple: Set attributes of this tuple that have a matching attribute from sourceTuple.
assignTuple(int, Tuple) - Method in interface com.ibm.streams.operator.OutputTuple: Assign attributes of a nested tuple attribute from matching attributes in a Tuple.
assignTuple(String, Tuple) - Method in interface com.ibm.streams.operator.OutputTuple: Set the attribute as a TUPLE by attribute name by assigning matching attributes from tuple.
Attribute - Interface in com.ibm.streams.operator: Meta-data for an attribute within a StreamSchema.
ATTRIBUTE_CHANGE_INFO - Static variable in class com.ibm.streams.operator.control.NotifierSupport: An MBeanNotificationInfo that indicates an MBean generates jmx.attribute.change notifications using javax.management.AttributeChangeNotification.

B

before(Timestamp) - Method in class com.ibm.streams.operator.types.Timestamp: Is this Timestamp before the specified Timestamp.
BinaryEncoding - Interface in com.ibm.streams.operator.encoding: Interface to encode and decode Tuples into a binary encoding.
Blob - Interface in com.ibm.streams.operator.types: SPL blob, which is a sequence of bytes.
BooleanControlVariable - Class in com.ibm.streams.operator.control.variable: Provides the implementation of the boolean control variable MBean.
BooleanControlVariable() - Constructor for class com.ibm.streams.operator.control.variable.BooleanControlVariable: Create a BooleanControlVariableMXBean initially set to false.
BooleanControlVariable(boolean) - Constructor for class com.ibm.streams.operator.control.variable.BooleanControlVariable: Create a BooleanControlVariableMXBean initially set to initialState.
BooleanControlVariableMXBean - Interface in com.ibm.streams.operator.control.variable: MXBean representing a boolean control variable.
BoundedType - Interface in com.ibm.streams.operator.meta: Type specific information for SPL bounded types, BLIST, BMAP, BSET and BSTRING.

C

CharacterEncoding - Interface in com.ibm.streams.operator.encoding: Interface to encode and decode Tuples into a character encoding.
checkAttributes(StreamSchema, boolean, StreamSchema) - Method in interface com.ibm.streams.operator.compile.OperatorContextChecker: Check that one or more attributes for a StreamSchema have the required type.
checkAttributes(StreamSchema, boolean, String) - Method in interface com.ibm.streams.operator.compile.OperatorContextChecker: Check that one or more attributes for a StreamSchema have the required type.
checkAttributes(StreamingData, boolean, StreamSchema) - Method in interface com.ibm.streams.operator.compile.OperatorContextChecker: Check that one or more attributes for a input or output port have the required type.
checkAttributes(StreamingData, boolean, String) - Method in interface com.ibm.streams.operator.compile.OperatorContextChecker: Check that one or more attributes for a input or output port have the required type.
checkAttributeType(Attribute, Type.MetaType...) - Method in interface com.ibm.streams.operator.compile.OperatorContextChecker: Check that attribute is one of the types listed in validTypes.
checkDependentParameters(String, String...) - Method in interface com.ibm.streams.operator.compile.OperatorContextChecker: Check that if parameterName is set as a parameter, then all of the parameters in dependentParameterNames are set.
checkExcludedParameters(String, String...) - Method in interface com.ibm.streams.operator.compile.OperatorContextChecker: Check that if parameterName is set as a parameter, then none of the parameters in excludedParameterNames are set.
checkMatchingSchemas(StreamingData, StreamingData...) - Method in interface com.ibm.streams.operator.compile.OperatorContextChecker: Check that one or more ports has a stream schema that matches another port.
Checkpoint - Interface in com.ibm.streams.operator.state: Represents a checkpoint.
checkpoint(Checkpoint) - Method in class com.ibm.streams.operator.state.DelegateStateHandler
checkpoint(Checkpoint) - Method in class com.ibm.streams.operator.state.OrderedStateHandlers
checkpoint(Checkpoint) - Method in interface com.ibm.streams.operator.state.StateHandler: Checkpoint the operator state to support resetting of its state to the saved state, using StateHandler.reset(Checkpoint).
checkpoint(Checkpoint) - Method in class com.ibm.streams.operator.window.StatefulWindowListener: Checkpoint the operator state to support resetting of its state to the saved state, using StateHandler.reset(Checkpoint).
CheckpointableWindowListener<O extends Operator,T> - Interface in com.ibm.streams.operator.window
CheckpointContext - Interface in com.ibm.streams.operator.state: Context information that allows operators to create or restore checkpoint data of their state information.
CheckpointContext.Kind - Enum in com.ibm.streams.operator.state: TODO
checkPorts(int, int) - Method in class com.ibm.streams.operator.AbstractOperator: Deprecated.
As of InfoSphere Streams 3.0, replaced by input and output port configurations in the Java primitive operator model.
checkRequiredAttributes(StreamSchema, String...) - Method in interface com.ibm.streams.operator.compile.OperatorContextChecker: Check that a set of required attributes exist in a StreamSchema.
checkRequiredAttributes(StreamingData, String...) - Method in interface com.ibm.streams.operator.compile.OperatorContextChecker: Check that one or more required attributes exist for a port.
checkSlidingWindow(StreamingInput<?>) - Method in interface com.ibm.streams.operator.compile.OperatorContextChecker: Check the streaming window for an input port is sliding.
checkTumblingWindow(StreamingInput<?>) - Method in interface com.ibm.streams.operator.compile.OperatorContextChecker: Check the streaming window for an input port is tumbling.
clear() - Method in class com.ibm.streams.flow.handlers.MostRecent: Clear the most recent tuple and punctuation mark by calling MostRecent.clearMostRecentTuple() and MostRecent.clearMostRecentMark().
clearMostRecentMark() - Method in class com.ibm.streams.flow.handlers.MostRecent: Clear the most recent punctuation mark.
clearMostRecentTuple() - Method in class com.ibm.streams.flow.handlers.MostRecent: Clear the most recent tuple.
close() - Method in class com.ibm.streams.operator.state.DelegateStateHandler
close() - Method in class com.ibm.streams.operator.state.OrderedStateHandlers
close() - Method in class com.ibm.streams.operator.window.StatefulWindowListener
closeOnShutdown(OperatorContext, Closeable) - Static method in class com.ibm.streams.operator.management.OperatorLifeCycle: Register to close a Closeable when the operator is shutdown.
CollectionType - Interface in com.ibm.streams.operator.meta: Meta-data for a SPL collection type.
com.ibm.streams.flow.declare - package com.ibm.streams.flow.declare: Declaration of an SPL directed flow graph of Java primitive operators.
com.ibm.streams.flow.execute - package com.ibm.streams.flow.execute: The execution of an SPL directed flow graph that contains Java primitive operators.
com.ibm.streams.flow.handlers - package com.ibm.streams.flow.handlers: Stream handler implementations.
com.ibm.streams.flow.javaprimitives - package com.ibm.streams.flow.javaprimitives: Testing of an SPL directed flow graph that contains Java primitive operators.
com.ibm.streams.function.model - package com.ibm.streams.function.model: Annotation to define SPL Java native functions.
com.ibm.streams.operator - package com.ibm.streams.operator: Java Operator API for InfoSphere Streams.
com.ibm.streams.operator.compile - package com.ibm.streams.operator.compile: SPL compile time support for Java primitive operators.
com.ibm.streams.operator.control - package com.ibm.streams.operator.control: Java primitive operator interface to the Job Control Plane.
com.ibm.streams.operator.control.variable - package com.ibm.streams.operator.control.variable: Collection of utilities and generic MBeans that can be used to represent control variables in the Job Control Plane (JCP).
com.ibm.streams.operator.encoding - package com.ibm.streams.operator.encoding: Encoding of tuples into alternate representations.
com.ibm.streams.operator.log4j - package com.ibm.streams.operator.log4j: SPL trace and logging for the Java Operator API using the Apache log4j logging facilities.
com.ibm.streams.operator.logging - package com.ibm.streams.operator.logging: SPL trace and logging for the Java Operator API using the Java™ 2 platform's core logging facilities.
com.ibm.streams.operator.management - package com.ibm.streams.operator.management: Operator integration with the JMX platform MBean server.
com.ibm.streams.operator.meta - package com.ibm.streams.operator.meta: Meta-data for SPL composite and bounded types.
com.ibm.streams.operator.metrics - package com.ibm.streams.operator.metrics: Metrics for Operator and Processing Element.
com.ibm.streams.operator.model - package com.ibm.streams.operator.model: Annotations to define an SPL Java primitive operator.
com.ibm.streams.operator.state - package com.ibm.streams.operator.state: State management for operators.
com.ibm.streams.operator.types - package com.ibm.streams.operator.types: SPL specific types.
com.ibm.streams.operator.version - package com.ibm.streams.operator.version
com.ibm.streams.operator.window - package com.ibm.streams.operator.window: Input port windowing interfaces and classes.
com.ibm.streams.operator.window.sort - package com.ibm.streams.operator.window.sort: Stream window listeners that implement window based sorting.
compareTo(Timestamp) - Method in class com.ibm.streams.operator.types.Timestamp: Compare this to another Timestamp.
compareTo(Version) - Method in class com.ibm.streams.operator.version.Version
compileChecks() - Method in interface com.ibm.streams.flow.declare.OperatorGraph: Run compile checks for all the declared operators in the graph.
compileChecks(boolean) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation: Run compile checks against this invocation.
compileChecks() - Method in interface com.ibm.streams.flow.declare.OperatorInvocation: Run compile checks against this invocation.
completion() - Method in interface com.ibm.streams.flow.javaprimitives.JavaTestableGraph: Return a Future that completes when all the operator invocations in the graph have completed.
CompositeType - Interface in com.ibm.streams.operator.meta: Parent meta-type interface for an attribute of composite attributes.
connect(OutputPortDeclaration...) - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration: Connect this input port to output ports.
connect(InputPortDeclaration...) - Method in interface com.ibm.streams.flow.declare.OutputPortDeclaration: Connect this output port to input ports.
connect() - Method in interface com.ibm.streams.operator.control.ControlPlaneContext: Connect the PE for this operator to the Job Control Plane.
connect(Controllable) - Method in interface com.ibm.streams.operator.control.ControlPlaneContext: Connect the PE for this operator to the Job Control Plane.
ConsistentRegionContext - Interface in com.ibm.streams.operator.state: Context information for the consistent region the operator is in.
ConsistentRegionMXBean - Interface in com.ibm.streams.operator.control: Management Bean (MBean) registered in the Job Control Plane for a consistent region within the job.
ConsistentRegionMXBean.State - Enum in com.ibm.streams.operator.control: States of a consistent region.
ConsistentRegionMXBean.Trigger - Enum in com.ibm.streams.operator.control
CONTROL_PLANE_METRIC - Static variable in class com.ibm.streams.operator.control.ControlPlaneManagement: Name of the custom gauge metric ("controlPlaneConnection") created for an operator when it connections to the Job Control Plane.
Controllable - Interface in com.ibm.streams.operator.control: Operator interface to establish control mechanisms in the Job Control Plane using JMX.
Controllable.EventType - Enum in com.ibm.streams.operator.control: Job Control Plane connection event types.
ControlPlaneContext - Interface in com.ibm.streams.operator.control: Interface to provide access to Job Control Plane for Java Operators and functions.
ControlPlaneManagement - Class in com.ibm.streams.operator.control: Utilities for the Job Control Plane.
ControlPlaneMXBean - Interface in com.ibm.streams.operator.control: Management for the Job Control Plane.
ControlVariableAccessor<T> - Interface in com.ibm.streams.operator.control.variable: Operator access to a control variable.
convertTo(TimeUnit) - Method in class com.ibm.streams.operator.types.Timestamp: Convert this timestamp into the unit specified.
createAvoidCompletionThread() - Method in class com.ibm.streams.operator.AbstractOperator: Create a thread to avoid completion of the operator by the SPL runtime.
createAvoidCompletionThread(OperatorContext) - Static method in class com.ibm.streams.operator.AbstractOperator: Create a thread that avoids the SPL runtime completing the operator.
createAvoidCompletionThreadIfNoInputs() - Method in class com.ibm.streams.operator.AbstractOperator: Create a thread to avoid completion of the operator by the SPL runtime if the operator has no input ports.
createBooleanControlVariable(String, boolean, boolean) - Method in interface com.ibm.streams.operator.control.ControlPlaneContext: An operator boolean control variable that is maintained as a BooleanControlVariable in the Job Control Plane.
createCheckpoint() - Method in interface com.ibm.streams.operator.state.CheckpointContext: Create a checkpoint.
createCustomMetric(String, String, Metric.Kind) - Method in interface com.ibm.streams.operator.metrics.OperatorMetrics: Create a custom metric specific to this operator.
createDoubleControlVariable(String, boolean, double) - Method in interface com.ibm.streams.operator.control.ControlPlaneContext: An operator double control variable that is maintained as a DoubleControlVariable in the Job Control Plane.
createLongControlVariable(String, boolean, long) - Method in interface com.ibm.streams.operator.control.ControlPlaneContext: An operator long control variable that is maintained as a LongControlVariable in the Job Control Plane.
createStringControlVariable(String, boolean, String) - Method in interface com.ibm.streams.operator.control.ControlPlaneContext: An operator String control variable that is maintained as a StringControlVariable in the Job Control Plane.
currentTime() - Static method in class com.ibm.streams.operator.types.Timestamp: Create a Timestamp representing the current time since the epoch.
currentTime(int) - Static method in class com.ibm.streams.operator.types.Timestamp: Create a Timestamp representing the current time since the epoch and the give machine identifier.
CUSTOM_METRIC_CREATED - Static variable in interface com.ibm.streams.operator.management.OperatorContextMXBean: Notification the operator has created a custom metric.
CustomMetric - Annotation Type in com.ibm.streams.operator.model: Declare a relationship between an Operator's Java bean property and custom metric.

D

DataException - Exception in com.ibm.streams.operator: This is an exception that is thrown by Java primitive operators when an error condition is found when processing input tuples.
DataException() - Constructor for exception com.ibm.streams.operator.DataException: Constructs a DataException.
DataException(String) - Constructor for exception com.ibm.streams.operator.DataException: Constructs a DataException with the specified message.
DataException(String, Throwable) - Constructor for exception com.ibm.streams.operator.DataException: Constructs a DataException with the specified message and cause.
DEBUG - Static variable in class com.ibm.streams.operator.log4j.TraceLevel: DEBUG is a message level for debug level tracing information including method entry, exit, and return values.
DEBUG - Static variable in class com.ibm.streams.operator.logging.TraceLevel: DEBUG is a message level for debug level tracing information including method entry, exit, and return values.
decodeTuple(ByteBuffer) - Method in interface com.ibm.streams.operator.encoding.BinaryEncoding: Decode a encoded tuple from buffer and return it as an immutable Tuple.
DEFAULT_MACHINE - Static variable in class com.ibm.streams.operator.types.Timestamp: Default Machine identifier (zero).
DefaultAttribute - Annotation Type in com.ibm.streams.operator.model: Declare a default attribute to be used as the value for an optional 'Attribute' parameter.
deferredSubmit(T) - Method in interface com.ibm.streams.operator.StreamingOutput: Return a Callable object that may be used to submit a tuple in the future, typically using the ScheduledExecutorService from OperatorContext.
DelegateStateHandler<T extends StateHandler> - Class in com.ibm.streams.operator.state: TODO
DelegateStateHandler(T) - Constructor for class com.ibm.streams.operator.state.DelegateStateHandler
DOMAIN - Static variable in class com.ibm.streams.operator.control.ControlPlaneManagement: The domain ("com.ibm.streams.control") for MBeans registered by the Job Control Plane itself.
DoubleControlVariable - Class in com.ibm.streams.operator.control.variable: Provides the implementation of the double control variable MBean.
DoubleControlVariable() - Constructor for class com.ibm.streams.operator.control.variable.DoubleControlVariable: Create a DoubleControlVariableMXBean with no initial value.
DoubleControlVariable(double) - Constructor for class com.ibm.streams.operator.control.variable.DoubleControlVariable: Create a DoubleControlVariableMXBean with an initial value.
DoubleControlVariableMXBean - Interface in com.ibm.streams.operator.control.variable: MXBean representing a double control variable.
drain() - Method in class com.ibm.streams.operator.state.DelegateStateHandler
drain() - Method in class com.ibm.streams.operator.state.OrderedStateHandlers
drain() - Method in interface com.ibm.streams.operator.state.StateHandler: Drain any outstanding processing.
drain() - Method in class com.ibm.streams.operator.window.StatefulWindowListener: Drain any outstanding processing.
DynamicForwarder<T> - Class in com.ibm.streams.flow.handlers: Forward a stream to another StreamHandler.
DynamicForwarder() - Constructor for class com.ibm.streams.flow.handlers.DynamicForwarder: Create a DynamicForwarder with the destination set to a StreamDiscarder.
DynamicForwarder(StreamHandler<T>) - Constructor for class com.ibm.streams.flow.handlers.DynamicForwarder: Create a DynamicForwarder with the destination set to a handler.

E

encodeAsString(Tuple) - Method in interface com.ibm.streams.operator.encoding.JSONEncoding: Encode all attributes for tuple into a string representation of a JSON object.
encodeTuple(Tuple, ByteBuffer) - Method in interface com.ibm.streams.operator.encoding.BinaryEncoding: Encode tuple into buffer using this encoding.
encodeTuple(Tuple, StringBuilder) - Method in interface com.ibm.streams.operator.encoding.CharacterEncoding: Encode tuple into buffer using this encoding.
encodeTuple(Tuple) - Method in interface com.ibm.streams.operator.encoding.CharacterEncoding: Encode a tuple as a String using this encoding.
encodeTuple(Tuple, O) - Method in interface com.ibm.streams.operator.encoding.JSONEncoding: Encode all attributes for tuple as a JSON object.
encodeTuple(Tuple) - Method in interface com.ibm.streams.operator.encoding.JSONEncoding: Encode all attributes for tuple into a JSON object.
EncodingFactory - Class in com.ibm.streams.operator.encoding: Factory methods to get encoding classes for Tuple objects.
EnumType - Interface in com.ibm.streams.operator.meta: Meta-type for an attribute of type ENUM.
equals(Object) - Method in class com.ibm.streams.operator.types.RString: Compares this to other.
equals(Object) - Method in class com.ibm.streams.operator.types.Timestamp: A Timestamp is equal to another Timestamp with the same seconds and nanoseconds value.
equals(Object) - Method in class com.ibm.streams.operator.version.Version
ERROR - Static variable in class com.ibm.streams.operator.log4j.LogLevel: ERROR is a level indicating the operator cannot continue.
ERROR - Static variable in class com.ibm.streams.operator.log4j.TraceLevel: ERROR is a level indicating the operator cannot continue.
ERROR - Static variable in class com.ibm.streams.operator.logging.LogLevel: ERROR is a level indicating the operator cannot continue.
ERROR - Static variable in class com.ibm.streams.operator.logging.TraceLevel: ERROR is a level indicating the operator cannot continue.
event(MBeanServerConnection, OperatorContext, Controllable.EventType) - Method in interface com.ibm.streams.operator.control.Controllable: Notify this Controllable of a change in the connection to the Job Control Plane.
evictCount(int) - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration: Set the type of the window eviction policy to be StreamWindow.Policy.COUNT.
evictDelta(String, Object) - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration: Set the type of the window eviction policy to be StreamWindow.Policy.DELTA.
evictionsOccurred(Object) - Method in class com.ibm.streams.operator.window.StatefulWindowListener: For a sliding window has this partition had tuples evicted.
evictPartition(Object) - Method in interface com.ibm.streams.operator.window.StreamWindow: Evict a partition and its tuples from the window.
evictPunctuation() - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration: Set the type of the window eviction policy to be StreamWindow.Policy.PUNCTUATION.
evictTime(double) - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration: Set the type of the window eviction policy to be StreamWindow.Policy.TIME.
evictTime(long, TimeUnit) - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration: Set the type of the window eviction policy to be StreamWindow.Policy.TIME.
executable(OperatorGraph) - Method in interface com.ibm.streams.flow.execute.ExecutableGraphFactory: Creates a new executable version of operatorGraph.
executable(OperatorGraph) - Method in class com.ibm.streams.flow.javaprimitives.JavaOperatorTester: Create a JavaTestableGraph for a graph of Java primitive operators.
ExecutableGraph<E extends ExecutableGraph<E>> - Interface in com.ibm.streams.flow.execute: ExecutableGraph represents an executable flow graph of Java primitive operators.
ExecutableGraphFactory<E extends ExecutableGraph<E>> - Interface in com.ibm.streams.flow.execute: A factory for creating executable graphs of operators.
execute() - Method in interface com.ibm.streams.flow.execute.ExecutableGraph: Execute the complete graph.
executeToCompletion() - Method in interface com.ibm.streams.flow.execute.ExecutableGraph: Execute this graph and wait for the completion of the graph.
extend(Type, String) - Method in interface com.ibm.streams.operator.StreamSchema: Create an extension of this schema with an additional attribute.
extend(String, String) - Method in interface com.ibm.streams.operator.StreamSchema: Create an extension of this schema with an additional attribute.
extendByAttributes(Attribute...) - Method in interface com.ibm.streams.operator.StreamSchema: Create an extension of this schema with additional attributes.
extendBySchemas(StreamSchema...) - Method in interface com.ibm.streams.operator.StreamSchema: Create an extension of this schema from another schema.

F

Function - Annotation Type in com.ibm.streams.function.model: Declare an SPL Java native function.

G

getApplicationDirectory() - Method in interface com.ibm.streams.operator.management.ProcessingElementMXBean: Return the absolute path of the application directory for the SPL application.
getApplicationDirectory() - Method in interface com.ibm.streams.operator.ProcessingElement: Return the application directory for the SPL application.
getApplicationName() - Method in interface com.ibm.streams.operator.management.ProcessingElementMXBean: Return the name of the application the PE is running.
getApplicationName() - Method in interface com.ibm.streams.operator.ProcessingElement: Return the name of the SPL application.
getApplicationScope() - Method in interface com.ibm.streams.operator.management.ProcessingElementMXBean: Return the application scope for the job the PE is running in.
getApplicationScope() - Method in interface com.ibm.streams.operator.ProcessingElement: Return the application scope for the job the PE is running in.
getAsCompositeElementType() - Method in interface com.ibm.streams.operator.Type: Get the type of the object returned for this type when stored in a collection type.
getAttribute(int) - Method in interface com.ibm.streams.operator.StreamSchema: Get the meta-data for the attribute at the given index.
getAttribute(String) - Method in interface com.ibm.streams.operator.StreamSchema: Get the meta-data for the attribute at the given name.
getAttribute() - Method in interface com.ibm.streams.operator.TupleAttribute: A reference to the actual attribute object
getAttributeCount() - Method in interface com.ibm.streams.operator.StreamSchema: Returns the number of attributes in this schema.
getAttributeIndex(String) - Method in interface com.ibm.streams.operator.StreamSchema: For a given attribute name, find its index.
getAttributeNames() - Method in interface com.ibm.streams.operator.StreamSchema: Return an unmodifiable set of attribute names in this schema.
getAttributeObject(Tuple, Attribute) - Method in interface com.ibm.streams.operator.encoding.JSONEncoding: Get an attribute value from tuple as object for a JSON object.
getAttributeObject(Tuple, String) - Method in interface com.ibm.streams.operator.encoding.JSONEncoding: Get an attribute value from tuple as an object for a JSON object.
getAttributesComparator(boolean, String...) - Method in interface com.ibm.streams.operator.StreamSchema: Return a comparator for this schema ordering by a sub-set of the attributes.
getBigDecimal(int) - Method in interface com.ibm.streams.operator.Tuple: Get an attribute as a BigDecimal.
getBigDecimal(String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as an BigDecimal using the attribute's name.
getBlob(int) - Method in interface com.ibm.streams.operator.Tuple: Get an attribute as a Blob.
getBlob(String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as a Blob using the attribute's name.
getBoolean(int) - Method in interface com.ibm.streams.operator.Tuple: Get an attribute as a primitive boolean.
getBoolean(String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as a boolean using the attribute's name.
getBoundedSize() - Method in interface com.ibm.streams.operator.meta.BoundedType: Get the bound size of the type.
getBuffer(int) - Method in interface com.ibm.streams.operator.Tuple: Get an attribute as a read-only java.nio.Buffer.
getBuffer(int, Class<T>) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as a buffer of type T using the attribute's index.
getBuffer(String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as a java.nio.Buffer using the attribute's name.
getBuffer(String, Class<T>) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as a buffer of type T using the attribute's name.
getByte(int) - Method in interface com.ibm.streams.operator.Tuple: Get an attribute as a primitive byte.
getByte(String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as a byte using the attribute's name.
getByteBuffer() - Method in interface com.ibm.streams.operator.types.Blob: Return a read-only Byte Buffer that represents this complete blob.
getByteBuffer(long, int) - Method in interface com.ibm.streams.operator.types.Blob: Return a read-only Byte Buffer that represents the portion of this blob value defined b
getByteBuffer() - Method in class com.ibm.streams.operator.types.RString: Get a ByteBuffer that represents the contents of this value.
getChannel() - Method in interface com.ibm.streams.operator.management.OperatorContextMXBean: Get the index of the parallel channel the operator is on.
getChannel() - Method in interface com.ibm.streams.operator.OperatorContext: Get the index of the parallel channel the operator is on.
getCheckpointingInterval() - Method in interface com.ibm.streams.operator.state.CheckpointContext: Returns the checkpointing interval if periodic checkpointing is configured.
getCleanStart() - Method in interface com.ibm.streams.operator.control.RegionMonitorMXBean: Return true if the region experienced a clean start.
getConfiguredHost() - Method in interface com.ibm.streams.operator.ProcessingElement: Get the host this PE is executing on.
getConfiguredHostName() - Method in interface com.ibm.streams.operator.management.ProcessingElementMXBean: Get the host name this PE is executing on.
getConnections() - Method in interface com.ibm.streams.flow.declare.PortDeclaration: Get the list of connections for this port.
getConsistentRegionMXBeanName() - Method in interface com.ibm.streams.operator.state.ConsistentRegionContext: Get the object name of the ConsistentRegionMXBean MBean registered with the Job Control Plane.
getControlPlaneContext() - Method in class com.ibm.streams.operator.AbstractOperator: Get the optional ControlPlaneContext for the Job Control Plane in the application.
getCurrentContext() - Static method in class com.ibm.streams.operator.PERuntime: Get the operator context for the current operator.
getCustomMetric(String) - Method in interface com.ibm.streams.operator.metrics.OperatorMetrics: Return a custom metric either previously created by createCustomMetric or specified in the operator model.
getCustomMetrics() - Method in interface com.ibm.streams.operator.metrics.OperatorMetrics: Returns a read-only view of the operator's custom metrics.
getData() - Method in interface com.ibm.streams.operator.types.Blob: Get a copy of the data for this blob.
getData() - Method in class com.ibm.streams.operator.types.RString: Get the raw data for this value.
getDataDirectory() - Method in interface com.ibm.streams.operator.management.ProcessingElementMXBean: Return the absolute path of the data directory for the SPL application.
getDataDirectory() - Method in interface com.ibm.streams.operator.ProcessingElement: Return the data directory for the SPL application.
getDeclaredSchema() - Method in interface com.ibm.streams.operator.meta.XMLType: Get the schema of the XML attribute.
getDefaultValue() - Method in interface com.ibm.streams.operator.Type: Get an object that represents the default initial value for this type.
getDelegateHandler() - Method in class com.ibm.streams.operator.state.DelegateStateHandler
getDescription() - Method in interface com.ibm.streams.operator.management.MetricMXBean: Get the description of this metric.
getDescription() - Method in interface com.ibm.streams.operator.metrics.Metric: Get the description of this metric.
getDestination() - Method in class com.ibm.streams.flow.handlers.AbstractStreamForwarder: Get the current destination for the stream.
getDestination() - Method in class com.ibm.streams.flow.handlers.DynamicForwarder: Get the current destination for the stream.
getDestination() - Method in class com.ibm.streams.flow.handlers.StreamForwarder: Get the current destination for the stream.
getDomainId() - Method in interface com.ibm.streams.operator.management.ProcessingElementMXBean: Return the Streams domain identifier for this PE.
getDomainId() - Method in interface com.ibm.streams.operator.ProcessingElement: Return the Streams domain identifier for this PE.
getDouble(int) - Method in interface com.ibm.streams.operator.Tuple: Get an attribute as a primitive double.
getDouble(String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as a double using the attribute's name.
getDrainTimeout() - Method in interface com.ibm.streams.operator.control.ConsistentRegionMXBean: Gets the drain timeout as configured via the @consistent SPL annotation.
getDrainTimeout() - Method in interface com.ibm.streams.operator.state.ConsistentRegionContext: Get the drain timeout of the consistent region.
getElementType() - Method in interface com.ibm.streams.operator.meta.CollectionType: Return the Type of the elements in the Collection.
getEncodedSize(Tuple) - Method in interface com.ibm.streams.operator.encoding.BinaryEncoding: Get the maximum number of bytes required to write out a binary encoded version of a tuple using this encoding.
getEnum(Class<E>, int) - Method in interface com.ibm.streams.operator.Tuple: Get an attribute as an enumeration.
getEnum(Class<E>, String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as an enumeration using the attribute's name.
getEvictionPolicy() - Method in interface com.ibm.streams.operator.window.StreamWindow: Get the eviction policy for the window.
getExportType() - Method in interface com.ibm.streams.operator.StreamingOutput: Return how this port is exported.
getFix() - Method in class com.ibm.streams.operator.version.Version: Returns the fix level as an integer
getFloat(int) - Method in interface com.ibm.streams.operator.Tuple: Get an attribute as a primitive float.
getFloat(String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as a float using the attribute's name.
getGenericJSONEncoding() - Static method in class com.ibm.streams.operator.encoding.EncodingFactory: Create a JSONEncoding instance that supports conversion of tuples and attribute values into JSON data structures using standard collection types java.util.Map and java.util.List.
getHandlers() - Method in class com.ibm.streams.flow.handlers.HandlerCollection: Get the handler collection.
getHandlers() - Method in class com.ibm.streams.operator.state.OrderedStateHandlers
getHealth() - Method in interface com.ibm.streams.operator.control.RegionMonitorMXBean: Health of the region as an aggregation of the health of PE's within the region.
getIdentifiers() - Method in interface com.ibm.streams.operator.meta.EnumType: Get the list of identifiers declared for this SPL enumeration.
getImplementationClassName() - Method in interface com.ibm.streams.operator.management.OperatorContextMXBean: Get the Java class name implementing the operator
getImportType() - Method in interface com.ibm.streams.operator.StreamingInput: Return the type of this port's import.
getIndex() - Method in interface com.ibm.streams.operator.Attribute: Get the logical index (zero based) of the attribute in the tuple.
getIndex() - Method in interface com.ibm.streams.operator.control.ConsistentRegionMXBean: Returns the index of the consistent region.
getIndex() - Method in interface com.ibm.streams.operator.state.ConsistentRegionContext: Get the region index.
getInitializedState(Object, List<Tuple>) - Method in class com.ibm.streams.operator.window.sort.SortedTupleWindow: Return a new linked list each time.
getInitializedState(Object, S) - Method in class com.ibm.streams.operator.window.StatefulWindowListener: Get an initialized state object for the given partition.
getInput() - Method in interface com.ibm.streams.flow.declare.StreamConnection: The declaration for the input port that will receive tuples and punctuation marks.
getInput(int) - Method in class com.ibm.streams.operator.AbstractOperator: Shorthand method to get the StreamingInput object for a given port.
getInputPort() - Method in interface com.ibm.streams.operator.window.StreamWindow: Get the StreamingInput reference for the input port this window is for.
getInputPortMetric(int, OperatorMetrics.InputPortMetric) - Method in interface com.ibm.streams.operator.metrics.OperatorMetrics: Get a read-only Metric for a specific operator input port.
getInputPortMetric(int, PEMetrics.InputPortMetric) - Method in interface com.ibm.streams.operator.metrics.PEMetrics: Get a read-only Metric for a specific processing element input port.
getInputPorts() - Method in interface com.ibm.streams.operator.state.ConsistentRegionContext: Return the set of this operators input ports that are part of this consistent region.
getInputStream() - Method in interface com.ibm.streams.operator.state.Checkpoint: Provides an ObjectInputStream object that can be used to read data stored in the checkpoint.
getInputStream() - Method in interface com.ibm.streams.operator.types.Blob: Return an InputStream representing the value positioned at the first byte.
getInputStream() - Method in interface com.ibm.streams.operator.types.XML: Get the byte stream for this document with character encoding specified by the XML declaration
getInputTester(InputPortDeclaration) - Method in interface com.ibm.streams.flow.javaprimitives.JavaTestableGraph: Obtain a StreamingOutput that can be used to submit test tuples and punctuation marks to a disconnected input port.
getInstanceId() - Method in interface com.ibm.streams.operator.management.ProcessingElementMXBean: Return the Streams instance identifier for this PE.
getInstanceId() - Method in interface com.ibm.streams.operator.ProcessingElement: Return the Streams instance identifier for this PE.
getInt(int) - Method in interface com.ibm.streams.operator.Tuple: Get an attribute as a primitive int.
getInt(String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as an int using the attribute's name.
getJobGroup() - Method in interface com.ibm.streams.operator.management.ProcessingElementMXBean: Return the name of the job group for the job the PE is running in.
getJobGroup() - Method in interface com.ibm.streams.operator.ProcessingElement: Return the name of the job group for the job the PE is running in.
getJobId() - Method in interface com.ibm.streams.operator.control.ControlPlaneMXBean: Get the job identifier.
getJobId() - Method in interface com.ibm.streams.operator.management.ProcessingElementMXBean: Get the runtime identifier for job containing this processing element.
getJobId() - Method in interface com.ibm.streams.operator.ProcessingElement: Get the runtime identifier for job containing this processing element.
getJobName() - Method in interface com.ibm.streams.operator.management.ProcessingElementMXBean: Return the name of the job the PE is running in.
getJobName() - Method in interface com.ibm.streams.operator.ProcessingElement: Return the name of the job the PE is running in.
getJSONEncoding() - Static method in class com.ibm.streams.operator.encoding.EncodingFactory: Create a JSONEncoding instance that supports conversion of tuples and attribute values into JSON data structures using JSON4J com.ibm.json.java.
getKeyType() - Method in interface com.ibm.streams.operator.meta.MapType: Return the Type of the keys in the map.
getKind() - Method in interface com.ibm.streams.operator.management.MetricMXBean: Get the kind of this metric.
getKind() - Method in interface com.ibm.streams.operator.metrics.Metric: Get the kind of this metric.
getKind() - Method in interface com.ibm.streams.operator.OperatorContext: Get the SPL primitive operator kind that is executing the this operator.
getKind() - Method in interface com.ibm.streams.operator.state.CheckpointContext: Return the kind of the configured checkpointing.
getLanguageType() - Method in interface com.ibm.streams.operator.StreamSchema: Return the tuple definition for this schema.
getLanguageType() - Method in interface com.ibm.streams.operator.Type: Returns the type name as it appears in SPL.
getLanguageType() - Method in enum com.ibm.streams.operator.Type.MetaType: Returns the type name as it appears in SPL, null if it is a composite type that does not have a single representation in SPL.
getLastCompletedSequenceID() - Method in interface com.ibm.streams.operator.control.ConsistentRegionMXBean: Gets the identifier of the last successfully completed drain.
getLength() - Method in interface com.ibm.streams.operator.types.Blob: Get the number of bytes in this blob.
getLength() - Method in class com.ibm.streams.operator.types.RString: Get the number of bytes in the rstring value.
getList(int) - Method in interface com.ibm.streams.operator.Tuple: Get an attribute as a List.
getList(String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as a java.util.List using the attribute's name.
getLogicalName() - Method in interface com.ibm.streams.operator.management.OperatorContextMXBean: Get the logical name of the operator.
getLogicalName() - Method in interface com.ibm.streams.operator.OperatorContext: Get the logical name of the operator.
getLong(int) - Method in interface com.ibm.streams.operator.Tuple: Get an attribute as a primitive long.
getLong(String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as a long using the attribute's name.
getMachineId() - Method in class com.ibm.streams.operator.types.Timestamp: Return the application specific machine identifier associated with this timestamp.
getMap(int) - Method in interface com.ibm.streams.operator.Tuple: Get an attribute as a Map.
getMap(String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as a java.util.Map using the attribute's name.
getMarkCount(StreamingData.Punctuation) - Method in class com.ibm.streams.flow.handlers.StreamCounter: Return the number of punctuation marks of type mark that are seen on the stream.
getMathContext() - Method in enum com.ibm.streams.operator.Type.MetaType: Return a suitable MathContext.
getMaxChannels() - Method in interface com.ibm.streams.operator.management.OperatorContextMXBean: Get the total number of parallel channels for the parallel region that the operator is in.
getMaxChannels() - Method in interface com.ibm.streams.operator.OperatorContext: Get the total number of parallel channels for the parallel region that the operator is in.
getMaxConsecutiveResetAttempts() - Method in interface com.ibm.streams.operator.control.ConsistentRegionMXBean: Gets the maximum number of consecutive reset attempts as configured via the @consistent SPL annotation.
getMetaType() - Method in interface com.ibm.streams.operator.Type: Return the enumeration representing the meta-type.
getMetaTypeInteface() - Method in enum com.ibm.streams.operator.Type.MetaType: Get the interface that provide the meta-data about the type.
getMetric(OperatorContext, int) - Method in enum com.ibm.streams.operator.metrics.OperatorMetrics.InputPortMetric: Convenience method to get the metric for a specific operator port.
getMetric(OperatorContext, int) - Method in enum com.ibm.streams.operator.metrics.OperatorMetrics.OutputPortMetric: Convenience method to get the Metric for a specific operator port.
getMetric(OperatorContext, int) - Method in enum com.ibm.streams.operator.metrics.PEMetrics.InputPortMetric: Convenience method to get the Metric for a specific processing element port.
getMetric(OperatorContext, int) - Method in enum com.ibm.streams.operator.metrics.PEMetrics.OutputPortMetric: Convenience method to get the Metric for a specific processing element port.
getMetrics() - Method in interface com.ibm.streams.operator.OperatorContext: Get the OperatorMetrics object for access to metrics specific to this operator.
getMetrics() - Method in interface com.ibm.streams.operator.ProcessingElement: Get the metrics information for this processing element.
getMod() - Method in class com.ibm.streams.operator.version.Version: Returns the modification level as an integer
getMostRecentMark() - Method in class com.ibm.streams.flow.handlers.MostRecent: Return the most recent punctuation that is seen on the stream.
getMostRecentTuple() - Method in class com.ibm.streams.flow.handlers.MostRecent: Return the most recent tuple that is seen on the stream.
getName() - Method in interface com.ibm.streams.flow.declare.OperatorInvocation: Get the complete name of the operator.
getName() - Method in interface com.ibm.streams.operator.Attribute: Get the name of this attribute.
getName() - Method in interface com.ibm.streams.operator.control.ConsistentRegionMXBean: Get the name of the consistent region.
getName() - Method in interface com.ibm.streams.operator.control.RegionMonitorMXBean: Return the name of region.
getName() - Method in class com.ibm.streams.operator.control.variable.AbstractControlVariable
getName() - Method in interface com.ibm.streams.operator.control.variable.BooleanControlVariableMXBean: Get the name of this control variable.
getName() - Method in interface com.ibm.streams.operator.control.variable.ControlVariableAccessor: Get the name of this control variable.
getName() - Method in interface com.ibm.streams.operator.control.variable.DoubleControlVariableMXBean: Get the name of this control variable.
getName() - Method in interface com.ibm.streams.operator.control.variable.LongControlVariableMXBean: Get the name of this control variable.
getName() - Method in interface com.ibm.streams.operator.control.variable.StringControlVariableMXBean: Get the name of this control variable.
getName() - Method in interface com.ibm.streams.operator.management.MetricMXBean: Get the name of this metric.
getName() - Method in interface com.ibm.streams.operator.management.OperatorContextMXBean: Get the name of the operator.
getName(OperatorManagement.Type, String) - Static method in class com.ibm.streams.operator.management.OperatorManagement: Get the ObjectName for an MXBean in OperatorManagement.STREAMS_OPERATOR_JMX_DOMAIN.
getName(OperatorContext) - Static method in class com.ibm.streams.operator.management.OperatorManagement: Get the ObjectName for automatically registered OperatorContextMXBean for the OperatorContext.
getName() - Method in interface com.ibm.streams.operator.metrics.Metric: Get the name of this metric.
getName() - Method in interface com.ibm.streams.operator.OperatorContext: Get the name of the operator.
getName() - Method in interface com.ibm.streams.operator.StreamingData: Get the name for this port as defined in the application.
getNanoseconds() - Method in class com.ibm.streams.operator.types.Timestamp: Return nanoseconds portion of the time since the epoch.
getNumberOfInputPorts() - Method in interface com.ibm.streams.operator.ProcessingElement: Get the number of input ports for this processing element.
getNumberOfOutputPorts() - Method in interface com.ibm.streams.operator.ProcessingElement: Get the number of output ports for this processing element.
getNumberOfStreamingInputs() - Method in interface com.ibm.streams.operator.OperatorContext: Get the number of streaming input ports.
getNumberOfStreamingOutputs() - Method in interface com.ibm.streams.operator.OperatorContext: Get the number of output ports.
getObject(int) - Method in interface com.ibm.streams.operator.Tuple: Get the object representing the attribute's value at given index.
getObject(int, Class<T>) - Method in interface com.ibm.streams.operator.Tuple: Get an object of type T representing the attribute's value at given index.
getObject(String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as an Object using the attribute's name.
getObject(String, Class<T>) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as an object of type T using the attribute's name.
getObjectName() - Method in class com.ibm.streams.operator.control.NotifierSupport: Get this MBean's ObjectName.
getObjectType() - Method in interface com.ibm.streams.operator.Type: Get the type of the object returned for this type from a generic object based getter.
getOperatorClass() - Method in interface com.ibm.streams.flow.declare.OperatorInvocation: Get the class representing this operator invocation.
getOperatorContext() - Method in class com.ibm.streams.operator.AbstractOperator: Return the OperatorContext object describing the execution environment of this operator.
getOperatorContext() - Method in interface com.ibm.streams.operator.compile.OperatorContextChecker: Get the operator context for the operator's invocation.
getOperatorContext() - Method in interface com.ibm.streams.operator.window.StreamWindow: Return the OperatorContext for this window's operator invocation.
getOperatorContextMBean(String) - Method in interface com.ibm.streams.flow.javaprimitives.JavaTestableGraph: Return a proxy to the OperatorContextMXBean for the operator invocation named name.
getOperatorContextMBean(OperatorInvocation<? extends Operator>) - Method in interface com.ibm.streams.flow.javaprimitives.JavaTestableGraph: Return a proxy to the OperatorContextMXBean for an operator invocation.
getOperatorContextMXBean(OperatorContext) - Static method in class com.ibm.streams.operator.management.OperatorManagement: Get a proxy to the OperatorContextMXBean for context.
getOperatorInstance(OperatorInvocation<T>) - Method in interface com.ibm.streams.flow.javaprimitives.JavaTestableGraph: Return the reference to the instance of T executing in this graph for invocation represented by operator.
getOperatorSpecificName(String, OperatorManagement.Type, String, Hashtable<String, String>) - Static method in class com.ibm.streams.operator.management.OperatorManagement: Get the ObjectName for an MXBean specific to a named operator.
getOptionalContext(Class<O>) - Method in interface com.ibm.streams.operator.OperatorContext: Get an optional context for this operator invocation.
getOutput() - Method in interface com.ibm.streams.flow.declare.StreamConnection: The declaration for the output port that will submit tuples and punctuation marks.
getOutput(int) - Method in class com.ibm.streams.operator.AbstractOperator: Shorthand method to get the StreamingOutput object for a given port.
getOutputDirectory() - Method in interface com.ibm.streams.operator.management.ProcessingElementMXBean: Return the absolute path of the output directory for the compiled SPL application.
getOutputDirectory() - Method in interface com.ibm.streams.operator.ProcessingElement: Return the output directory for the compiled SPL application.
getOutputPortMetric(int, OperatorMetrics.OutputPortMetric) - Method in interface com.ibm.streams.operator.metrics.OperatorMetrics: Get a read-only Metric for a specific operator output port.
getOutputPortMetric(int, PEMetrics.OutputPortMetric) - Method in interface com.ibm.streams.operator.metrics.PEMetrics: Get a read-only Metric for a specific processing element output port.
getOutputStream() - Method in interface com.ibm.streams.operator.state.Checkpoint: Provides an ObjectOutputStream object that can be used to put data into the checkpoint.
getParameterNames() - Method in interface com.ibm.streams.operator.OperatorContext: Return the set of names for parameters that have values.
getParameterValues(String) - Method in interface com.ibm.streams.operator.OperatorContext: Returns the list of parameter values for the given parameter name.
getPartition() - Method in class com.ibm.streams.operator.window.StreamWindowEvent: The partition the event is for.
getPartition(T) - Method in interface com.ibm.streams.operator.window.StreamWindowPartitioner: Return the window's partition for the tuple.
getPartitions() - Method in interface com.ibm.streams.operator.window.StreamWindow: Get a read-only copy of the partition keys in the window.
getPartitionState(Object) - Method in class com.ibm.streams.operator.window.StatefulWindowListener: Return the state for the given partition.
getPE() - Method in interface com.ibm.streams.operator.OperatorContext: Get the processing element hosting this Operator
getPE() - Static method in class com.ibm.streams.operator.PERuntime: Get the processing element for the current operator.
getPEId() - Method in interface com.ibm.streams.operator.management.ProcessingElementMXBean: Get the runtime identifier for this processing element.
getPEId() - Method in interface com.ibm.streams.operator.ProcessingElement: Get the runtime identifier for this processing element.
getPEName(BigInteger) - Static method in class com.ibm.streams.operator.control.ControlPlaneManagement: Get the ObjectName for a com.ibm.streams.management.job.PeMXBean in this job in the Job Control Plane.
getPEName() - Static method in class com.ibm.streams.operator.management.OperatorManagement: Get the ObjectName for automatically registered ProcessingElementMXBean.
getPEPortNumber() - Method in interface com.ibm.streams.operator.StreamingData: Get the PE (processing element) port number index for this port.
getPeriod() - Method in interface com.ibm.streams.operator.control.ConsistentRegionMXBean: Gets the period of the consistent region as configured via the @consistent SPL annotation.
getPermitRunnable(Runnable) - Method in interface com.ibm.streams.operator.state.ConsistentRegionContext: Return a task that wraps task with permit acquisition and release for this region.
getPes() - Method in interface com.ibm.streams.operator.control.RegionMonitorMXBean: Return the set of processing elements containing all the operators in the monitored region.
getPort() - Method in interface com.ibm.streams.operator.TupleAttribute: The port whose schema includes the referenced attribute
getPortNumber() - Method in interface com.ibm.streams.operator.StreamingData: Get the port number as defined in the application.
getPortSet() - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration: Return the port set for this port if the operator class had an InputPortSet annotation.
getPortSet() - Method in interface com.ibm.streams.flow.declare.OutputPortDeclaration: Return the port set for this port if the operator class had an OutputPortSet annotation.
getProcessingElementMXBean() - Static method in class com.ibm.streams.operator.management.OperatorManagement: Get a proxy to the ProcessingElementMXBean registered for the current Processing Element.
getRelaunchCount() - Method in interface com.ibm.streams.operator.management.ProcessingElementMXBean: Return the number of times this PE has been relaunched.
getRelaunchCount() - Method in interface com.ibm.streams.operator.ProcessingElement: Return the number of times this PE has been relaunched.
getRelease() - Method in class com.ibm.streams.operator.version.Version: Returns the release level as an integer
getResetAttempt() - Method in interface com.ibm.streams.operator.state.ConsistentRegionContext: This method returns the current number of attempts of resetting a consistent region.
getResetTimeout() - Method in interface com.ibm.streams.operator.control.ConsistentRegionMXBean: Gets the reset timeout as configured via the @consistent SPL annotation.
getResetTimeout() - Method in interface com.ibm.streams.operator.state.ConsistentRegionContext: Get the reset timeout of the consistent region.
getScheduledExecutorService() - Method in interface com.ibm.streams.operator.OperatorContext: Return a scheduler to execute background tasks.
getSeconds() - Method in class com.ibm.streams.operator.types.Timestamp: Return seconds portion of the time since the epoch.
getSequenceId() - Method in interface com.ibm.streams.operator.state.Checkpoint: Sequence identifier of this checkpoint.
getSequenceId() - Method in interface com.ibm.streams.operator.state.ConsistentRegionContext: This method returns the current sequence identifier of a consistent region.
getServer() - Method in class com.ibm.streams.operator.control.NotifierSupport: Get the MBeanServer this MBean is registered in.
getSet(int) - Method in interface com.ibm.streams.operator.Tuple: Get an attribute as a Set.
getSet(String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as a java.util.Set using the attribute's name.
getShort(int) - Method in interface com.ibm.streams.operator.Tuple: Get an attribute as a primitive short.
getShort(String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as a short using the attribute's name.
getSQLTimestamp() - Method in class com.ibm.streams.operator.types.Timestamp: Return a SQL Timestamp object set from this Timestamp.
getState() - Method in interface com.ibm.streams.operator.control.ConsistentRegionMXBean: Returns a string indicating the current state of the consistent region.
getStreamingInputs() - Method in interface com.ibm.streams.operator.OperatorContext: Get the list of input ports.
getStreamingOutputs() - Method in interface com.ibm.streams.operator.OperatorContext: Get a list of output ports.
getStreamProperties() - Method in interface com.ibm.streams.operator.StreamingOutput: Get the collection of stream properties currently set for this output port.
getStreamPropertiesAsTuple() - Method in interface com.ibm.streams.operator.StreamingOutput: Get the collection of stream properties currently set for this output port.
getStreamSchema() - Method in interface com.ibm.streams.operator.StreamingData: Get the schema for this port.
getStreamSchema() - Method in interface com.ibm.streams.operator.Tuple: Get the StreamSchema for this Tuple.
getStreamSchema(String) - Static method in class com.ibm.streams.operator.Type.Factory: Get a StreamSchema for a schema described by a String.
getStreamSource() - Method in interface com.ibm.streams.operator.types.XML: Get a StreamSource for this document.
getStreamWindow() - Method in interface com.ibm.streams.operator.StreamingInput: Get the window configuration for this port.
getString(int) - Method in interface com.ibm.streams.operator.Tuple: Get an attribute as a String.
getString(String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as a String using the attribute's name.
getString() - Method in class com.ibm.streams.operator.types.RString: Return the value as a String using UTF-8 encoding.
getString(String) - Method in class com.ibm.streams.operator.types.RString: Return the value as a String using the defined character set encoding.
getString(Charset) - Method in class com.ibm.streams.operator.types.RString: Return the value as a String using the defined character set encoding.
getSubmissionSemaphore() - Method in interface com.ibm.streams.operator.state.ConsistentRegionContext: Get the semaphore used to control processing and tuple submission.
getThreadFactory() - Method in interface com.ibm.streams.operator.OperatorContext: Return a ThreadFactory specific to the Operator with the thread context class loader set correctly.
getThreadIds() - Method in interface com.ibm.streams.operator.management.OperatorContextMXBean: Return the current set of thread identifiers for live threads created by this operator's ThreadFactory.
getTime() - Method in class com.ibm.streams.operator.types.Timestamp: Get the value as a number of milliseconds.
getTimeAsSeconds() - Method in class com.ibm.streams.operator.types.Timestamp: Get the time in seconds (including the number of nanoseconds) as a BigDecimal.
getTimestamp() - Method in interface com.ibm.streams.operator.state.Checkpoint: Return the time (in millisecs) at which the checkpoint was created.
getTimestamp(int) - Method in interface com.ibm.streams.operator.Tuple: Get an attribute as a Timestamp.
getTimestamp(String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as a Timestamp using the attribute's name.
getTimestamp(long) - Static method in class com.ibm.streams.operator.types.Timestamp: Create a Timestamp from a number of milliseconds.
getTimestamp(long, int) - Static method in class com.ibm.streams.operator.types.Timestamp: Create a Timestamp from a number of milliseconds and a machine identifier.
getTimestamp(Timestamp) - Static method in class com.ibm.streams.operator.types.Timestamp: Convert a JDBC Timestamp to an SPL timestamp representation with its machine identifier set to zero.
getTimestamp(Timestamp, int) - Static method in class com.ibm.streams.operator.types.Timestamp: Convert a JDBC Timestamp to an SPL timestamp representation with a specified machine identifier.
getTimestamp(double) - Static method in class com.ibm.streams.operator.types.Timestamp: Create a timestamp from a double representing number of seconds with its machine identifier set to zero.
getTimestamp(BigDecimal) - Static method in class com.ibm.streams.operator.types.Timestamp: Create a timestamp from a BigDecimal representing number of seconds with its machine identifier set to zero.
getToolkitDirectory() - Method in interface com.ibm.streams.operator.OperatorContext: Get the root directory of the toolkit that declares the OperatorContext.getKind() of this operator invocation.
getTrigger() - Method in interface com.ibm.streams.operator.control.ConsistentRegionMXBean: Gets the trigger of the consistent region as configured via the @consistent SPL annotation.
getTriggerPolicy() - Method in interface com.ibm.streams.operator.window.StreamWindow: Get the trigger policy for a sliding window.
getTuple() - Method in interface com.ibm.streams.operator.StreamSchema: Return a Tuple for this schema with all attributes set to the default value.
getTuple(Tuple) - Method in interface com.ibm.streams.operator.StreamSchema: Return a Tuple for this schema with any matching attributes set from the supplied tuple.
getTuple(Map<String, ?>) - Method in interface com.ibm.streams.operator.StreamSchema: Return a Tuple for this schema with any attributes set from the supplied map based upon the attribute name being the key in the map.
getTuple(List<?>) - Method in interface com.ibm.streams.operator.StreamSchema: Return a Tuple for this schema with any attributes set from the supplied list by position.
getTuple(Object[]) - Method in interface com.ibm.streams.operator.StreamSchema: Return a Tuple for this schema with any attributes set from the supplied array by position.
getTuple(int) - Method in interface com.ibm.streams.operator.Tuple: Get an attribute as a Tuple.
getTuple(String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as a Tuple using the attribute's name.
getTupleCount() - Method in class com.ibm.streams.flow.handlers.StreamCollector: Get the number of tuples in the collection returned by StreamCollector.getTuples().
getTupleCount() - Method in class com.ibm.streams.flow.handlers.StreamCounter: Return the number of tuples that are seen on the stream.
getTuples() - Method in class com.ibm.streams.flow.handlers.StreamCollector: Get the tuple collection.
getTuples() - Method in class com.ibm.streams.operator.window.StreamWindowEvent: A sequence of tuples in arrival order, from oldest to most recent.
getTupleSchema() - Method in interface com.ibm.streams.operator.meta.TupleType: Get the schema of the tuple attribute.
getTupleType(String) - Static method in class com.ibm.streams.operator.Type.Factory: Get a TupleType for a tuple type described by a String.
getTupleType(Source) - Static method in class com.ibm.streams.operator.Type.Factory: Get a TupleType for a tuple type described by an XML representation of the schema using the tuple type model.
getTupleType(Node) - Static method in class com.ibm.streams.operator.Type.Factory: Get a TupleType for a tuple type described by an XML representation of the schema using the tuple type model.
getType() - Method in interface com.ibm.streams.operator.Attribute: Get the type information for this attribute.
getType() - Method in interface com.ibm.streams.operator.window.StreamWindow: Return the type of the window defined against the port.
getType() - Method in class com.ibm.streams.operator.window.StreamWindowEvent: The type of the event.
getValue() - Method in class com.ibm.streams.operator.control.variable.BooleanControlVariable: Get the value of this control variable.
getValue() - Method in interface com.ibm.streams.operator.control.variable.BooleanControlVariableMXBean: Get the value of this control variable.
getValue() - Method in interface com.ibm.streams.operator.control.variable.ControlVariableAccessor: Get the value of this control variable.
getValue() - Method in class com.ibm.streams.operator.control.variable.DoubleControlVariable: Get the value of this control variable.
getValue() - Method in interface com.ibm.streams.operator.control.variable.DoubleControlVariableMXBean: Get the value of this control variable.
getValue() - Method in class com.ibm.streams.operator.control.variable.LongControlVariable: Get the value of this control variable.
getValue() - Method in interface com.ibm.streams.operator.control.variable.LongControlVariableMXBean: Get the value of this control variable.
getValue() - Method in class com.ibm.streams.operator.control.variable.StringControlVariable: Get the value of this control variable.
getValue() - Method in interface com.ibm.streams.operator.control.variable.StringControlVariableMXBean: Get the value of this control variable.
getValue() - Method in interface com.ibm.streams.operator.management.MetricMXBean: Get the value of this metric.
getValue() - Method in interface com.ibm.streams.operator.metrics.Metric: Get the value of this metric.
getValue(T) - Method in interface com.ibm.streams.operator.TupleAttribute: The value of the attribute in the specified tuple.
getValueType() - Method in interface com.ibm.streams.operator.meta.MapType: Return the Type of the values in the map.
getVariableObjectName() - Method in interface com.ibm.streams.operator.control.variable.ControlVariableAccessor: Get the ObjectName of this control variable's MXBean in the Job Control Plane Mbean server.
getVersion() - Static method in class com.ibm.streams.operator.version.Product: Returns the product's version number
getVersion() - Method in class com.ibm.streams.operator.version.Version: Returns the version level as an integer
getWindow() - Method in class com.ibm.streams.operator.window.StatefulWindowListener: Get the window this object is handling.
getXML(int) - Method in interface com.ibm.streams.operator.Tuple: Get an attribute as an XML.
getXML(String) - Method in interface com.ibm.streams.operator.Tuple: Get the attribute as an XML using the attribute's name.
getXMLTupleType() - Method in interface com.ibm.streams.operator.StreamSchema: Return the tuple definition for this schema as document containing the XML tuple type model.
getXMLTupleType(String) - Method in interface com.ibm.streams.operator.StreamSchema: Return the tuple definition for this schema as document containing the XML tuple type model using namespacePrefix as the prefix for elements.
getXMLTupleTypeElement(Document, String) - Method in interface com.ibm.streams.operator.StreamSchema: Return the tuple definition for this schema as an Element for the XML document doc The caller must add the returned Element as a child to an existing Node in the document.
graph() - Method in interface com.ibm.streams.flow.declare.OperatorInvocation: Return the graph for this operator invocation.

H

handleEvent(StreamWindowEvent<Tuple>) - Method in class com.ibm.streams.operator.window.sort.SortedTupleWindow: Handle INSERTION and EVICTION events to maintain a sorted List of tuples in the window.
handleEvent(StreamWindowEvent<Tuple>) - Method in class com.ibm.streams.operator.window.sort.TumblingWindowSort: Handle a TUMBLING window events.
handleEvent(StreamWindowEvent<T>) - Method in interface com.ibm.streams.operator.window.StreamWindowListener: Handle a event from a StreamWindow.
HandlerCollection<S extends StreamHandler<T>,T> - Class in com.ibm.streams.flow.handlers: A StreamHandler that sends tuples and punctuation marks to a collection of StreamHandler instances.
HandlerCollection(Collection<S>) - Constructor for class com.ibm.streams.flow.handlers.HandlerCollection: Create a HandlerCollection.
hasDataDirectory() - Method in interface com.ibm.streams.operator.ProcessingElement: Does this job have a data directory.
hashCode() - Method in class com.ibm.streams.operator.types.RString: Returns a hash code for this RString.
hashCode() - Method in class com.ibm.streams.operator.types.Timestamp: Returns a hash code for this Timestamp.
hashCode() - Method in class com.ibm.streams.operator.version.Version

I

IBM_COPYRIGHT - Static variable in class com.ibm.streams.flow.declare.OperatorGraphFactory
IBM_COPYRIGHT - Static variable in class com.ibm.streams.flow.handlers.AbstractStreamForwarder
IBM_COPYRIGHT - Static variable in class com.ibm.streams.flow.handlers.DynamicForwarder
IBM_COPYRIGHT - Static variable in class com.ibm.streams.flow.handlers.HandlerCollection
IBM_COPYRIGHT - Static variable in class com.ibm.streams.flow.handlers.MostRecent
IBM_COPYRIGHT - Static variable in class com.ibm.streams.flow.handlers.StreamCollector
IBM_COPYRIGHT - Static variable in class com.ibm.streams.flow.handlers.StreamCounter
IBM_COPYRIGHT - Static variable in class com.ibm.streams.flow.handlers.StreamDiscarder
IBM_COPYRIGHT - Static variable in class com.ibm.streams.flow.handlers.StreamForwarder
IBM_COPYRIGHT - Static variable in class com.ibm.streams.flow.javaprimitives.JavaOperatorTester
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.AbstractOperator
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.control.AbstractPersistentControlMBean
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.control.ControlPlaneManagement
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.control.NotifierSupport
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.control.variable.AbstractControlVariable
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.control.variable.BooleanControlVariable
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.control.variable.DoubleControlVariable
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.control.variable.LongControlVariable
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.control.variable.StringControlVariable
IBM_COPYRIGHT - Static variable in exception com.ibm.streams.operator.DataException
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.encoding.EncodingFactory
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.log4j.LogLevel
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.log4j.TraceLevel
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.logging.LogLevel
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.logging.TraceLevel
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.management.OperatorLifeCycle
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.management.OperatorManagement
IBM_COPYRIGHT - Static variable in interface com.ibm.streams.operator.meta.MapType
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.PERuntime
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.state.DelegateStateHandler
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.state.OrderedStateHandlers
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.Type.Factory
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.types.RString
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.types.Timestamp
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.types.ValueFactory
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.window.AbstractWindowOperator
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.window.sort.SortedTupleWindow
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.window.sort.TumblingWindowSort
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.window.StatefulWindowListener
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.window.StreamWindowEvent
IBM_COPYRIGHT - Static variable in class com.ibm.streams.operator.window.WindowUtilities
Icons - Annotation Type in com.ibm.streams.operator.model: Declare a set of icon files for the operator.
increment() - Method in interface com.ibm.streams.operator.metrics.Metric: Increment the value of this metric by one.
incrementValue(long) - Method in interface com.ibm.streams.operator.metrics.Metric: Increment the value of this metric.
INFO - Static variable in class com.ibm.streams.operator.log4j.LogLevel: INFO is level indicating general information outlining overall operator progress.
INFO - Static variable in class com.ibm.streams.operator.log4j.TraceLevel: INFO is level indicating general information outlining overall operator progress.
INFO - Static variable in class com.ibm.streams.operator.logging.LogLevel: INFO is level indicating general information outlining overall operator progress.
INFO - Static variable in class com.ibm.streams.operator.logging.TraceLevel: INFO is level indicating general information outlining overall operator progress.
initialize() - Method in interface com.ibm.streams.flow.javaprimitives.JavaTestableGraph: Asynchronously initialize all the Operator invocations in the graph.
initialize(OperatorContext) - Method in class com.ibm.streams.operator.AbstractOperator: Initialize this operator.
initialize(OperatorContext) - Method in interface com.ibm.streams.operator.Operator: Initialize this operator.
initialize(OperatorContext) - Method in class com.ibm.streams.operator.window.AbstractWindowOperator: Initialize this operator.
initialize() - Method in interface com.ibm.streams.operator.window.CheckpointableWindowListener
InputPortDeclaration - Interface in com.ibm.streams.flow.declare: Declaration of an input port for an OperatorInvocation.
InputPortDeclaration.CongestionPolicy - Enum in com.ibm.streams.flow.declare
InputPorts - Annotation Type in com.ibm.streams.operator.model: Declare a set of input port sets for an operator.
InputPortSet - Annotation Type in com.ibm.streams.operator.model: Declare a single input port set.
InputPortSet.WindowMode - Enum in com.ibm.streams.operator.model: Enumeration containing the types of windowing semantics supported by an operator.
InputPortSet.WindowPunctuationInputMode - Enum in com.ibm.streams.operator.model: Enumeration listing the types of punctuation semantics that can be supported by a port.
insertionsOccurred(Object) - Method in class com.ibm.streams.operator.window.StatefulWindowListener: Has this partition had a tuple inserted into it.
isAllPortsReady() - Method in interface com.ibm.streams.operator.management.OperatorContextMXBean: Has the operator been notified of port readiness.
isApplicable(OperatorContext) - Method in interface com.ibm.streams.operator.control.Controllable: Is this Controllable applicable for this operator invocation.
isCollectionType() - Method in enum com.ibm.streams.operator.Type.MetaType: Is the type a SPL collection type.
isConnected() - Method in interface com.ibm.streams.flow.declare.PortDeclaration: Is the port connected in the graph.
isConnectedToDomain() - Method in interface com.ibm.streams.operator.control.ControlPlaneMXBean: Does this Job Control Plane have an open connection to the Domain JMX.
isConnectedToPEPort() - Method in interface com.ibm.streams.operator.StreamingData: Is this port connected to a PE (processing element) port.
isContextValid() - Method in interface com.ibm.streams.operator.compile.OperatorContextChecker: Is the invocation context valid so far.
isControl() - Method in interface com.ibm.streams.operator.StreamingInput: Is the port a control port.
isDebugging() - Method in interface com.ibm.streams.operator.ProcessingElement: Return if the PE is running under debug mode.
isDefaultValue() - Method in interface com.ibm.streams.operator.types.XML: Is this value the default value for an SPL xml attribute.
isEnabled() - Method in interface com.ibm.streams.operator.state.CheckpointContext: Return whether checkpointing/restore is enabled.
isEndOfRegion() - Method in interface com.ibm.streams.operator.state.ConsistentRegionContext: Check if this operator is an end of a consistent region.
isExported() - Method in interface com.ibm.streams.operator.StreamingOutput: Does this port produce an exported (dynamic) stream.
isImported() - Method in interface com.ibm.streams.operator.StreamingInput: Is the port importing an exported stream.
isList() - Method in enum com.ibm.streams.operator.Type.MetaType: Is the type a SPL list type.
isMap() - Method in enum com.ibm.streams.operator.Type.MetaType: Is the type a SPL map type.
isOptimized() - Method in interface com.ibm.streams.operator.ProcessingElement: Return if the PE is running under optimized mode.
isPartitioned() - Method in interface com.ibm.streams.operator.window.StreamWindow: Is this window partitioned.
isProfilingOn() - Method in interface com.ibm.streams.operator.ProcessingElement: Return if the PE has profiling turned on.
isRunning() - Method in interface com.ibm.streams.operator.control.RegionMonitorMXBean: Is the region running.
isSet() - Method in enum com.ibm.streams.operator.Type.MetaType: Is the type a SPL set type.
isShutdown() - Method in interface com.ibm.streams.operator.management.OperatorContextMXBean: Has the operator been notified of shutdown..
isStandalone() - Method in interface com.ibm.streams.operator.management.ProcessingElementMXBean: Return true if this processing element is running in standalone mode.
isStandalone() - Method in interface com.ibm.streams.operator.ProcessingElement: Return true if this processing element is running in standalone mode.
isStartOfRegion() - Method in interface com.ibm.streams.operator.state.ConsistentRegionContext: Check if this operator is a start of a consistent region.
isTriggerOperator() - Method in interface com.ibm.streams.operator.state.ConsistentRegionContext: Check if the operator is the trigger operator of a consistent cut region.
iterator() - Method in interface com.ibm.streams.operator.StreamSchema: Returns an iterator of the attributes in this schema.

J

JavaOperatorTester - Class in com.ibm.streams.flow.javaprimitives: Utility methods for testing OperatorGraph instances that contain implementations of Operator.
JavaOperatorTester() - Constructor for class com.ibm.streams.flow.javaprimitives.JavaOperatorTester
JavaTestableGraph - Interface in com.ibm.streams.flow.javaprimitives: An executable flow graph of Java primitive operators with support for disconnected input and output ports.
JOB_CONTROL_PLANE - Static variable in class com.ibm.streams.operator.control.ControlPlaneManagement: Nameservice prefix for the entries that correspond to JMX URLS for the Job Control Plane.
JOB_NAME - Static variable in class com.ibm.streams.operator.control.ControlPlaneManagement: The ObjectName name for the com.ibm.streams.management.job.JobMXBean that is registered in the Job Control Plane MBean server.
JSONEncoding<O extends java.util.Map,A extends java.util.List> - Interface in com.ibm.streams.operator.encoding: Interface to encode Tuples into JSON (JavaScript Object Notation) data structures.

L

Libraries - Annotation Type in com.ibm.streams.operator.model: Declare a set of Java class libraries to be added to the operator's class loader at execution time.
LOG_FACILITY - Static variable in interface com.ibm.streams.operator.log4j.LoggerNames: Name for the Logger to be used to send log messages to the SPL log facility.
LOG_FACILITY - Static variable in interface com.ibm.streams.operator.logging.LoggerNames: Name for the Logger to be used to send log messages to the SPL log facility.
LoggerNames - Interface in com.ibm.streams.operator.log4j: Apache log4j Logger names with a specific purpose for Java operators.
LoggerNames - Interface in com.ibm.streams.operator.logging: Names for instances of java.util.logging.Logger with a specific purpose for the Java Operator API.
LogLevel - Class in com.ibm.streams.operator.log4j: Convenience class to provide SPL log levels through the org.apache.log4j facility.
LogLevel - Class in com.ibm.streams.operator.logging: Convenience class to provide SPL log levels through the java.util.logging facility.
LongControlVariable - Class in com.ibm.streams.operator.control.variable: Provides the implementation of the long control variable MBean.
LongControlVariable() - Constructor for class com.ibm.streams.operator.control.variable.LongControlVariable: Create a LongControlVariableMXBean with no initial value.
LongControlVariable(long) - Constructor for class com.ibm.streams.operator.control.variable.LongControlVariable: Create a LongControlVariableMXBean with an initial value.
LongControlVariableMXBean - Interface in com.ibm.streams.operator.control.variable: MXBean representing a long control variable.

M

makeConsistent() - Method in interface com.ibm.streams.operator.state.ConsistentRegionContext: Make the region consistent by draining processing and checkpointing state.
MapType - Interface in com.ibm.streams.operator.meta: Meta-type for an attribute of type MAP.
mark(StreamingData.Punctuation) - Method in class com.ibm.streams.flow.handlers.AbstractStreamForwarder: Send the punctuation mark to the destination that is returned by AbstractStreamForwarder.getDestination().
mark(StreamingData.Punctuation) - Method in class com.ibm.streams.flow.handlers.HandlerCollection: Propagate the punctuation mark to each handler in the collection.
mark(StreamingData.Punctuation) - Method in class com.ibm.streams.flow.handlers.MostRecent: Save the most recent punctuation mark.
mark(StreamingData.Punctuation) - Method in class com.ibm.streams.flow.handlers.StreamCollector: No action is taken with punctuation marks.
mark(StreamingData.Punctuation) - Method in class com.ibm.streams.flow.handlers.StreamCounter: Count the number of punctuation marks.
mark(StreamingData.Punctuation) - Method in class com.ibm.streams.flow.handlers.StreamDiscarder: Do nothing with the mark.
mark(StreamingData.Punctuation) - Method in interface com.ibm.streams.flow.handlers.StreamHandler: Process a punctuation mark.
Metric - Interface in com.ibm.streams.operator.metrics: A metric represents a measurement of an element in either an operator or a processing element.
Metric.Kind - Enum in com.ibm.streams.operator.metrics: Kind of metric.
METRIC_PROPERTY - Static variable in interface com.ibm.streams.operator.management.MetricMXBean: Property key in the registered bean's object name that defines the type of the metric.
MetricMXBean - Interface in com.ibm.streams.operator.management: The management bean for a Metric.
MetricMXBean.MetricType - Enum in com.ibm.streams.operator.management: Type of metrics represented by a MetricMXBean
MGMT_NAME - Static variable in class com.ibm.streams.operator.control.ControlPlaneManagement: The ObjectName name for the ControlPlaneMXBean that is registered in the Job Control Plane MBean server.
MLET_NAME - Static variable in class com.ibm.streams.operator.control.ControlPlaneManagement: The ObjectName name for the javax.management.loading.MLetMBean that is registered in the Job Control Plane MBean server.
MostRecent<T> - Class in com.ibm.streams.flow.handlers: Keeps track of the most recent tuple and punctuation mark that are seen on a stream.
MostRecent() - Constructor for class com.ibm.streams.flow.handlers.MostRecent

N

Namespace - Annotation Type in com.ibm.streams.operator.model: Declares a default SPL namespace for SPL artifacts in the annotated package.
needsPartitionEviction() - Method in interface com.ibm.streams.operator.window.StreamWindow: Determine if partition eviction is required according to policy.
newBlob(ByteBuffer, int) - Static method in class com.ibm.streams.operator.types.ValueFactory: Create an Blob value from a byte stream contained in a ByteBuffer.
newBlob(RString) - Static method in class com.ibm.streams.operator.types.ValueFactory: Create a new Blob with the raw byte contents of an RString.
newBlob(byte[], int, int) - Static method in class com.ibm.streams.operator.types.ValueFactory: Create an Blob value from an array of bytes.
newBlob(byte[]) - Static method in class com.ibm.streams.operator.types.ValueFactory: Create an Blob value from an array of bytes.
newCharacterEncoding() - Method in interface com.ibm.streams.operator.StreamSchema: Create a CharacterEncoding instance that implements SPL character encoding for this schema.
newComplex32(CharSequence) - Static method in class com.ibm.streams.operator.types.ValueFactory: Create a Complex representing a complex32 from its SPL character encoding format of (real, imaginary).
newComplex64(CharSequence) - Static method in class com.ibm.streams.operator.types.ValueFactory: Create a Complex representing a complex64 from its SPL character encoding format of (real, imaginary).
newGraph() - Static method in class com.ibm.streams.flow.declare.OperatorGraphFactory: Create a new, empty OperatorGraph.
newJSONArray() - Method in interface com.ibm.streams.operator.encoding.JSONEncoding: Return a new JSONObject.
newJSONEncoding(Class<O>, Class<A>) - Static method in class com.ibm.streams.operator.encoding.EncodingFactory: Create a JSONEncoding instance that supports conversion of tuples and attribute values into JSON data structures using JSON library types that extend standard collection types java.util.Map and java.util.List.
newJSONObject() - Method in interface com.ibm.streams.operator.encoding.JSONEncoding: Return a new JSONObject.
newLinkedListCollector() - Static method in class com.ibm.streams.flow.handlers.StreamCollector: Create a new StreamCollector that uses a LinkedList to collect tuples.
newNativeBinaryEncoding(StreamSchema) - Static method in class com.ibm.streams.operator.encoding.EncodingFactory: Create a BinaryEncoding instance that implements SPL non-NBF, native binary encoding.
newNativeBinaryEncoding() - Method in interface com.ibm.streams.operator.StreamSchema: Create a BinaryEncoding instance that implements SPL non-NBF, native binary encoding.
newTuple() - Method in interface com.ibm.streams.operator.StreamingOutput: Return a new tuple that can be sent using this port.
newXML(InputStream) - Static method in class com.ibm.streams.operator.types.ValueFactory: Create an XML document value from a byte stream.
newXML(ByteBuffer, int) - Static method in class com.ibm.streams.operator.types.ValueFactory: Create an XML document value from a byte stream contained in a ByteBuffer.
newXML(Transformer, Source) - Static method in class com.ibm.streams.operator.types.ValueFactory: Create an XML document value from an XML source input.
nextSequence() - Method in class com.ibm.streams.operator.control.NotifierSupport
NotifierSupport<T> - Class in com.ibm.streams.operator.control: Abstract MBean implementation with notification support.
NotifierSupport(MBeanNotificationInfo...) - Constructor for class com.ibm.streams.operator.control.NotifierSupport: Create an instance of this MBean.

O

off() - Method in class com.ibm.streams.operator.control.variable.BooleanControlVariable: Set this control variable to false.
off() - Method in interface com.ibm.streams.operator.control.variable.BooleanControlVariableMXBean: Set this control variable to false.
on() - Method in class com.ibm.streams.operator.control.variable.BooleanControlVariable: Set this control variable to true.
on() - Method in interface com.ibm.streams.operator.control.variable.BooleanControlVariableMXBean: Set this control variable to true.
operator() - Method in interface com.ibm.streams.flow.declare.PortDeclaration: Get the operator invocation for this port.
Operator - Interface in com.ibm.streams.operator: Operator for processing and producing streams of tuples.
Operator.TagNames - Interface in com.ibm.streams.operator: Tag names for use with Operator#setTagData(String, Map.
OperatorContext - Interface in com.ibm.streams.operator: Context information for the Operator's execution context.
OperatorContext.ContextCheck - Annotation Type in com.ibm.streams.operator: A method annotated @ContextCheck allows checking of an operator's invocation context.
OperatorContextChecker - Interface in com.ibm.streams.operator.compile: Interface for checking a Java primitive operator is being invoked with a valid context.
OperatorContextMXBean - Interface in com.ibm.streams.operator.management: The management bean for a Java operator's context.
OperatorGraph - Interface in com.ibm.streams.flow.declare: OperatorGraph represents a declaration of a flow graph that contains Java primitive operators.
OperatorGraphFactory - Class in com.ibm.streams.flow.declare: Factory that creates OperatorGraph instances.
OperatorGraphFactory() - Constructor for class com.ibm.streams.flow.declare.OperatorGraphFactory
OperatorIGC - Static variable in interface com.ibm.streams.operator.Operator.TagNames
OperatorInvocation<T> - Interface in com.ibm.streams.flow.declare: Declaration of an invocation of a Java operator in an OperatorGraph.
OperatorLifeCycle - Class in com.ibm.streams.operator.management: Utility methods to interface with an operator's life cycle.
OperatorLifeCycle() - Constructor for class com.ibm.streams.operator.management.OperatorLifeCycle
OperatorManagement - Class in com.ibm.streams.operator.management: Utility code for working with an operator's MXBeans.
OperatorManagement.Type - Enum in com.ibm.streams.operator.management: Enumeration of names for an ObjectName's type key property for MXBeans in OperatorManagement.STREAMS_OPERATOR_JMX_DOMAIN.
OperatorMetrics - Interface in com.ibm.streams.operator.metrics: OperatorMetrics provides access to metrics related to an operator and its ports.
OperatorMetrics.InputPortMetric - Enum in com.ibm.streams.operator.metrics: Enumeration representing metric names for operator input ports.
OperatorMetrics.OutputPortMetric - Enum in com.ibm.streams.operator.metrics: Enumeration representing metric names for operator output ports.
OptionalContext - Interface in com.ibm.streams.operator: An invocation of an operator may have optional contexts, that provide information specific to a particular environment, such as a consistent region.
OrderedStateHandlers - Class in com.ibm.streams.operator.state: TODO
OrderedStateHandlers(StateHandler...) - Constructor for class com.ibm.streams.operator.state.OrderedStateHandlers
OutputPortDeclaration - Interface in com.ibm.streams.flow.declare: Declaration of output port for an OperatorInvocation.
OutputPorts - Annotation Type in com.ibm.streams.operator.model: Declare a set of output port sets for an operator.
OutputPortSet - Annotation Type in com.ibm.streams.operator.model: Declare a single output port set.
OutputPortSet.WindowPunctuationOutputMode - Enum in com.ibm.streams.operator.model: Enumeration that lists the types of window punctuation semantics supported by an operator.
OutputTuple - Interface in com.ibm.streams.operator: A mutable object that represents a tuple that can be submitted on an output port using the interface StreamingOutput.





P

Parameter - Annotation Type in com.ibm.streams.operator.model

Declare a relationship between an
 Operator's Java bean property and an SPL operator invocation parameter.

partitioned() - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration

Set the window for this input port to be partitioned.

partitionEvictionAge(double) - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration

Set the window partition eviction policy to be age based.

partitionEvictionAge(long, TimeUnit) - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration

Set the window partition eviction policy to be age based.

partitionEvictionCount(int) - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration

Set the window partition eviction policy to partition count based.

partitionEvictionTupleCount(int) - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration

Set the window partition eviction policy to tuple count based.

PE_USER_REQUEST - Static variable in interface com.ibm.streams.operator.control.RegionMonitorMXBean

Notification that a PE in the region was stopped or restarted
 by a user request.

PEMetrics - Interface in com.ibm.streams.operator.metrics

PEMetrics provides access to metrics related to an
 processing element's ports.

PEMetrics.InputPortMetric - Enum in com.ibm.streams.operator.metrics

Enumeration representing metric names for processing element input ports.

PEMetrics.OutputPortMetric - Enum in com.ibm.streams.operator.metrics

Enumeration representing metric names for processing element output ports.

persistControlState(byte[]) - Method in class com.ibm.streams.operator.control.AbstractPersistentControlMBean

Persist control state for this MBean using
 ControlPlaneMXBean#persistControlState(ObjectName, byte[]).

persistControlState(ObjectName, byte[]) - Method in interface com.ibm.streams.operator.control.ControlPlaneMXBean

Persist control state for a registered MBean.

PersistentControlMBean - Interface in com.ibm.streams.operator.control

Control state persistence for MBeans in the Job Control Plane (JCP).

PERuntime - Class in com.ibm.streams.operator

Utility methods to get information about the
 current processing element and operator context.

PERuntime() - Constructor for class com.ibm.streams.operator.PERuntime
 
PortDeclaration<T extends PortDeclaration<T>> - Interface in com.ibm.streams.flow.declare

Declaration of a port for an OperatorInvocation.

postDeregister() - Method in class com.ibm.streams.operator.control.NotifierSupport

Actions the MBean takes after it has been unregistered from an MBean server.

postRegister(Boolean) - Method in class com.ibm.streams.operator.control.NotifierSupport

Actions the MBean takes after it has been registered in an MBean server.

preDeregister() - Method in class com.ibm.streams.operator.control.NotifierSupport

Actions the MBean takes before it is unregistered from an MBean server.

preRegister(MBeanServer, ObjectName) - Method in class com.ibm.streams.operator.control.NotifierSupport

Actions the MBean takes before it is registered in an MBean server.

preRegister(MBeanServer, ObjectName) - Method in class com.ibm.streams.operator.control.variable.AbstractControlVariable
 
PrimitiveOperator - Annotation Type in com.ibm.streams.operator.model

Declares a Java primitive operator.

process(StreamingInput<Tuple>, Tuple) - Method in class com.ibm.streams.operator.AbstractOperator

Process an incoming tuple that arrived on the specified port.

process(StreamingInput<Tuple>, Tuple) - Method in interface com.ibm.streams.operator.Operator

Process an incoming tuple that arrived on the specified port.

process(StreamingInput<Tuple>, Tuple) - Method in class com.ibm.streams.operator.window.AbstractWindowOperator

Final method that does nothing, all tuple processing
 will be handled through the registered instances of
 StreamWindowListener.

ProcessingElement - Interface in com.ibm.streams.operator

Information about an Operator's
 processing element.

ProcessingElementMXBean - Interface in com.ibm.streams.operator.management

The management interface for a ProcessingElement.

processPunctuation(StreamingInput<Tuple>, StreamingData.Punctuation) - Method in class com.ibm.streams.operator.AbstractOperator

Process an incoming punctuation mark on the specified port.

processPunctuation(StreamingInput<Tuple>, StreamingData.Punctuation) - Method in interface com.ibm.streams.operator.Operator

Process an incoming punctuation mark on the specified port.

processPunctuation(StreamingInput<Tuple>, StreamingData.Punctuation) - Method in class com.ibm.streams.operator.window.AbstractWindowOperator

Empty method, punctuation processing
 is handled through the registered instances of
 StreamWindowListener.

Product - Class in com.ibm.streams.operator.version

Class representing the InfoSphere Streams product information
 such as the product version number.

Product() - Constructor for class com.ibm.streams.operator.version.Product
 
punctuate(StreamingData.Punctuation) - Method in interface com.ibm.streams.operator.StreamingOutput

Submit a punctuation mark to this output port.

put(ByteBuffer) - Method in interface com.ibm.streams.operator.types.Blob

Put this value into a byte buffer.

put(ByteBuffer) - Method in class com.ibm.streams.operator.types.RString

Put this value into a byte buffer.





R

randomValue(Random) - Method in interface com.ibm.streams.operator.meta.XMLType

Return a randomly generated value for testing.

randomValue(Random) - Method in interface com.ibm.streams.operator.Type

Return a randomly generated value for testing.

readBlob(InputStream) - Static method in class com.ibm.streams.operator.types.ValueFactory

Read a Blob value from an InputStream.

readBlob(InputStream, long) - Static method in class com.ibm.streams.operator.types.ValueFactory

Read a Blob value from an InputStream.

readBlobWithPrefixLength(InputStream) - Static method in class com.ibm.streams.operator.types.ValueFactory

Read a Blob value from an InputStream where the
 number of bytes in the Blob is represented as
 a four byte length value in the stream before the value.

RegionMonitorMXBean - Interface in com.ibm.streams.operator.control

Monitors a region, a set of operators, within the current job.

RegionMonitorMXBean.Health - Enum in com.ibm.streams.operator.control

The health of a region as an aggregation of the health of the PEs for the region.

registerAttributePartitioner(StreamWindow<Tuple>, String...) - Static method in class com.ibm.streams.operator.window.WindowUtilities

Register a StreamWindowPartitioner for a StreamWindow
 where partitioning is defined by attributes of the input tuples.

registerCustomMetric(String) - Method in interface com.ibm.streams.operator.management.OperatorContextMXBean

Register a MetricMXBean for a custom metric.

registerInputPortMetrics(int) - Method in interface com.ibm.streams.operator.management.OperatorContextMXBean

Register an MetricMXBean for all valid metrics for the
 operator input port at index port.

registerListener(StreamWindowListener<T>, boolean) - Method in interface com.ibm.streams.operator.window.StreamWindow

Register a listener to handle window events.

registerOutputPortMetrics(int) - Method in interface com.ibm.streams.operator.management.OperatorContextMXBean

Register an MetricMXBean for all metrics for the
 operator output port at index port.

registerPartitioner(StreamWindowPartitioner<T, ?>) - Method in interface com.ibm.streams.operator.window.StreamWindow

Register a StreamWindowPartitioner for the window.

registerRegionMonitor(String, Set<BigInteger>) - Method in interface com.ibm.streams.operator.control.ControlPlaneMXBean

Register a RegionMonitorMXBean for an
 arbitrary set of processing elements within
 this job.

registerStateHandler(StateHandler) - Method in interface com.ibm.streams.operator.OperatorContext

Register a StateHandler to manage state for
 this operator.

registerStreamHandler(OutputPortDeclaration, StreamHandler<Tuple>) - Method in interface com.ibm.streams.flow.javaprimitives.JavaTestableGraph

Register a StreamHandler to a disconnected output port.

releasePermit() - Method in interface com.ibm.streams.operator.state.ConsistentRegionContext

Release a single submission permit.

remove(String...) - Method in interface com.ibm.streams.operator.StreamSchema

Create a schema that is a based upon this schema with
 the named attributes removed.

removeStreamProperties(String...) - Method in interface com.ibm.streams.operator.StreamingOutput

Remove the named stream properties from this output port.

reportFailure(BigInteger) - Method in interface com.ibm.streams.operator.control.ControlPlaneMXBean

Report an apparent failure for a processing element.

RESERVED_DOMAIN - Static variable in class com.ibm.streams.operator.control.ControlPlaneManagement

The domain ("com.ibm.streams.control.reserved") for MBeans registered by the Job Control Plane itself
 for internal use.

reset() - Method in class com.ibm.streams.flow.handlers.StreamCounter

Reset all the counts to zero.

reset(boolean) - Method in interface com.ibm.streams.operator.control.ConsistentRegionMXBean

Requests a reset of the region to the last consistent state.

reset() - Method in interface com.ibm.streams.operator.state.ConsistentRegionContext

Reset this consistent region to its last consistent state.

reset(Checkpoint) - Method in class com.ibm.streams.operator.state.DelegateStateHandler
 
reset(Checkpoint) - Method in class com.ibm.streams.operator.state.OrderedStateHandlers
 
reset(Checkpoint) - Method in interface com.ibm.streams.operator.state.StateHandler

Reset the operator to a previous state defined by checkpoint.

reset(Checkpoint) - Method in class com.ibm.streams.operator.window.StatefulWindowListener

Reset the operator to a previous state defined by checkpoint.

resetToInitialState() - Method in class com.ibm.streams.operator.state.DelegateStateHandler
 
resetToInitialState() - Method in class com.ibm.streams.operator.state.OrderedStateHandlers
 
resetToInitialState() - Method in interface com.ibm.streams.operator.state.StateHandler

Reset the operator to its initial state.

resetToInitialState() - Method in class com.ibm.streams.operator.window.StatefulWindowListener

Reset the operator to its initial state.

retireCheckpoint(long) - Method in class com.ibm.streams.operator.state.DelegateStateHandler
 
retireCheckpoint(long) - Method in class com.ibm.streams.operator.state.OrderedStateHandlers
 
retireCheckpoint(long) - Method in interface com.ibm.streams.operator.state.StateHandler

Called when a checkpoint can be retired.

retireCheckpoint(long) - Method in class com.ibm.streams.operator.window.StatefulWindowListener

Called when a checkpoint can be retired.

RString - Class in com.ibm.streams.operator.types

SPL rstring.

RString(ByteBuffer, int) - Constructor for class com.ibm.streams.operator.types.RString

Create an RString from the first length bytes
 of buf.

RString(byte[]) - Constructor for class com.ibm.streams.operator.types.RString

Create an rstring set from data.

RString(String) - Constructor for class com.ibm.streams.operator.types.RString

Create an rstring set from value using UTF-8 encoding.





S

same(Attribute) - Method in interface com.ibm.streams.operator.Attribute

Are two attributes the same.

seenInitialFull(Object) - Method in class com.ibm.streams.operator.window.StatefulWindowListener

For a sliding window return true if an INITIAL_FULL event has
 been received for the specified partition.

sendAttributeChangeNotification(String, String, Object, Object) - Method in class com.ibm.streams.operator.control.NotifierSupport

Send an AttributeChangeNotification with type jmx.attribute.change.

sendBooleanAttributeChangeNotification(String, boolean) - Method in class com.ibm.streams.operator.control.NotifierSupport

Send an AttributeChangeNotification with type jmx.attribute.change
 for a boolean attribute.

sendNotification(String) - Method in class com.ibm.streams.operator.control.NotifierSupport

Send a notification with type and no user data.

sendNotification(String, T) - Method in class com.ibm.streams.operator.control.NotifierSupport

Send a notification with type and userData.

set(O, OperatorContext, StreamWindow<T>) - Method in interface com.ibm.streams.operator.window.CheckpointableWindowListener
 
setAttributeParameter(String, String...) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation

Set a parameter to a list of Attribute names as String values.

setBigDecimal(int, BigDecimal) - Method in interface com.ibm.streams.operator.OutputTuple

Set an attribute as a BigDecimal.

setBigDecimal(String, BigDecimal) - Method in interface com.ibm.streams.operator.OutputTuple

Set the attribute as a BigDecimal by attribute name.

setBigDecimalParameter(String, BigDecimal...) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation

Set a parameter to a list of BigDecimal values.

setBlob(int, Blob) - Method in interface com.ibm.streams.operator.OutputTuple

Set an attribute as a Blob.

setBlob(String, Blob) - Method in interface com.ibm.streams.operator.OutputTuple

Set the attribute as a Blob by attribute name.

setBoolean(int, boolean) - Method in interface com.ibm.streams.operator.OutputTuple

Set an attribute as a primitive boolean.

setBoolean(String, boolean) - Method in interface com.ibm.streams.operator.OutputTuple

Set the attribute as a boolean by attribute name.

setBooleanParameter(String, boolean...) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation

Set a parameter to a list of boolean values.

setByte(int, byte) - Method in interface com.ibm.streams.operator.OutputTuple

Set an attribute as a primitive byte.

setByte(String, byte) - Method in interface com.ibm.streams.operator.OutputTuple

Set the attribute as a byte by attribute name.

setByteParameter(String, byte...) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation

Set a parameter to a list of byte values.

setCustomLiteralParameter(String, Enum<?>...) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation

Set a custom literal parameter to a list of Enum values.

setDestination(StreamHandler<T>) - Method in class com.ibm.streams.flow.handlers.DynamicForwarder

Set the destination for the stream.

setDouble(int, double) - Method in interface com.ibm.streams.operator.OutputTuple

Set an attribute as a primitive double.

setDouble(String, double) - Method in interface com.ibm.streams.operator.OutputTuple

Set the attribute as a double by attribute name.

setDoubleParameter(String, double...) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation

Set a parameter to a list of double values.

setEnum(Class<E>, int, E) - Method in interface com.ibm.streams.operator.OutputTuple

Set an enum attribute as an enumeration.

setEnum(Class<E>, String, E) - Method in interface com.ibm.streams.operator.OutputTuple

Set the attribute as a enumeration by attribute name.

setFloat(int, float) - Method in interface com.ibm.streams.operator.OutputTuple

Set an attribute as a primitive float.

setFloat(String, float) - Method in interface com.ibm.streams.operator.OutputTuple

Set the attribute as a float by attribute name.

setFloatParameter(String, float...) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation

Set a parameter to a list of float values.

setInt(int, int) - Method in interface com.ibm.streams.operator.OutputTuple

Set an attribute as a primitive int.

setInt(String, int) - Method in interface com.ibm.streams.operator.OutputTuple

Set the attribute as an int by attribute name.

setIntParameter(String, int...) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation

Set a parameter to a list of int values.

setInvalidContext() - Method in interface com.ibm.streams.operator.compile.OperatorContextChecker

Set that the context is invalid and thus the compile
 or runtime invocation will fail once all @ContextCheck
 annotated methods have been called.

setInvalidContext(String, Object[]) - Method in interface com.ibm.streams.operator.compile.OperatorContextChecker

Set that the context is invalid and log a message at ERROR level.

setList(int, List<?>) - Method in interface com.ibm.streams.operator.OutputTuple

Set an attribute as a List.

setList(String, List<?>) - Method in interface com.ibm.streams.operator.OutputTuple

Set the attribute as a List by attribute name.

setLoggerAspects(String, String...) - Method in class com.ibm.streams.operator.AbstractOperator

Set the aspects associated with a named Logger.

setLoggerAspects(String, String...) - Method in interface com.ibm.streams.operator.ProcessingElement

Set the aspects associated with a named Logger.

setLong(int, long) - Method in interface com.ibm.streams.operator.OutputTuple

Set an attribute as a primitive long.

setLong(String, long) - Method in interface com.ibm.streams.operator.OutputTuple

Set the attribute as a long by attribute name.

setLongParameter(String, long...) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation

Set a parameter to a list of long values.

setMap(int, Map<?, ?>) - Method in interface com.ibm.streams.operator.OutputTuple

Set an attribute as a Map.

setMap(String, Map<?, ?>) - Method in interface com.ibm.streams.operator.OutputTuple

Set the attribute as a Map by attribute name.

setObject(int, Object) - Method in interface com.ibm.streams.operator.OutputTuple

Set the value of the attribute at the given index.

setObject(String, Object) - Method in interface com.ibm.streams.operator.OutputTuple

Set the attribute as an Object by attribute name.

setSet(int, Set<?>) - Method in interface com.ibm.streams.operator.OutputTuple

Set an attribute as a Set.

setSet(String, Set<?>) - Method in interface com.ibm.streams.operator.OutputTuple

Set the attribute as a Set by attribute name.

setShort(int, short) - Method in interface com.ibm.streams.operator.OutputTuple

Set an attribute as a primitive short.

setShort(String, short) - Method in interface com.ibm.streams.operator.OutputTuple

Set the attribute as a short by attribute name.

setShortParameter(String, short...) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation

Set a parameter to a list of short values.

setStreamProperties(Map<String, ?>) - Method in interface com.ibm.streams.operator.StreamingOutput

Set the value of existing stream properties for this port.

setString(int, String) - Method in interface com.ibm.streams.operator.OutputTuple

Set an attribute as a String.

setString(String, String) - Method in interface com.ibm.streams.operator.OutputTuple

Set the attribute as a String by attribute name.

setStringParameter(String, String...) - Method in interface com.ibm.streams.flow.declare.OperatorInvocation

Set a parameter to a list of String values.

setTagData(String, Map<String, String>) - Method in class com.ibm.streams.operator.AbstractOperator

Set tag data for the operator.

setTagData(String, Map<String, String>) - Method in interface com.ibm.streams.operator.Operator

Set tag data for the operator.

setTagData(String, Map<String, String>) - Method in interface com.ibm.streams.operator.ProcessingElement

Set tag data for the PE.

setTimestamp(int, Timestamp) - Method in interface com.ibm.streams.operator.OutputTuple

Set an attribute as a Timestamp.

setTimestamp(String, Timestamp) - Method in interface com.ibm.streams.operator.OutputTuple

Set the attribute as a Timestamp by attribute name.

setTraceLevel(TraceLevel) - Method in interface com.ibm.streams.flow.execute.ExecutableGraph

Set the trace level for the executing graph.

setTuple(int, Tuple) - Method in interface com.ibm.streams.operator.OutputTuple

Set a nested tuple attribute as a Tuple.

setTuple(String, Tuple) - Method in interface com.ibm.streams.operator.OutputTuple

Set the attribute as a TUPLE by attribute name.

setup(MBeanServerConnection, OperatorContext) - Method in interface com.ibm.streams.operator.control.Controllable

Setup the Job Control Plane for this Controllable.

setupComplete() - Method in class com.ibm.streams.operator.control.AbstractPersistentControlMBean

Called when the JCP has completed its persistent setup
 of this MBean.

setupComplete() - Method in interface com.ibm.streams.operator.control.PersistentControlMBean

Called when the JCP has completed its persistent setup
 of this MBean.

setValue(boolean) - Method in class com.ibm.streams.operator.control.variable.BooleanControlVariable

Set the value of this control variable.

setValue(boolean) - Method in interface com.ibm.streams.operator.control.variable.BooleanControlVariableMXBean

Set the value of this control variable.

setValue(T) - Method in interface com.ibm.streams.operator.control.variable.ControlVariableAccessor

Set this control variable to a new value.

setValue(double) - Method in class com.ibm.streams.operator.control.variable.DoubleControlVariable

Set the value of this control variable.

setValue(double) - Method in interface com.ibm.streams.operator.control.variable.DoubleControlVariableMXBean

Set the value of this control variable.

setValue(long) - Method in class com.ibm.streams.operator.control.variable.LongControlVariable

Set the value of this control variable.

setValue(long) - Method in interface com.ibm.streams.operator.control.variable.LongControlVariableMXBean

Set the value of this control variable.

setValue(String) - Method in class com.ibm.streams.operator.control.variable.StringControlVariable

Set the value of this control variable.

setValue(String) - Method in interface com.ibm.streams.operator.control.variable.StringControlVariableMXBean

Set the value of this control variable.

setValue(long) - Method in interface com.ibm.streams.operator.metrics.Metric

Set the value of this metric.

setXML(int, XML) - Method in interface com.ibm.streams.operator.OutputTuple

Set an XML attribute as a XML.

setXML(String, XML) - Method in interface com.ibm.streams.operator.OutputTuple

Set the attribute as a XML by attribute name.

SharedLoader - Annotation Type in com.ibm.streams.operator.model

Declare if the class loader for a Java primitive operator
 is shared within an processing element.

shutdown() - Method in interface com.ibm.streams.flow.javaprimitives.JavaTestableGraph

Asynchronously notify all the Operator invocations in
 the graph of a shutdown request.

shutdown() - Method in class com.ibm.streams.operator.AbstractOperator

Instruct this operator to shutdown.

SHUTDOWN - Static variable in interface com.ibm.streams.operator.management.OperatorContextMXBean

Notification the operator is to be shutdown.

shutdown() - Method in interface com.ibm.streams.operator.Operator

Instruct this operator to shutdown.

SHUTDOWN_COMPLETE - Static variable in interface com.ibm.streams.operator.management.OperatorContextMXBean

Notification the operator has completed its shutdown
 by returning from its
 Operator.shutdown() method.

singleOp(Class<T>) - Method in class com.ibm.streams.flow.javaprimitives.JavaOperatorTester

Create an OperatorInvocation for a single operator.

singleOp(String, Class<T>) - Method in class com.ibm.streams.flow.javaprimitives.JavaOperatorTester
 
sliding() - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration

Set this input port to be a sliding window.

SortedTupleWindow - Class in com.ibm.streams.operator.window.sort

Abstract window handler that sorts incoming generic tuples according
 to a comparator for the window's tuples.

SortedTupleWindow(StreamWindow<Tuple>, boolean, String...) - Constructor for class com.ibm.streams.operator.window.sort.SortedTupleWindow

Sort tuples according to a set of attributes using comparators that match
 the natural ordering of the Java object mapping for the attributes SPL type.

SortedTupleWindow(StreamWindow<Tuple>, boolean, List<String>) - Constructor for class com.ibm.streams.operator.window.sort.SortedTupleWindow

Sort tuples according to a set of attributes using comparators that match
 the natural ordering of the Java object mapping for the attributes SPL type.

SortedTupleWindow(StreamWindow<Tuple>, Comparator<Tuple>) - Constructor for class com.ibm.streams.operator.window.sort.SortedTupleWindow

Sort the tuples according to a specific comparator.

StatefulWindowListener<S,T> - Class in com.ibm.streams.operator.window

Abstract class that registers listeners with a StreamWindow.

StatefulWindowListener(StreamWindow<T>) - Constructor for class com.ibm.streams.operator.window.StatefulWindowListener

Creates and registers a StreamWindowListener
 for the passed in window.

StateHandler - Interface in com.ibm.streams.operator.state

Handler for operator state.

StreamCollector<C extends java.util.Collection<T>,T> - Class in com.ibm.streams.flow.handlers

Collect tuples seen on a stream.

StreamCollector(C) - Constructor for class com.ibm.streams.flow.handlers.StreamCollector

Construct a StreamCollector that will use tuples
 to collect tuples seen on the stream.

StreamConnection - Interface in com.ibm.streams.flow.declare

A stream connection between an input and output port.

StreamCounter<T> - Class in com.ibm.streams.flow.handlers

Count the number of tuples and punctuation marks that are seen on a stream.

StreamCounter() - Constructor for class com.ibm.streams.flow.handlers.StreamCounter

Construct a StreamCounter that initializes all the counts to zero.

StreamDiscarder<T> - Class in com.ibm.streams.flow.handlers

Discards all tuples and marks.

StreamDiscarder() - Constructor for class com.ibm.streams.flow.handlers.StreamDiscarder
 
StreamForwarder<T> - Class in com.ibm.streams.flow.handlers

Forward a stream to another StreamHandler.

StreamForwarder(StreamHandler<T>) - Constructor for class com.ibm.streams.flow.handlers.StreamForwarder

Create a StreamForwarder that forwards to destination.

StreamHandler<T> - Interface in com.ibm.streams.flow.handlers

A generic processing interface for a stream of tuples and punctuation marks.

StreamingData - Interface in com.ibm.streams.operator

StreamingData describes an Operator's port.

StreamingData.Punctuation - Enum in com.ibm.streams.operator

Enumeration for punctuation marks.

StreamingInput<T> - Interface in com.ibm.streams.operator

StreamingInput represents an input port for an
 Operator.

StreamingInput.ImportType - Enum in com.ibm.streams.operator

Enumeration for how a port imports its streams.

StreamingOutput<T> - Interface in com.ibm.streams.operator

StreamingOutput represents an output port for an
 Operator.

StreamingOutput.ExportType - Enum in com.ibm.streams.operator

Enumeration for how a port exports its stream.

STREAMS_3_2_0 - Static variable in class com.ibm.streams.operator.version.Product
 
STREAMS_3_2_1 - Static variable in class com.ibm.streams.operator.version.Product
 
STREAMS_4_0_0 - Static variable in class com.ibm.streams.operator.version.Product
 
STREAMS_4_0_1 - Static variable in class com.ibm.streams.operator.version.Product
 
STREAMS_OPERATOR_JMX_DOMAIN - Static variable in class com.ibm.streams.operator.management.OperatorManagement

ObjectName domain for MXBeans registered in the platform MBeanServer
 of the executing processing element.

StreamSchema - Interface in com.ibm.streams.operator

An immutable object representing the schema of a port or an attribute
 of type TUPLE.

StreamWindow<T> - Interface in com.ibm.streams.operator.window

A window connected to an input port (stream).

StreamWindow.Policy - Enum in com.ibm.streams.operator.window

Policy type for eviction and trigger policies.

StreamWindow.Type - Enum in com.ibm.streams.operator.window

Window type.

StreamWindowEvent<T> - Class in com.ibm.streams.operator.window

An event for a windowed input port.

StreamWindowEvent(StreamWindowEvent.Type, StreamWindow<T>, Object, Iterable<T>) - Constructor for class com.ibm.streams.operator.window.StreamWindowEvent
 
StreamWindowEvent.Type - Enum in com.ibm.streams.operator.window

Stream window event type.

StreamWindowListener<T> - Interface in com.ibm.streams.operator.window

Handle StreamWindowEvents being generated by a StreamWindow.

StreamWindowPartitioner<T,P> - Interface in com.ibm.streams.operator.window

StreamWindowPartitioner provides the mapping from an tuple
 being inserted into the window to a partition.

StringControlVariable - Class in com.ibm.streams.operator.control.variable

Provides the implementation of the String control variable MBean.

StringControlVariable() - Constructor for class com.ibm.streams.operator.control.variable.StringControlVariable

Create a StringControlVariableMXBean with no initial value.

StringControlVariable(String) - Constructor for class com.ibm.streams.operator.control.variable.StringControlVariable

Create a StringControlVariableMXBean with an initial value.

StringControlVariableMXBean - Interface in com.ibm.streams.operator.control.variable

MXBean representing a String control variable.

submit(T) - Method in interface com.ibm.streams.operator.StreamingOutput

Submit a tuple to this output port.

submit(Tuple) - Method in interface com.ibm.streams.operator.StreamingOutput

Submit an immutable tuple to this output port.

submitAsTuple(Object...) - Method in interface com.ibm.streams.operator.StreamingOutput

Submit a tuple using variable list of
 values for the attributes.

submitListAsTuple(List<?>) - Method in interface com.ibm.streams.operator.StreamingOutput

Submit a tuple setting attribute values
 from the supplied list by position
 

 The submitted tuple is identical
 to a tuple obtained from
 

 getStreamSchema().getTuple(List<?>).

submitMapAsTuple(Map<String, ?>) - Method in interface com.ibm.streams.operator.StreamingOutput

Submit a tuple using Map containing
 attribute values with the attribute names
 as keys.

subtract(Timestamp) - Method in class com.ibm.streams.operator.types.Timestamp

Return a Timestamp that is the result of subtracting the
 delta Timestamp from this Timestamp.

supportsWindow() - Method in class com.ibm.streams.operator.window.sort.TumblingWindowSort

Only support a TUMBLING window.

supportsWindow() - Method in class com.ibm.streams.operator.window.StatefulWindowListener

Return true if this listener supports the window type described
 by StreamWindow.

sync() - Method in interface com.ibm.streams.operator.control.variable.ControlVariableAccessor

Synchronize this view of this control variable with the value in the Job
 Control Plane.





T

tester(OperatorInvocation<? extends Operator>) - Method in class com.ibm.streams.flow.javaprimitives.JavaOperatorTester

Create a JavaTestableGraph that contains the operator
 invocation that is declared by invocation.

threaded(InputPortDeclaration.CongestionPolicy, int, boolean) - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration

Set this input port to be a threaded port.

TIMER_NAME - Static variable in class com.ibm.streams.operator.control.ControlPlaneManagement

The ObjectName name for the javax.management.timer.TimerMBean that is
 registered in the Job Control Bean MBean server.

Timestamp - Class in com.ibm.streams.operator.types

SPL timestamp.

Timestamp(long, int) - Constructor for class com.ibm.streams.operator.types.Timestamp

Construct a Timestamp with the given values and a machine identifier
 set to zero.

Timestamp(long, int, int) - Constructor for class com.ibm.streams.operator.types.Timestamp

Construct a Timestamp with the given values.

toString(Object) - Method in interface com.ibm.streams.operator.Type

Returns a string that textually represents
 a value of this type, typically using Object.toString()
 of Type.getObjectType().

toString() - Method in class com.ibm.streams.operator.types.RString

Returns getString().

toString() - Method in class com.ibm.streams.operator.types.Timestamp

Return this timestamp as a String using
 the SPL character encoding.

toString() - Method in class com.ibm.streams.operator.version.Version
 
TRACE - Static variable in class com.ibm.streams.operator.log4j.TraceLevel

TRACE is a level for more detailed trace that includes all the detail
 that is needed to debug problems.

TRACE - Static variable in class com.ibm.streams.operator.logging.TraceLevel

TRACE is a level for more detailed trace that includes all the detail
 that is needed to debug problems.

TRACE_LEVEL - Static variable in interface com.ibm.streams.operator.management.ProcessingElementMXBean

Notification the SPL trace level has changed.

TraceLevel - Class in com.ibm.streams.operator.log4j

Convenience class to provide SPL trace levels through the org.apache.log4j facility.

TraceLevel - Class in com.ibm.streams.operator.logging

Convenience class to provide SPL trace levels through the java.util.logging facility.

triggerCount(int) - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration

Set the type of the window trigger policy to be StreamWindow.Policy.COUNT.

triggerDelta(String, Object) - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration

Set the type of the window trigger policy to be StreamWindow.Policy.DELTA.

triggerTime(double) - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration

Set the type of the window trigger policy to be StreamWindow.Policy.TIME.

triggerTime(long, TimeUnit) - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration

Set the type of the window trigger policy to be StreamWindow.Policy.TIME.

tumbling() - Method in interface com.ibm.streams.flow.declare.InputPortDeclaration

Set this input port to be a tumbling window.

TumblingWindowSort - Class in com.ibm.streams.operator.window.sort

Implement a tuple window sort for a tumbling window.

TumblingWindowSort(StreamWindow<Tuple>, boolean, List<String>, StreamingOutput<?>, boolean) - Constructor for class com.ibm.streams.operator.window.sort.TumblingWindowSort

Creates and registers a listener for the window.

tuple(T) - Method in class com.ibm.streams.flow.handlers.AbstractStreamForwarder

Send the tuple to the destination that is returned by AbstractStreamForwarder.getDestination().

tuple(T) - Method in class com.ibm.streams.flow.handlers.HandlerCollection

Propagate the tuple to each handler in the collection.

tuple(T) - Method in class com.ibm.streams.flow.handlers.MostRecent

Save the most recent tuple.

tuple(T) - Method in class com.ibm.streams.flow.handlers.StreamCollector

Add the tuple to the collection.

tuple(T) - Method in class com.ibm.streams.flow.handlers.StreamCounter

Count the number of tuples.

tuple(T) - Method in class com.ibm.streams.flow.handlers.StreamDiscarder

Do nothing with the tuple.

tuple(T) - Method in interface com.ibm.streams.flow.handlers.StreamHandler

Process a tuple.

Tuple - Interface in com.ibm.streams.operator

A representation of a stream's tuple.

TupleAttribute<T,A> - Interface in com.ibm.streams.operator

Defines an attribute for a specific port.

TupleType - Interface in com.ibm.streams.operator.meta

Meta-type for an attribute of type
 TUPLE.

TYPE - Static variable in interface com.ibm.streams.operator.control.ConsistentRegionMXBean

Type of this MBean in its object name.

type() - Method in enum com.ibm.streams.operator.management.MetricMXBean.MetricType

Return the value used for MetricMXBean.METRIC_PROPERTY
 in an ObjectName.

type() - Method in enum com.ibm.streams.operator.management.OperatorManagement.Type

Return the value used for the ObjectName's type
 key property for this management bean type.

Type - Interface in com.ibm.streams.operator

Describes a specific type within a StreamSchema and its representation within Java.

Type.Factory - Class in com.ibm.streams.operator

Factory for creating SPL type related objects.

Type.Factory() - Constructor for class com.ibm.streams.operator.Type.Factory
 
Type.MetaType - Enum in com.ibm.streams.operator

Enumeration of SPL types.





U

updateControlState(byte[]) - Method in interface com.ibm.streams.operator.control.PersistentControlMBean

Called when the JCP discovers that data has been associated
 with this MBean (via its name).

updateControlState(byte[]) - Method in class com.ibm.streams.operator.control.variable.BooleanControlVariable

Update this variable's value from its persisted state.

updateControlState(byte[]) - Method in class com.ibm.streams.operator.control.variable.DoubleControlVariable

Update this variable's value from its persisted state.

updateControlState(byte[]) - Method in class com.ibm.streams.operator.control.variable.LongControlVariable

Update this variable's value from its persisted state.

updateControlState(byte[]) - Method in class com.ibm.streams.operator.control.variable.StringControlVariable

Update this variable's value from its persisted state.





V

ValueFactory - Class in com.ibm.streams.operator.types

Factory for creating instances of Streams specific attribute value objects.

ValueFactory() - Constructor for class com.ibm.streams.operator.types.ValueFactory
 
valueOf(String) - Static method in enum com.ibm.streams.flow.declare.InputPortDeclaration.CongestionPolicy

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.control.ConsistentRegionMXBean.State

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.control.ConsistentRegionMXBean.Trigger

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.control.Controllable.EventType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.control.RegionMonitorMXBean.Health

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.management.MetricMXBean.MetricType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.management.OperatorManagement.Type

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.metrics.Metric.Kind

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.metrics.OperatorMetrics.InputPortMetric

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.metrics.OperatorMetrics.OutputPortMetric

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.metrics.PEMetrics.InputPortMetric

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.metrics.PEMetrics.OutputPortMetric

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.model.InputPortSet.WindowMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.model.InputPortSet.WindowPunctuationInputMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.model.OutputPortSet.WindowPunctuationOutputMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.state.CheckpointContext.Kind

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.StreamingData.Punctuation

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.StreamingInput.ImportType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.StreamingOutput.ExportType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.Type.MetaType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.window.StreamWindow.Policy

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.window.StreamWindow.Type

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.ibm.streams.operator.window.StreamWindowEvent.Type

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.ibm.streams.flow.declare.InputPortDeclaration.CongestionPolicy

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.control.ConsistentRegionMXBean.State

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.control.ConsistentRegionMXBean.Trigger

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.control.Controllable.EventType

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.control.RegionMonitorMXBean.Health

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.management.MetricMXBean.MetricType

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.management.OperatorManagement.Type

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.metrics.Metric.Kind

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.metrics.OperatorMetrics.InputPortMetric

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.metrics.OperatorMetrics.OutputPortMetric

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.metrics.PEMetrics.InputPortMetric

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.metrics.PEMetrics.OutputPortMetric

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.model.InputPortSet.WindowMode

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.model.InputPortSet.WindowPunctuationInputMode

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.model.OutputPortSet.WindowPunctuationOutputMode

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.state.CheckpointContext.Kind

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.StreamingData.Punctuation

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.StreamingInput.ImportType

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.StreamingOutput.ExportType

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.Type.MetaType

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.window.StreamWindow.Policy

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.window.StreamWindow.Type

Returns an array containing the constants of this enum type, in
the order they are declared.

values() - Static method in enum com.ibm.streams.operator.window.StreamWindowEvent.Type

Returns an array containing the constants of this enum type, in
the order they are declared.

verifyMapping(Class<E>) - Method in interface com.ibm.streams.operator.meta.EnumType

Verify that the mapping between this SPL's enum
 identifiers and Java enumeration type E is valid.

verifyOrdinals(Class<E>) - Method in interface com.ibm.streams.operator.meta.EnumType

Verify that declared order of this SPL's enum
 identifiers matches order and position of constants for E.

Version - Class in com.ibm.streams.operator.version

Class representing a version number in the form of
 version.release.mod.fix.





W

waitForCompletion() - Method in interface com.ibm.streams.flow.javaprimitives.JavaTestableGraph

Wait for all the operator invocations to complete.

waitForTuples(int, long, TimeUnit) - Method in class com.ibm.streams.flow.handlers.StreamCounter
 
WARN - Static variable in class com.ibm.streams.operator.log4j.LogLevel

WARN is a level indicating a potential error or impending error.

WARN - Static variable in class com.ibm.streams.operator.log4j.TraceLevel

WARN is a level indicating a potential error or impending error.

WARN - Static variable in class com.ibm.streams.operator.logging.LogLevel

WARN is a level indicating a potential error or impending error.

WARN - Static variable in class com.ibm.streams.operator.logging.TraceLevel

WARN is a level indicating a potential error or impending error.

WindowUtilities - Class in com.ibm.streams.operator.window

Utility methods for windowed input ports.

WindowUtilities() - Constructor for class com.ibm.streams.operator.window.WindowUtilities
 




X

XML - Interface in com.ibm.streams.operator.types

SPL xml attribute.

XMLType - Interface in com.ibm.streams.operator.meta

Meta-type for an attribute of type
 XML.


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







Skip navigation links




Overview
Package
Class
Tree
Deprecated
Index
Help




Prev
Next


Frames
No Frames


All Classes