getNextOffset(StreamingJobProperties, Map) |   | 78% |   | 60% | 4 | 6 | 8 | 42 | 0 | 1 |
fetchRemoteMeta(Map) |   | 95% |   | 75% | 2 | 5 | 2 | 16 | 0 | 1 |
getSourceType() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getNextOffset$0(String, RemoteFile) |  | 87% |   | 50% | 1 | 2 | 0 | 1 | 0 | 1 |
lambda$rewriteTvfParams$2(Map, S3Offset, Plan) |  | 100% |  | 100% | 0 | 2 | 0 | 8 | 0 | 1 |
rewriteTvfParams(InsertIntoTableCommand, Offset) |  | 100% | | n/a | 0 | 1 | 0 | 5 | 0 | 1 |
getShowMaxOffset() |  | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
hasMoreDataToConsume() |  | 100% |  | 100% | 0 | 3 | 0 | 5 | 0 | 1 |
getShowCurrentOffset() |  | 100% |  | 100% | 0 | 2 | 0 | 3 | 0 | 1 |
updateOffset(Offset) |  | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
deserializeOffset(String) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$getNextOffset$1(String, RemoteFile) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
static {...} |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
S3SourceOffsetProvider() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |