Package org.apache.storm.starter.streams

Class TypedTupleExample

java.lang.Object

org.apache.storm.starter.streams.TypedTupleExample

public class TypedTupleExample
extends Object

An example that illustrates the usage of typed tuples (TupleN<..>) and TupleValueMappers.

Constructor Summary

Constructors

Constructor	Description
TypedTupleExample()

Method Summary

Modifier and Type	Method	Description
static void	main(String[] args)	The spout emits sequences of (Integer, Long, Long).

Methods inherited from class java.lang.Object

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

Constructor Details

TypedTupleExample

public TypedTupleExample()

Method Details

main

public static void main(String[] args)
                 throws Exception

The spout emits sequences of (Integer, Long, Long). TupleValueMapper can be used to extract fields from the values and produce a stream of typed tuple (Tuple3<Integer, Long, Long> in this case.

Throws:

Exception