Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5683#discussion_r174427161 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Execution.java --- @@ -54,6 +56,22 @@ public boolean isBatchExecution() { PropertyStrings.EXECUTION_TYPE_VALUE_BATCH); } + public TimeCharacteristic getTimeCharacteristic() { + final String s = properties.getOrDefault( + PropertyStrings.EXECUTION_TIME_CHARACTERISTIC, + PropertyStrings.EXECUTION_TIME_CHARACTERISTIC_VALUE_EVENT_TIME); + switch (s) { + case PropertyStrings.EXECUTION_TIME_CHARACTERISTIC_VALUE_EVENT_TIME: + return TimeCharacteristic.EventTime; + case PropertyStrings.EXECUTION_TIME_CHARACTERISTIC_VALUE_INGESTION_TIME: --- End diff -- Remove ingestion time?
---