StreamHandler (IBM InfoSphere 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
  
  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.