AbstractStreamForwarder (IBM InfoSphere Streams Java Operator API)

Skip navigation links

Prev Class
Next Class

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

java.lang.Object
- com.ibm.streams.flow.handlers.AbstractStreamForwarder<T>

Type Parameters:
T - Type for the tuples on the stream

All Implemented Interfaces:

StreamHandler<T>

Direct Known Subclasses:

DynamicForwarder, StreamForwarder
```
public abstract class AbstractStreamForwarder<T>
extends java.lang.Object
implements StreamHandler<T>
```
Forward a stream to another StreamHandler.

Since:

InfoSphere® Streams Version 3.1

Field Summary

Fields
Modifier and Type Field and Description

static java.lang.String IBM_COPYRIGHT

Constructor Summary

Constructors
Constructor and Description

AbstractStreamForwarder()

Method Summary

Methods
Modifier and Type	Method and Description
`abstract StreamHandler<T>`	`getDestination()` Get the current destination for the stream.
`void`	`mark(StreamingData.Punctuation mark)` Send the punctuation mark to the destination that is returned by `getDestination()`.
`void`	`tuple(T tuple)` Send the tuple to the destination that is returned by `getDestination()`.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - IBM_COPYRIGHT
```
public static final java.lang.String IBM_COPYRIGHT
```
    See Also:
    Constant Field Values
- Constructor Detail
  - AbstractStreamForwarder
```
public AbstractStreamForwarder()
```
- Method Detail
  - getDestination
```
public abstract StreamHandler<T> getDestination()
```
    Get the current destination for the stream.
    
    Returns:
    Handler that the stream is forwarded to.
  - tuple
```
public void tuple(T tuple)
           throws java.lang.Exception
```
    Send the tuple to the destination that is returned by getDestination().
    
    Specified by:
    
    tuple in interface StreamHandler<T>
    
    Parameters:
    tuple - The tuple.
    
    Throws:
    
    java.lang.Exception - Failure to process the tuple.
  - mark
```
public void mark(StreamingData.Punctuation mark)
          throws java.lang.Exception
```
    Send the punctuation mark to the destination that is returned by getDestination().
    
    Specified by:
    
    mark in interface StreamHandler<T>
    
    Parameters:
    mark - The punctuation mark.
    
    Throws:
    
    java.lang.Exception - Failure to process the punctuation mark.