[1/3] flink git commit: [FLINK-5223] [doc] Add documentation of UDTF in Table API & SQL

Repository: flink Updated Branches: refs/heads/master 270140a1d -> 5baea3f2e [FLINK-5223] [doc] Add documentation of UDTF in Table API & SQL This closes #2956. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5c86efbb

[3/3] flink git commit: [FLINK-3848] [table] Add ProjectableTableSource and push projections into BatchTableSourceScan.

[FLINK-3848] [table] Add ProjectableTableSource and push projections into BatchTableSourceScan. This closes #2923. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5baea3f2 Tree:

[3/7] flink git commit: [FLINK-5188] [table] [connectors] [core] Adjust imports and method calls to new Row type.

[FLINK-5188] [table] [connectors] [core] Adjust imports and method calls to new Row type. - Port RowCsvInputFormat to Java and move it to flink-core. This closes #3003. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/7] flink git commit: [FLINK-5188] [table] [connectors] [core] Adjust imports and method calls to new Row type.

Repository: flink Updated Branches: refs/heads/master 5dab9345c -> 4d27f8f2d http://git-wip-us.apache.org/repos/asf/flink/blob/4d27f8f2/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/SumAggregate.scala

[2/7] flink git commit: [FLINK-5188] [table] [connectors] [core] Adjust imports and method calls to new Row type.

http://git-wip-us.apache.org/repos/asf/flink/blob/4d27f8f2/flink-java/src/test/java/org/apache/flink/api/java/io/RowCsvInputFormatTest.java -- diff --git

[7/7] flink git commit: [FLINK-5266] [table] Inject projection of unused fields before aggregations.

[FLINK-5266] [table] Inject projection of unused fields before aggregations. This closes #2961. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/15e7f0a8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/15e7f0a8 Diff:

flink git commit: [FLINK-5280] [table] Refactor TableSource interface.

Repository: flink Updated Branches: refs/heads/release-1.2 be3784f55 -> a504abe46 [FLINK-5280] [table] Refactor TableSource interface. This closes #3039. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a504abe4 Tree:

[1/2] flink git commit: [FLINK-5280] [table] Refactor TableSource interface.

Repository: flink Updated Branches: refs/heads/master d4d7cc326 -> 2af939a10 [FLINK-5280] [table] Refactor TableSource interface. This closes #3039. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/38ded2bb Tree:

flink git commit: [hotfix] [docs] Improved Table API docs.

Repository: flink Updated Branches: refs/heads/release-1.2 8b7331409 -> d8d9d7603 [hotfix] [docs] Improved Table API docs. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d8d9d760 Tree:

flink git commit: [hotfix] [docs] Improved Table API docs.

Repository: flink Updated Branches: refs/heads/master 2bda5e457 -> 59b3be0ec [hotfix] [docs] Improved Table API docs. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/59b3be0e Tree:

