| waitForServer(FetchEmitTuple, IntermediateResult) |  | 0% | | 0% | 14 | 14 | 75 | 75 | 1 | 1 |
| maybeInit() | | 0% | | 0% | 7 | 7 | 32 | 32 | 1 | 1 |
| process(FetchEmitTuple) | | 0% | | n/a | 1 | 1 | 26 | 26 | 1 | 1 |
| buildFatalResult(String, EmitKey, PipesResult.RESULT_STATUS, Optional, String) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| waitForStartup() | | 0% | | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
| reconnect() | | 0% | | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
| closeConnection() | | 0% | | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
| ping() | | 0% | | 0% | 4 | 4 | 12 | 12 | 1 | 1 |
| PipesClient(PipesConfig, Path) | | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| PipesClient(PipesConfig, ServerManager) | | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| writeTask(FetchEmitTuple) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| close() | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| tryToClose(Closeable, List) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| static {...} | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| buildFatalResult(String, EmitKey, PipesResult.RESULT_STATUS, Optional) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getFilesProcessed() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getPipesClientId() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |