org.apache.storm.streams.operations

Class PairValueJoiner<V1,V2>

java.lang.Object

org.apache.storm.streams.operations.PairValueJoiner<V1,V2>

Type Parameters:

V1 - the type of the first value

V2 - the type of the second value

All Implemented Interfaces:

Serializable, Operation, ValueJoiner<V1,V2,Pair<V1,V2>>

public class PairValueJoiner<V1,V2>
extends Object
implements ValueJoiner<V1,V2,Pair<V1,V2>>

A ValueJoiner that joins two values to produce a Pair of the two values as the result.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PairValueJoiner()

Method Summary

Modifier and Type	Method and Description
Pair<V1,V2>	apply(V1 value1, V2 value2) Joins two values and produces a Pair of the values as the result.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PairValueJoiner

public PairValueJoiner()

Method Detail

apply

public Pair<V1,V2> apply(V1 value1,
                         V2 value2)

Joins two values and produces a Pair of the values as the result.

Specified by:

apply in interface ValueJoiner<V1,V2,Pair<V1,V2>>

Parameters:

value1 - the first value

value2 - the second value

Returns:

a pair of the first and second value