alexcasalboni/kinesis-streams-fan-out-kinesis-analytics
View on GitHubCentralize input/output streams schema
Open
#3 opened on Jun 17, 2017
enhancementhelp wanted
Repository metrics
- Stars
- (104 stars)
- PR merge metrics
- (No merged PRs in 30d)
Description
At the moment, the schema is distributed across a few commands and files:
- input-schema.json: this is the JSON format required by the CreateApplication API (it can be automated by putting a few records and running the discovery feature)
- query.sql: this is the Kinesis Analytics Application query that actually implements the fan-out (input/output structure must be known)
- putRecords.js: this command writes N records into the input stream (for discovery and testing)