[33/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-connector-kafka-base/pom.xml -- diff --git a/flink-connectors/flink-connector-kafka-base/pom.xml

[26/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerTest.java -- diff --git

[20/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/TableInputFormatITCase.java -- diff --git

[07/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java -- diff --git

[23/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisCommandsContainerBuilder.java -- diff --git

flink git commit: [FLINK-5159] [table] Add single-row broadcast nested-loop join.

Repository: flink Updated Branches: refs/heads/master b181662be -> dbe707324 [FLINK-5159] [table] Add single-row broadcast nested-loop join. - Support for arbitrary joins (cross, theta, equi) if one input has exactly one row. This closes #2811. Project:

flink git commit: [FLINK-5184] [table] Fix compareSerialized() of RowComparator.

Repository: flink Updated Branches: refs/heads/release-1.1 5ebd7c844 -> 0758d0be6 [FLINK-5184] [table] Fix compareSerialized() of RowComparator. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0758d0be Tree:

[1/3] flink git commit: [FLINK-4825] [table] Implement a RexExecutor that uses Flink's code generation.

Repository: flink Updated Branches: refs/heads/master 910f733f5 -> ecfb5b5f6 [FLINK-4825] [table] Implement a RexExecutor that uses Flink's code generation. This closes #2884 This closes #2874 (closing PR with Public API breaking changes) Project:

[3/3] flink git commit: [FLINK-4832] [table] Fix global aggregation of empty tables (Count/Sum = 0).

[FLINK-4832] [table] Fix global aggregation of empty tables (Count/Sum = 0). - Fix injects a union with a null record before the global aggregation. This closes #2840 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ecfb5b5f

[2/3] flink git commit: [FLINK-5184] [table] Fix compareSerialized() of RowComparator.

[FLINK-5184] [table] Fix compareSerialized() of RowComparator. This closes #2894 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0bb68479 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0bb68479 Diff:

[44/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-avro/src/test/java/org/apache/flink/api/io/avro/AvroSplittableInputFormatTest.java -- diff --git

[25/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/testutils/FakeKinesisBehavioursFactory.java -- diff --git

[40/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java -- diff --git

[32/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartition.java -- diff --git

[27/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java -- diff --git

[29/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaShortRetentionTestBase.java -- diff --git

[45/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-avro/src/main/java/org/apache/flink/api/java/io/AvroInputFormat.java -- diff --git

[36/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/Kafka08Fetcher.java -- diff --git

[42/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-connector-elasticsearch2/pom.xml -- diff --git a/flink-connectors/flink-connector-elasticsearch2/pom.xml

[17/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-streaming-connectors/flink-connector-elasticsearch2/pom.xml -- diff --git a/flink-streaming-connectors/flink-connector-elasticsearch2/pom.xml

[12/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-streaming-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ProducerITCase.java -- diff --git

[13/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-streaming-connectors/flink-connector-flume/pom.xml -- diff --git a/flink-streaming-connectors/flink-connector-flume/pom.xml

[18/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleWriteAheadSink.java -- diff --git

[31/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBaseTest.java -- diff --git

[04/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaShortRetentionTestBase.java -- diff --git

[11/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/Kafka08Fetcher.java -- diff --git

[35/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java -- diff --git

[08/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-streaming-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/internal/HandoverTest.java -- diff --git

[01/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

Repository: flink Updated Branches: refs/heads/master cc006ff18 -> 85a19bd4b http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization/KinesisDeserializationSchema.java

[16/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/RollingSink.java -- diff --git

[09/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java -- diff --git

[21/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-hadoop-compatibility/src/test/java/org/apache/flink/test/hadoopcompatibility/mapred/HadoopMapFunctionITCase.java -- diff --git

[39/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/RollingSinkITCase.java -- diff --git

[28/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-connector-kinesis/pom.xml -- diff --git a/flink-connectors/flink-connector-kinesis/pom.xml b/flink-connectors/flink-connector-kinesis/pom.xml new

[14/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-streaming-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/RollingSinkITCase.java -- diff --git

[03/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-streaming-connectors/flink-connector-kafka-base/src/test/resources/logback-test.xml -- diff --git

[49/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-batch-connectors/flink-avro/src/test/resources/avro/user.avsc -- diff --git a/flink-batch-connectors/flink-avro/src/test/resources/avro/user.avsc

[47/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-batch-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java -- diff --git

[38/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-connector-flume/pom.xml -- diff --git a/flink-connectors/flink-connector-flume/pom.xml b/flink-connectors/flink-connector-flume/pom.xml new file

[41/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/RollingSink.java -- diff --git

[51/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

[FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module. This closes #2897. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/de4fe3b7 Tree:

[10/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-streaming-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaShortRetention08ITCase.java -- diff --git

[50/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/avro/EncoderDecoderTest.java -- diff --git

[48/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-batch-connectors/flink-hadoop-compatibility/src/test/java/org/apache/flink/api/java/typeutils/runtime/StringArrayWritable.java -- diff --git

[02/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java -- diff --git

[34/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerCallBridge.java -- diff --git

[30/51] [abbrv] [partial] flink git commit: [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.

http://git-wip-us.apache.org/repos/asf/flink/blob/de4fe3b7/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java -- diff --git

[1/4] flink git commit: [FLINK-5249] [docs] Fix description of datastream rescaling to match the figure.

Repository: flink Updated Branches: refs/heads/master 8134f4433 -> 98d182603 [FLINK-5249] [docs] Fix description of datastream rescaling to match the figure. This closes #2932. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[4/4] flink git commit: [FLINK-5251] [table] Decouple StreamTableSourceScan from TableSourceTable.

[FLINK-5251] [table] Decouple StreamTableSourceScan from TableSourceTable. This closes #2934. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/98d18260 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/98d18260 Diff:

[3/4] flink git commit: [FLINK-5257] [table] Include optimized logical plan in explain().

[FLINK-5257] [table] Include optimized logical plan in explain(). This closes #2949. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6f9633cd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6f9633cd Diff:

[1/2] flink git commit: [FLINK-5249] [docs] Fix description of datastream rescaling to match the figure.

Repository: flink Updated Branches: refs/heads/release-1.1 c7db532ab -> 7bb6b696c [FLINK-5249] [docs] Fix description of datastream rescaling to match the figure. This closes #2932. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-5259] [docs] Fix wrong execution environment in batch retry delays example.

[FLINK-5259] [docs] Fix wrong execution environment in batch retry delays example. This closes #2943. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7bb6b696 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7bb6b696

[2/2] flink-web git commit: [blog] Add Year 2016 in Review blog post.

[blog] Add Year 2016 in Review blog post. This closes #43. Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/f03b28f8 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/f03b28f8 Diff:

[1/2] flink-web git commit: [FLINK-5308] Add missing previous releases and release dates.

Repository: flink-web Updated Branches: refs/heads/asf-site 6a622bc29 -> f03b28f85 [FLINK-5308] Add missing previous releases and release dates. This closes #41. Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit:

[27/47] flink git commit: [FLINK-4704] [table] Refactor package structure of flink-table.

http://git-wip-us.apache.org/repos/asf/flink/blob/ffe9ec8e/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala -- diff --git

[01/47] flink git commit: [FLINK-4704] [table] Refactor package structure of flink-table.

Repository: flink Updated Branches: refs/heads/master 48ef46a4d -> 67c4be648 http://git-wip-us.apache.org/repos/asf/flink/blob/ffe9ec8e/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/datastream/DataStreamCorrelateITCase.scala

[12/47] flink git commit: [FLINK-4704] [table] Refactor package structure of flink-table.

http://git-wip-us.apache.org/repos/asf/flink/blob/ffe9ec8e/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/sql/JoinITCase.scala -- diff --git

[10/47] flink git commit: [FLINK-4704] [table] Refactor package structure of flink-table.

http://git-wip-us.apache.org/repos/asf/flink/blob/ffe9ec8e/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/stream/table/CalcITCase.scala -- diff --git

flink git commit: [hotfix] [table] Disable event-time OVER RANGE UNBOUNDED PRECEDING window.

Repository: flink Updated Branches: refs/heads/master fe2c61a28 -> cac9fa028 [hotfix] [table] Disable event-time OVER RANGE UNBOUNDED PRECEDING window. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cac9fa02 Tree:

[2/5] flink git commit: [FLINK-6089] [table] Add decoration phase for stream queries to rewrite plans after the cost-based optimization.

[FLINK-6089] [table] Add decoration phase for stream queries to rewrite plans after the cost-based optimization. This closes #3564. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6949c8c7 Tree:

[1/5] flink git commit: [FLINK-5658] [table] Add event-time OVER ROWS/RANGE UNBOUNDED PRECEDING aggregation to SQL.

Repository: flink Updated Branches: refs/heads/master 976e03c1e -> fe2c61a28 [FLINK-5658] [table] Add event-time OVER ROWS/RANGE UNBOUNDED PRECEDING aggregation to SQL. This closes #3386. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/5] flink git commit: [FLINK-5570] [table] Register ExternalCatalogs in TableEnvironment.

[FLINK-5570] [table] Register ExternalCatalogs in TableEnvironment. This closes #3409. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/135a57c4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/135a57c4 Diff:

[4/5] flink git commit: [FLINK-5990] [table] Add event-time OVER ROWS BETWEEN x PRECEDING aggregation to SQL.

[FLINK-5990] [table] Add event-time OVER ROWS BETWEEN x PRECEDING aggregation to SQL. This closes #3585. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7a9d39fe Tree:

[5/5] flink git commit: [hotfix] [table] Improved code documentation for external catalog.

[hotfix] [table] Improved code documentation for external catalog. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f97deaa9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f97deaa9 Diff:

flink git commit: [FLINK-5698] [table] Add NestedFieldsProjectableTableSource interface.

Repository: flink Updated Branches: refs/heads/master cac9fa028 -> 5c37e55c8 [FLINK-5698] [table] Add NestedFieldsProjectableTableSource interface. This closes #3269. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-5655] [table] Add event-time OVER RANGE BETWEEN x PRECEDING aggregation to SQL.

Repository: flink Updated Branches: refs/heads/master ca681101f -> d4665a00a [FLINK-5655] [table] Add event-time OVER RANGE BETWEEN x PRECEDING aggregation to SQL. This closes #3629. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[14/50] [abbrv] flink git commit: [FLINK-6018] Add tests for KryoSerializer restore with registered types

http://git-wip-us.apache.org/repos/asf/flink/blob/09164cf2/flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java -- diff --git

[01/50] [abbrv] flink git commit: [FLINK-6139] [build] Add "mapr" build profile

Repository: flink Updated Branches: refs/heads/table-retraction d160b5e56 -> ee033c903 [FLINK-6139] [build] Add "mapr" build profile This build profile is for building Flink to be compatible with MapR. It additionally excludes dependency clashes between MapR's Hadoop / Zookeeper distributions

[43/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Fix waiting for execution termination

[hotfix] [dist. coordination] Fix waiting for execution termination Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/85f75a59 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/85f75a59 Diff:

[03/50] [abbrv] flink git commit: [FLINK-6170] [metrics] Don't rely on stats snapshot for checkpoint metrics

[FLINK-6170] [metrics] Don't rely on stats snapshot for checkpoint metrics This closes #3597. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d0695c05 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d0695c05 Diff:

[28/50] [abbrv] flink git commit: [FLINK-5929] Allow Access to Per-Window State in ProcessWindowFunction

[FLINK-5929] Allow Access to Per-Window State in ProcessWindowFunction Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fad201bf Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fad201bf Diff:

[15/50] [abbrv] flink git commit: [FLINK-6018] Add tests for KryoSerializer restore with registered types

[FLINK-6018] Add tests for KryoSerializer restore with registered types This commit also renames isCompatibleWith() to canRestoreFrom() to make the method asymetric because in the case of KryoSerializer we can restore from state that was stored using no registed types/serializers while the other

[08/50] [abbrv] flink git commit: [FLINK-4354] [heartbeat] Implement heartbeat logic between TaskManager and ResourceManager

[FLINK-4354] [heartbeat] Implement heartbeat logic between TaskManager and ResourceManager This closes #3591. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fd90672f Tree:

[07/50] [abbrv] flink git commit: [FLINK-4354] [heartbeat] Add heartbeats between the ResourceManager and TaskExecutor

[FLINK-4354] [heartbeat] Add heartbeats between the ResourceManager and TaskExecutor Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/83b99f8a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/83b99f8a Diff:

[45/50] [abbrv] flink git commit: [FLINK-5340] [metrics] Add an uptime and downtime metric to the Execution Graph.

[FLINK-5340] [metrics] Add an uptime and downtime metric to the Execution Graph. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/719d0cf1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/719d0cf1 Diff:

[24/50] [abbrv] flink git commit: [FLINK-6089] [table] Add decoration phase for stream queries to rewrite plans after the cost-based optimization.

[FLINK-6089] [table] Add decoration phase for stream queries to rewrite plans after the cost-based optimization. This closes #3564. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6949c8c7 Tree:

[31/50] [abbrv] flink git commit: [FLINK-5911] [gelly] Command-line parameters

[FLINK-5911] [gelly] Command-line parameters Create interface for parsing command-line parameters using ParameterTool and generic implementations for boolean, long, double, string, choice. This closes #3433 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[34/50] [abbrv] flink git commit: [FLINK-6197] [cep] Add support for iterative conditions.

[FLINK-6197] [cep] Add support for iterative conditions. So far, the where clause only supported simple FilterFunction conditions. With this, we add support for conditions where an event is accepted not only based on its own properties, e.g. name, as it was before, but also based on some

[30/50] [abbrv] flink git commit: [hotfix] [docs] Fix broken links

[hotfix] [docs] Fix broken links This closes #3618. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/037b5cbd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/037b5cbd Diff:

[47/50] [abbrv] flink git commit: [FLINK-5655] [table] Add event-time OVER RANGE BETWEEN x PRECEDING aggregation to SQL.

[FLINK-5655] [table] Add event-time OVER RANGE BETWEEN x PRECEDING aggregation to SQL. This closes #3629. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d4665a00 Tree:

[32/50] [abbrv] flink git commit: [FLINK-6197] [cep] Add support for iterative conditions.

http://git-wip-us.apache.org/repos/asf/flink/blob/7fbdc100/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/pattern/PatternTest.java -- diff --git

[19/50] [abbrv] flink git commit: [FLINK-6128] [tests] Optimize JVM options to improve test performance

[FLINK-6128] [tests] Optimize JVM options to improve test performance Decrease the time to run TravisCI builds and reduce OOM by - increasing the heap size - switching to Java's serial garbage collector - removing the UseGCOverheadLimit option This closes #3571 Project:

[25/50] [abbrv] flink git commit: [hotfix] [table] Disable event-time OVER RANGE UNBOUNDED PRECEDING window.

[hotfix] [table] Disable event-time OVER RANGE UNBOUNDED PRECEDING window. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cac9fa02 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cac9fa02 Diff:

[12/50] [abbrv] flink git commit: [hotfix] Add EvictingWindowOperatorContractTest

[hotfix] Add EvictingWindowOperatorContractTest The existing WindowOperatorContractTest is turned into a test base while RegularWindowOperatorContract test tests WindowOperator and EvictingWindowOperatorTest tests EvictingWindowOperator. For this to work, the base tests now always use List

[06/50] [abbrv] flink git commit: [FLINK-3318] Add support for quantifiers to CEP's pattern API

[FLINK-3318] Add support for quantifiers to CEP's pattern API Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9001c4ef Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9001c4ef Diff:

[13/50] [abbrv] flink git commit: [FLINK-5972] Don't allow shrinking merging windows

[FLINK-5972] Don't allow shrinking merging windows This closes #3587. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/68289b1a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/68289b1a Diff:

[2/2] flink git commit: [FLINK-6200] [table] Add support for unbounded event-time OVER RANGE window.

[FLINK-6200] [table] Add support for unbounded event-time OVER RANGE window. This closes #3649. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/44f9c76a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/44f9c76a Diff:

[1/2] flink git commit: [FLINK-5653] [table] Add processing-time OVER ROWS BETWEEN x PRECEDING aggregation to SQL.

Repository: flink Updated Branches: refs/heads/master aa3c395b9 -> ee033c903 [FLINK-5653] [table] Add processing-time OVER ROWS BETWEEN x PRECEDING aggregation to SQL. This closes #3653. This closes #3574. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[16/50] [abbrv] flink git commit: [hotfix] Remove validateRunsInMainThread from TaskExecutor to fix TaskExecutorTest

[hotfix] Remove validateRunsInMainThread from TaskExecutor to fix TaskExecutorTest Currently, the TestingSerialRpcService does not play well together with the MainThreadValidatorUtil which assumes that rpc calls are dispatched to a mailbox from where they are picked up. In order to support the

[44/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Move metrics out of the Execution Graph

[hotfix] [dist. coordination] Move metrics out of the Execution Graph ExecutionGraph-based metrics should be in their own package 'org.apache.flink.runtime.executiongraph.metrics'. They are instantiated by whoever builds the execution graph, but not by the execution graph itself. This separates

<    1   2   3   4   5   6   7   8   9   10   >