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