[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

[05/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/KafkaConsumerTestBase.java -- diff --git a/flink-streaming-

[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 a/flink-streaming-connectors/fl

[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 a/flink-strea

[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 a/flink-batch-connectors/flink-avro/src/test/java/org/apach

[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 a/flink-batch-connectors

[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 a/flink-stre

[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 a/flink-connectors/flink-avro/src/test/java/org/apa

[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 a/flink-conn

[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 a/flink-connectors/flink-conn

[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 a/flink-connectors/f

[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 a/flink-connectors/flink-co

[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 a/flink-connectors/fli

[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 a/flink-connectors/flink-avro/src/main/java/org/apache/flink/api/

[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 a/flink-connectors/flink-c

[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 b/flink-connectors/flink-connector-elastics

[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 b/flink-streaming-conne

[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 a/flink-streaming

[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 b/flink-streaming-connectors/flink-connec

[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 a/flink-

[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 a/flink-streaming

[06/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/util/serialization/TypeInformationKeyValueSerializationSchema.java -- diff --

[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 a/flink-connectors/fl

[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 a/flink-connectors/flink-connector-

[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 fi

[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 a/flink-streaming-connect

[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 a/flink-streaming-connectors/flink-connector-kafka-base/src/test/re

[24/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-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfig.java -- diff --git a/flink-connectors/fli

[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 a/flink-connectors

[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 a/flink-connectors/flink-con

[43/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-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleWriteAheadSink.java -- diff --git a/flink-connectors

[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 b/flink-batch-conn

[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 a/flink-batch-connectors/flink-hbase/src/main/java/org/a

[37/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.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ProducerITCase.java -- diff --git a/flink-connectors/flink-co

[46/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-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java -- diff --git a/flink-batch-connectors/flink-jdbc/src/main/java/org/

[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 mod

[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 a/flink-connectors/flink-connector-filesy

[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: http://git-wip-us.apache.org/repos/asf/flink/tree/de4

[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 b/flink-connectors/flink-connector-kafka-base/pom.x

[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: http://git-wip-us.apache.org/repos/asf/flink/com

[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: htt

[2/4] 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/ebe228db Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ebe228db

[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: http://git-w

[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: http://git-wip-us.apache.org/repos/asf/flin

[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

[3/4] flink git commit: [FLINK-3921] Add support to set encoding in CsvReader and StringParser.

[FLINK-3921] Add support to set encoding in CsvReader and StringParser. This closes #2060. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f2186af6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f2186af6 Diff: http:/

[1/4] flink git commit: [FLINK-5226] [table] Use correct DataSetCostFactory and improve DataSetCalc costs.

Repository: flink Updated Branches: refs/heads/master 55d60615a -> 41d5875bf [FLINK-5226] [table] Use correct DataSetCostFactory and improve DataSetCalc costs. - Improved DataSetCalc costs make projections cheap and help to push them down. This closes #2926. Project: http://git-wip-us.apac

[2/4] flink git commit: [FLINK-5039] Bump Avro version to 1.7.7.

[FLINK-5039] Bump Avro version to 1.7.7. This closes #2953. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2d8f03e7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2d8f03e7 Diff: http://git-wip-us.apache.org/repos/as

[4/4] flink git commit: [FLINK-3921] Add support to set encoding in CsvReader and StringParser.

[FLINK-3921] Add support to set encoding in CsvReader and StringParser. - extends first commit. This closes #2901. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/41d5875b Tree: http://git-wip-us.apache.org/repos/asf/flink/t

flink git commit: [FLINK-5039] Bump Avro version to 1.7.7.

Repository: flink Updated Branches: refs/heads/release-1.1 671b434cf -> 3ae6e9e09 [FLINK-5039] Bump Avro version to 1.7.7. This closes #2953. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3ae6e9e0 Tree: http://git-wip-u

[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: http://git-wip-us.apache.org/repos/asf/flink/t

[2/3] flink git commit: [FLINK-5304] [table] Rename crossApply/outerApply to join/leftOuterJoin in Table API.

[FLINK-5304] [table] Rename crossApply/outerApply to join/leftOuterJoin in Table API. This closes #2978. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/da4af125 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/da4af1

[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 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: http://git-wip-us.apache.org/repos/asf/flink/commit/4d27f8

[4/7] flink git commit: [FLINK-5187] [core] Port Row and related type utils to Java and move them to flink-core.

[FLINK-5187] [core] Port Row and related type utils to Java and move them to flink-core. This closes #2968. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/86f8a255 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/86f

[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

[6/7] flink git commit: [FLINK-5189] [table] Delete Row and its related classes from flink-table.

[FLINK-5189] [table] Delete Row and its related classes from flink-table. This closes #3004. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a9e6ec86 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a9e6ec86 Diff: http

[5/7] flink git commit: [FLINK-5189] [table] Delete Row and its related classes from flink-table.

http://git-wip-us.apache.org/repos/asf/flink/blob/a9e6ec86/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/table/typeutils/RowSerializerTest.scala -- diff --git a/flink-libraries/flink-table/src/test/scala/org/apac

[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 a/flink-java/src/test/java/org/apache/flink/api/java/io/RowCsvInputFormatTes

[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: h

[03/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/table/api/scala/stream/table/UnionITCase.scala -- diff --git a/flink-libraries/flink-table/src/test/scala/org/a

[23/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/expressions/ExpressionParser.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/

[07/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/table/runtime/datastream/DataStreamCorrelateITCase.scala -- diff --git a/flink-libraries/flink-table/src/te

[22/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/expressions/mathExpressions.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/f

[30/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/api/table/runtime/aggregate/MinAggregate.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/a

[08/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/table/expressions/SqlExpressionTest.scala -- diff --git a/flink-libraries/flink-table/src/test/scala/org/ap

[26/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/calcite/FlinkPlannerImpl.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flin

[38/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/api/table/codegen/calls/FloorCeilCallGen.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/a

[17/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/runtime/aggregate/Aggregate.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/f

[16/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/runtime/aggregate/MinAggregate.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apach

[25/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/codegen/CodeGenerator.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/t

[43/47] flink git commit: [FLINK-5008] [docs] Update IDE setup and quickstart documentation.

[FLINK-5008] [docs] Update IDE setup and quickstart documentation. This closes #2764. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/67c4be64 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/67c4be64 Diff: http://git-

[41/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/java/org/apache/flink/table/explain/PlanJsonParser.java -- diff --git a/flink-libraries/flink-table/src/main/java/org/apache/flink/tab

[13/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/java/org/apache/flink/table/api/java/batch/table/JoinITCase.java -- diff --git a/flink-libraries/flink-table/src/test/java/org/apache/

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

[FLINK-4704] [table] Refactor package structure of flink-table. This closes #2958. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ffe9ec8e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ffe9ec8e Diff: http://git-wip

[09/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/table/ExpressionReductionTest.scala -- diff --git a/flink-libraries/flink-table/src/test/scala/org/apache/f

[36/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/api/table/expressions/mathExpressions.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apac

[47/47] flink git commit: [FLINK-5255] [table] Generalize detection of single row inputs for DataSetSingleRowJoinRule.

[FLINK-5255] [table] Generalize detection of single row inputs for DataSetSingleRowJoinRule. - Add support for projections and filters following a global aggregation. This closes #3009. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/fl

[20/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/plan/nodes/FlinkCorrelate.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/fli

[02/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/table/expressions/ScalarOperatorsTest.scala -- diff --git a/flink-libraries/flink-table/src/test/scala/org/apac

[32/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/api/table/plan/rules/dataSet/DataSetSortRule.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/o

[35/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/api/table/plan/ProjectionTranslator.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache

[28/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/StreamTableEnvironment.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/fl

[18/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/plan/rules/dataSet/DataSetSortRule.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/a

[33/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/api/table/plan/nodes/datastream/DataStreamAggregate.scala -- diff --git a/flink-libraries/flink-table/src/main/

[31/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/api/table/runtime/aggregate/Aggregate.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apac

[37/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/api/table/expressions/ExpressionParser.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apa

[29/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/api/table/typeutils/TimeIntervalTypeInfo.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/a

[11/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/table/JoinITCase.scala -- diff --git a/flink-libraries/flink-table/src/test/scala/org/apache/fl

[04/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/table/api/scala/batch/table/UserDefinedTableFunctionTest.scala -- diff --git a/flink-libraries/flink-table/src/

[34/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/api/table/plan/nodes/FlinkRel.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink

[46/47] flink git commit: [FLINK-3848] [table] follow-up: Refactor TableSource tests.

[FLINK-3848] [table] follow-up: Refactor TableSource tests. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/22af6cf5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/22af6cf5 Diff: http://git-wip-us.apache.org/repos/asf

[45/47] flink git commit: [FLINK-5343] [table] Add support to overwrite files with CsvTableSink.

[FLINK-5343] [table] Add support to overwrite files with CsvTableSink. This closes #3011. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cc34c145 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cc34c145 Diff: http://

[19/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/plan/nodes/datastream/DataStreamAggregate.scala -- diff --git a/flink-libraries/flink-table/src/main/scal

[21/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/plan/ProjectionTranslator.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/fli

[15/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/java/org/apache/flink/api/java/batch/ExplainTest.java -- diff --git a/flink-libraries/flink-table/src/test/java/org/apache/flink/api/j

[44/47] flink git commit: [FLINK-3848] [table] Add projection push down for StreamTableSource.

[FLINK-3848] [table] Add projection push down for StreamTableSource. - Add plan tests for projection push down. - Implement ProjectableTableSource in CsvTableSource. - Refactored RowCsvInputFormat This closes #2810. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-w

[39/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/api/table/codegen/CodeGenUtils.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flin

[40/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/api/table/BatchTableEnvironment.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/fli

[05/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/table/api/scala/batch/table/AggregationsITCase.scala -- diff --git a/flink-libraries/flink-table/src/test/scala

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