[
https://issues.apache.org/jira/browse/FLINK-41210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Theusner reassigned FLINK-41210:
-------------------------------------
Assignee: Timo Theusner
> Add fluent StartMode factories
> ------------------------------
>
> Key: FLINK-41210
> URL: https://issues.apache.org/jira/browse/FLINK-41210
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / API
> Reporter: Timo Theusner
> Assignee: Timo Theusner
> Priority: Major
>
> {{StartMode}} only has {{of(StartModeKind, ...)}} factories taking an
> {{{}Interval{}}}, or an {{Instant}} plus a local-time-zone flag, which mirror
> the parser rather than a Java caller. Add one factory per {{START_MODE}}
> clause, taking {{Duration}} and {{{}Instant{}}}.
> Proposed Changes
> * Add {{{}fromBeginning(){}}}, {{{}fromNow(){}}}, {{{}fromNow(Duration){}}},
> {{{}fromTimestamp(Instant){}}}, {{{}resumeOrFromBeginning(){}}},
> {{{}resumeOrFromNow(){}}}, {{resumeOrFromNow(Duration)}} and
> {{resumeOrFromTimestamp(Instant)}} to {{StartMode}}
> * Reject offsets that are not positive or not a whole number of seconds
> * Map {{Instant}} arguments to their UTC date-time, independent of
> {{table.local-time-zone}}
> * Javadoc each factory with its {{START_MODE}} equivalent
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
