org.apache.storm.starter.trident

Class TridentMapExample

java.lang.Object

org.apache.storm.starter.trident.TridentMapExample

public class TridentMapExample
extends Object

A simple example that demonstrates the usage of Stream.map(MapFunction) and Stream.flatMap(FlatMapFunction) functions.

Constructor Summary

Constructors

Constructor and Description
TridentMapExample()

Method Summary

Modifier and Type	Method and Description
static StormTopology	buildTopology(org.apache.storm.LocalDRPC drpc)
static void	main(String[] args)

Methods inherited from class java.lang.Object

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

Constructor Detail

TridentMapExample

public TridentMapExample()

Method Detail

buildTopology

public static StormTopology buildTopology(org.apache.storm.LocalDRPC drpc)

main

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

Throws:

Exception