com.ibm.streams.flow.handlers

Class DynamicForwarder<T>

java.lang.Object

com.ibm.streams.flow.handlers.AbstractStreamForwarder<T>

com.ibm.streams.flow.handlers.DynamicForwarder<T>

Type Parameters:

T - Type for the tuples on the stream

All Implemented Interfaces:

StreamHandler<T>

public class DynamicForwarder<T>
extends AbstractStreamForwarder<T>

Forward a stream to another StreamHandler. The destination for the forwarded stream can be changed by calling setDestination(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
DynamicForwarder() Create a DynamicForwarder with the destination set to a StreamDiscarder.
DynamicForwarder(StreamHandler<T> handler) Create a DynamicForwarder with the destination set to a handler.

Method Summary

Methods

Modifier and Type	Method and Description
StreamHandler<T>	getDestination() Get the current destination for the stream.
void	setDestination(StreamHandler<T> destination) Set the destination for the stream.

Methods inherited from class com.ibm.streams.flow.handlers.AbstractStreamForwarder

mark, tuple

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

DynamicForwarder

public DynamicForwarder()

Create a DynamicForwarder with the destination set to a StreamDiscarder.

DynamicForwarder

public DynamicForwarder(StreamHandler<T> handler)

Create a DynamicForwarder with the destination set to a handler.

Method Detail

setDestination

public void setDestination(StreamHandler<T> destination)

Set the destination for the stream.

Parameters:

destination -

getDestination

public StreamHandler<T> getDestination()

Get the current destination for the stream.

Specified by:

getDestination in class AbstractStreamForwarder<T>

Returns:

Handler that the stream is forwarded to.