Sample Apache Flink application that can be deployed to Kinesis Analytics for Java. It reads taxi events from a Kinesis data stream, processes and aggregates them, and ingests the result to an Amazon Elasticsearch Service cluster for visualization with Kibana.
Main Code: 1,042 LOC (4 files) = YML (100%) Secondary code: Test: 0 LOC (0); Generated: 0 LOC (0); Build & Deploy: 0 LOC (0); Other: 842 LOC (28); |
|||
Duplication: 39% | |||
File Size: 0% long (>1000 LOC), 5% short (<= 200 LOC) | |||
|
Logical Component Decomposition: primary (1 component) | ||
|
2 years, 10 months old
|
|
|
|
0% of code updated more than 50 times Also see temporal dependencies for files frequently changed in same commits. |
|
|
|
Goals: Keep the system simple and easy to change (4) |
|
Latest commit date: 2022-01-04
3
commits
(30 days)
2
contributors
(30 days) |
|
generated by sokrates.dev (configuration) on 2022-01-31