Code Repositories
Find and share code repositories
Labels (1)
Contributor
Repo Description

In particular check out the ParseDelimitedTextBolt which allows you to externally define (JSON) the record layout of the tuples coming off your Kafka spout. The bolt consumes the JSON schema doc and configures the underlying parsers to interpret the fields. You can optionally pass in a list of filter fields to constrain the output. See the README and unit tests for examples of the implementation.

Repo Info
Github Repo URL https://github.com/rtempleton/storm-poncho
Github account name rtempleton
Repo name storm-poncho
260 Views
Don't have an account?
Version history
Revision #:
1 of 1
Last update:
‎05-16-2016 09:05 PM
Updated by:
 
Contributors
Top Kudoed Authors