| waitForServer(FetchEmitTuple, IntermediateResult) |  | 0% | | 0% | 19 | 19 | 90 | 90 | 1 | 1 |
| process(FetchEmitTuple) | | 0% | | n/a | 1 | 1 | 51 | 51 | 1 | 1 |
| maybeInit() | | 0% | | 0% | 7 | 7 | 32 | 32 | 1 | 1 |
| logTiming(String, PipesResult, long) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| reconnect() | | 0% | | 0% | 2 | 2 | 16 | 16 | 1 | 1 |
| waitForStartup() | | 0% | | 0% | 4 | 4 | 14 | 14 | 1 | 1 |
| buildFatalResult(String, EmitKey, PipesResult.RESULT_STATUS, Optional, String) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| writeTask(FetchEmitTuple) | | 0% | | 0% | 3 | 3 | 13 | 13 | 1 | 1 |
| closeConnection() | | 0% | | 0% | 2 | 2 | 15 | 15 | 1 | 1 |
| PipesClient(PipesConfig, Path) | | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
| ping() | | 0% | | 0% | 4 | 4 | 13 | 13 | 1 | 1 |
| PipesClient(PipesConfig, ServerManager) | | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
| clientBackstopMillis(TimeoutLimits) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| resetTimings() | | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
| start() | | 0% | | n/a | 1 | 1 | 11 | 11 | 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 | 4 | 4 | 1 | 1 |
| us(long) | | 0% | | 0% | 2 | 2 | 1 | 1 | 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 |