TSink (Java Application API for IBM Streams)

Skip navigation links

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

All Superinterfaces:

Placeable<TSink>, TopologyElement
```
public interface TSink
extends TopologyElement, Placeable<TSink>
```
A handle to the sink of a TStream.
TSink implements Placeable to allow placement directives against its sink() processing. Calling a Placeable method on this will apply to the container that is executing the Consumer passed into sink().

See Also:

TStream.forEach(com.ibm.streamsx.topology.function.Consumer)

- Method Summary
  
  All Methods Instance Methods Abstract Methods
  Modifier and Type Method and Description
  
  com.ibm.streamsx.topology.builder.BOperatorInvocation operator()
  Internal method.
  - Methods inherited from interface com.ibm.streamsx.topology.context.Placeable
    addResourceTags, colocate, getInvocationName, getResourceTags, invocationName, isPlaceable
  - Methods inherited from interface com.ibm.streamsx.topology.TopologyElement
    builder, topology

- Method Detail
  - operator
```
com.ibm.streamsx.topology.builder.BOperatorInvocation operator()
```
    Internal method.
    Not intended to be called by applications, may be removed at any time.
    Get the operator associated with the sink.
    
    Specified by:
    
    operator in interface Placeable<TSink>
    
    Returns:
    
    the operator