| main(String[]) |  | 0% | | 0% | 3 | 3 | 26 | 26 | 1 | 1 |
| buildPubSubPipeline(StreamExecutionEnvironment, String, String, String, double) | | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
| buildDemoPipeline(StreamExecutionEnvironment, double) | | 0% | | n/a | 1 | 1 | 13 | 13 | 1 | 1 |
| buildKafkaPipeline(StreamExecutionEnvironment, String, String, String, double) | | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
| processTransactions(DataStream, double) | | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
| configureEnvironment(StreamExecutionEnvironment) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| getEnvOrDefault(String, String) | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
| lambda$buildDemoPipeline$9a5217ea$1(Transaction, long) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| static {...} | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| FraudDetectionJob() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |