Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4183#discussion_r124298519
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/queryConfig.scala
---
@@ -37,6 +37,14 @@ class BatchQueryConfig private[table] extends QueryConfig
class StreamQueryConfig private[table] extends QueryConfig {
/**
+ * The deferredComputationTime is a strategy config of deferred
computation that used to deal
+ * with late arriving data. For example, instead of computing a
tumbling window of 1 hour at each
+ * full hour, we can add a deferred computation interval of 15 minute
to compute the result
+ * quarter past each full hour.
+ */
+ private var deferredComputationTime: Long = 0L
--- End diff --
Should we call this parameter rather `firstResultTimeOffset`? This would
allow us to also use it to configure early results later. The value would be an
offset from the original computation time. A positive value (> 0) would mean
deferred computation (later than usual) and a negative value (<0) would mean an
early computation / early result.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
