Handling out of order events

摘要: Processing streaming data in accordance with policies that group by source, enforce a maximum permissible late arrival value for data, early and/or degree to which can be out of order and still compliant the policy is described. The correct starting point reading stream so as produce output from given start time enabled using policy. Using combinations policies, generated promptly (with low latency). When input source not disrupted, latency. Output even when stops applying