[2/2] flink git commit: [FLINK-6244] [cep] Emit timeouted Patterns as Side Output

2017-08-23 Thread dwysakowicz
[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:

[1/2] flink git commit: [FLINK-6244] [cep] Emit timeouted Patterns as Side Output

2017-08-23 Thread dwysakowicz
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

[3/5] flink git commit: [FLINK-7337] [table] Refactor internal handling of time indicator attributes.

2017-08-23 Thread twalthr
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

[5/5] flink git commit: [FLINK-7337] [table] Refactor internal handling of time indicator attributes.

2017-08-23 Thread twalthr
[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.

[1/5] flink git commit: [FLINK-7337] [table] Efficient handling of rowtime timestamps

2017-08-23 Thread twalthr
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

[4/5] flink git commit: [FLINK-7337] [table] Refactor internal handling of time indicator attributes.

2017-08-23 Thread twalthr
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

[2/5] flink git commit: [FLINK-7337] [table] Efficient handling of rowtime timestamps

2017-08-23 Thread twalthr
[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:

flink git commit: [hotifx][streaming] Simplify state of TwoPhaseCommitSinkFunction

2017-08-23 Thread aljoscha
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: