tree: 2154907a512cb17d9667a4d509169b63f6c7f739 [path history] [tgz]
  1. src/
  2. pom.xml
  3. README.md
examples/innerjoin/README.md

Sample application to show how to use the POJOInnerJoinOperator to join two data streams.

Operators in sample application are as follows:

  1. POJOGenerator which emits SalesEvent/ProductEvent POJO's
  2. POJOInnerJoinOperator which joins two POJO streams and emits POJO tuple.
  3. ConsoleOutputOperator which write joined POJO tuples to stdout.