Commits

Branch selector

 master

User selector

wuchong

Datepicker

All time

Commit History

Commits on Sep 26, 2017

• [FLINK-7439] [table] Support variable arguments for UDTF in SQL

  Show description for 79c17af
  

  wuchong

  authored and

  twalthr

  committed
  79c17af

  Copy full SHA for 79c17af

Commits on Aug 14, 2017

• [FLINK-7441] [table] Double quote string literals is not supported in Table API and SQL

  Show description for 98c06ad
  

  wuchong

  authored and

  twalthr

  committed
  98c06ad

  Copy full SHA for 98c06ad

Commits on Jul 17, 2017

• [FLINK-6887] [table] Split up CodeGenerator into several specific CodeGenerator

  Show description for 527e749
  wuchong

  committed
  527e749

  Copy full SHA for 527e749

Commits on Jul 13, 2017

• [FLINK-7126] [table] Support Distinct for Stream SQL and Table API

  Show description for c8ca31a
  

  wuchong

  authored and

  sunjincheng121

  committed
  c8ca31a

  Copy full SHA for c8ca31a

• [FLINK-6888] [table] Fix can't determine TypeInformation of ACC type of AggregateFunction when ACC is a Scala class

  Show description for 5946327
  wuchong

  committed
  5946327

  Copy full SHA for 5946327

Commits on Jun 19, 2017

• [FLINK-6930] [table] Forbid selecting window start/end on row-based Tumble/Slide windows

  Show description for 06e6338
  wuchong

  committed
  06e6338

  Copy full SHA for 06e6338

Commits on Jun 11, 2017

• [FLINK-6817] [table] Add OverWindowWithPreceding class to guide users apply preceding in over window

  Show description for 5f63bf9
  wuchong

  committed
  5f63bf9

  Copy full SHA for 5f63bf9

Commits on Jun 7, 2017

• [FLINK-6834] [table] Support scalar functions on Over Window

  Show description for 1cc1bb4
  

  wuchong

  authored and

  zentol

  committed
  1cc1bb4

  Copy full SHA for 1cc1bb4

Commits on Jun 6, 2017

• [FLINK-6816] [table] Fix wrong usage of Scala string interpolation in Table API

  Show description for 762141e
  

  wuchong

  authored and

  twalthr

  committed
  762141e

  Copy full SHA for 762141e

Commits on Mar 14, 2017

• [FLINK-5441] [table] Directly allow SQL queries on a Table

  Show description for f333723
  

  wuchong

  authored and

  twalthr

  committed
  f333723

  Copy full SHA for f333723

Commits on Feb 15, 2017

• [FLINK-5714] [table] Use a builder pattern for creating CsvTableSource

  Show description for 6c310a7
  

  wuchong

  authored and

  twalthr

  committed
  6c310a7

  Copy full SHA for 6c310a7

Commits on Jan 30, 2017

• [FLINK-5678] [table] Fix User-defined Functions do not support all types of parameters

  Show description for 126fb17
  

  wuchong

  authored and

  twalthr

  committed
  126fb17

  Copy full SHA for 126fb17

Commits on Jan 26, 2017

• [FLINK-5224] [table] Improve UDTF: emit rows directly instead of buffering them

  Show description for b5f870a
  

  wuchong

  authored and

  twalthr

  committed
  b5f870a

  Copy full SHA for b5f870a

Commits on Jan 16, 2017

• [FLINK-4692] [table] Add tumbling group-windows for batch tables

  Show description for 88576a0
  

  wuchong

  authored and

  twalthr

  committed
  88576a0

  Copy full SHA for 88576a0

Commits on Jan 5, 2017

• [FLINK-4686] [table] Add possibility to get column names

  Show description for 6ac5794
  

  wuchong

  authored and

  twalthr

  committed
  6ac5794

  Copy full SHA for 6ac5794

Commits on Dec 22, 2016

• [FLINK-5348] [core] Add support for custom field names to RowTypeInfo.

  Show description for d163f84
  

  wuchong

  authored and

  fhueske

  committed
  d163f84

  Copy full SHA for d163f84

• [FLINK-5385] [core] Add a helper method to create Row object.

  Show description for 61ae04f
  

  wuchong

  authored and

  fhueske

  committed
  61ae04f

  Copy full SHA for 61ae04f

Commits on Dec 15, 2016

• [FLINK-5187] [core] Port Row and related type utils to Java and move them to flink-core.

  Show description for 86f8a25
  

  wuchong

  authored and

  fhueske

  committed
  86f8a25

  Copy full SHA for 86f8a25

