[FLINK-6244] [cep] Emit timeouted Patterns as Side Output
This closes #4320
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6ed5815e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6ed5815e
Diff:
Repository: flink
Updated Branches:
refs/heads/master 9995588c8 -> 6ed5815e8
http://git-wip-us.apache.org/repos/asf/flink/blob/6ed5815e/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/SelectTimeoutCepOperator.java
http://git-wip-us.apache.org/repos/asf/flink/blob/93d0ae4a/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/OverWindowHarnessTest.scala
--
diff --git
[FLINK-7337] [table] Refactor internal handling of time indicator attributes.
- Expand phyiscal Row schema for time indicators.
- Refactor computation of logical schema of tables to import.
- Refactor operators to use time attribute in Row instead of StreamRecord
timestamp.
This closes #4488.
Repository: flink
Updated Branches:
refs/heads/master 6ed5815e8 -> 47944b1bb
http://git-wip-us.apache.org/repos/asf/flink/blob/47944b1b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeUnboundedOver.scala
http://git-wip-us.apache.org/repos/asf/flink/blob/93d0ae4a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalTableSourceScan.scala
--
diff --git
[FLINK-7337] [table] Efficient handling of rowtime timestamps
Use Long instead of a SQL Timestamp to represent timestamps internally
This closes #4532.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/47944b1b
Tree:
Repository: flink
Updated Branches:
refs/heads/master 47944b1bb -> 3e706b13a
[hotifx][streaming] Simplify state of TwoPhaseCommitSinkFunction
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3e706b13
Tree: