StreamHandler (IBM Streams Java Operator API)

Skip navigation links

Prev Class
Next Class

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

Type Parameters:

T - The type of the tuples on the stream

All Known Implementing Classes:

AbstractStreamForwarder, DynamicForwarder, HandlerCollection, MostRecent, StreamCollector, StreamCounter, StreamDiscarder, StreamForwarder
```
public interface StreamHandler<T>
```
A generic processing interface for a stream of tuples and punctuation marks.

Since:

InfoSphere® Streams Version 3.1

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`void`	`mark(StreamingData.Punctuation mark)` Process a punctuation mark.
`void`	`tuple(T tuple)` Process a tuple.

- Method Detail
  - tuple
```
void tuple(T tuple)
    throws java.lang.Exception
```
    Process a tuple.
    
    Parameters:
    
    tuple - The tuple.
    
    Throws:
    
    java.lang.Exception - Failure to process the tuple.
  - mark
```
void mark(StreamingData.Punctuation mark)
   throws java.lang.Exception
```
    Process a punctuation mark.
    
    Parameters:
    
    mark - The punctuation mark.
    
    Throws:
    
    java.lang.Exception - Failure to process the punctuation mark.