| from(List, String, Map) |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
| kafkaSinkBuilder(String, String, String, String, KafkaRecordTimestampStrategy, FlinkKafkaPartitioner) |  | 62% | | 50% | 1 | 2 | 2 | 11 | 0 | 1 |
| sseSourceFunction(String, String, String) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| kafkaSourceBuilder(String, String, String, List) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| EventDataStreamFactory(EventStreamFactory, JsonEventGenerator) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| sseSourceFunction(String, String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| fileStreamSourceBuilder(String, Path[]) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| from(List, String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$new$0(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| kafkaSourceBuilder(String, String, String, String, List) | | 98% | | 83% | 1 | 4 | 0 | 14 | 0 | 1 |
| fileDataStream(String, String, StreamExecutionEnvironment, WatermarkStrategy, URI[]) | | 100% | | n/a | 0 | 1 | 0 | 6 | 0 | 1 |
| serializer(String, String) | | 100% | | n/a | 0 | 1 | 0 | 9 | 0 | 1 |
| deserializer(String, String) | | 100% | | 100% | 0 | 2 | 0 | 5 | 0 | 1 |
| rowTypeInfo(String, String) | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| rowTypeInfo(String) | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| fileSinkEncoder(String, String) | | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
| EventDataStreamFactory(EventStreamFactory, JsonEventGenerator, Predicate) | | 100% | | n/a | 0 | 1 | 0 | 5 | 0 | 1 |
| getKafkaProducerConfig() | | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
| fileStreamSourceBuilder(String, String, Path[]) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| kafkaSinkBuilder(String, String, String, String, KafkaRecordTimestampStrategy) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| fileSinkBuilderRowFormat(String, String, String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| kafkaSourceBuilder(String, String, String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| fileDataStream(String, StreamExecutionEnvironment, WatermarkStrategy, URI[]) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| fileSinkBuilderRowFormat(String, String, Path) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| deserializer(String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| builder() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| static {...} | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getEventStreamFactory() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$fileDataStream$1(int) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |