Closed olessia closed 6 years ago
Log counts of late-arriving data. Add delay-hours parameter that allows delaying watermarking. Add a new way to check for LAD: based on paths touched in the last N runs.
Log counts of late-arriving data. Add delay-hours parameter that allows delaying watermarking. Add a new way to check for LAD: based on paths touched in the last N runs.