Commits on Dec 13, 2016

• [FLINK-5223] [doc] Add documentation of UDTF in Table API & SQL

  Show description for 5c86efb
  

  wuchong

  authored and

  fhueske

  committed
  5c86efb

  Copy full SHA for 5c86efb

• [FLINK-5304] [table] Rename crossApply/outerApply to join/leftOuterJoin in Table API.

  Show description for da4af12
  

  wuchong

  authored and

  fhueske

  committed
  da4af12

  Copy full SHA for da4af12

Commits on Dec 7, 2016

• [FLINK-4469] [table] Add support for user defined table function in Table API & SQL

  

  wuchong

  authored and

  twalthr

  committed
  e139f59

  Copy full SHA for e139f59

Commits on Nov 10, 2016

• [hotfix] [docs] [tableAPI] Fix typos in Table API documentation.

  Show description for 5767167
  

  wuchong

  authored and

  fhueske

  committed
  5767167

  Copy full SHA for 5767167

Commits on Oct 27, 2016

• [FLINK-4579] [RocksDB backend] Add StateBackendFactory and config shortcut for the RocksDB Backend

  Show description for fc730bb
  

  wuchong

  authored and

  StephanEwen

  committed
  fc730bb

  Copy full SHA for fc730bb

Commits on Oct 25, 2016

• [FLINK-4762] [table] Use plural in time interval units

  Show description for 11fa089
  

  wuchong

  authored and

  fhueske

  committed
  11fa089

  Copy full SHA for 11fa089

Commits on Oct 24, 2016

• [FLINK-4866] [streaming] Make Trigger.clear() Abstract to Enforce Implementation

  

  wuchong

  authored and

  aljoscha

  committed
  2c20b39

  Copy full SHA for 2c20b39

Commits on Oct 19, 2016

• [FLINK-4510] [checkpoint] Always create CheckpointCoordinator

  Show description for 398bd9b
  

  wuchong

  authored and

  uce

  committed
  398bd9b

  Copy full SHA for 398bd9b

Commits on Oct 4, 2016

• [FLINK-4546] [table] Remove STREAM keyword in Stream SQL

  Show description for 72e6b76
  

  wuchong

  authored and

  twalthr

  committed
  72e6b76

  Copy full SHA for 72e6b76

• [FLINK-4068] [table] Move constant computations out of code-generated

  Show description for a711339
  

  wuchong

  authored and

  twalthr

  committed
  a711339

  Copy full SHA for a711339

Commits on Sep 26, 2016

• [FLINK-4662] Bump Calcite version up to 1.9

  Show description for 8fa313c
  

  wuchong

  authored and

  twalthr

  committed
  8fa313c

  Copy full SHA for 8fa313c

Commits on Aug 30, 2016

• [FLINK-4271] [DataStream API] Enable CoGroupedStreams and JoinedStreams to set parallelism.

  Show description for 2a20229
  

  wuchong

  authored and

  StephanEwen

  committed
  2a20229

  Copy full SHA for 2a20229

Commits on Aug 29, 2016

• [FLINK-4420] [table] Introduce star(*) to select all of the columns in the table

  Show description for 1f17886
  

  wuchong

  authored and

  twalthr

  committed
  1f17886

  Copy full SHA for 1f17886

Commits on Aug 24, 2016

• [FLINK-4453] [docs] Scala code example in Window documentation shows Java

  Show description for 42f65e4
  

  wuchong

  authored and

  StephanEwen

  committed
  42f65e4

  Copy full SHA for 42f65e4

Commits on Aug 23, 2016

• [FLINK-4435] Replace Guava's VisibleForTesting annotation with Flink's annotation

  Show description for 863dc18
  

  wuchong

  authored and

  StephanEwen

  committed
  863dc18

  Copy full SHA for 863dc18

Commits on Aug 17, 2016

• [FLINK-4281] [table] Wrap all Calcite Exceptions in Flink Exceptions

  Show description for 7ce42c2
  

  wuchong

  authored and

  twalthr

  committed
  7ce42c2

  Copy full SHA for 7ce42c2

Commits on Aug 16, 2016

• [FLINK-4366] Add 'forceNonParallel()' to stream transformations and enforce parallelism=1 for AllWindowedStream

  Show description for ffe4065
  

  wuchong

  authored and

  StephanEwen

  committed
  ffe4065

  Copy full SHA for ffe4065

Pagination

Previous

Next