Commits

Branch selector

 master

User selector

beyond1920

Datepicker

All time

Commit History

Commits on Dec 29, 2021

• [FLINK-23999][table-planner] Support evaluating individual window table-valued function in planner (apache#17684)

  beyond1920

  authored
  9fce1be

  Copy full SHA for 9fce1be

Commits on Dec 28, 2021

• [FLINK-24772][docs] Add documentation for individual window table-valued function (apache#17885)

  beyond1920

  authored
  0797708

  Copy full SHA for 0797708

Commits on Nov 29, 2021

• [FLINK-21327][table-planner-blink] Support window TVF in batch mode (apache#17666)

  beyond1920

  authored
  f37f85e

  Copy full SHA for f37f85e

Commits on Nov 25, 2021

• [FLINK-24760][docs] Update user document for batch window tvf (apache#17670)

  beyond1920

  authored
  5bc3951

  Copy full SHA for 5bc3951

Commits on Nov 19, 2021

• [FLINK-24835][table-planner] Fix bug in RelTimeIndicatorConverter when materialize time attribute fields of regular join's inputs

  Show description for 8aa74d5
  

  beyond1920

  authored and

  godfreyhe

  committed
  8aa74d5

  Copy full SHA for 8aa74d5

Commits on Nov 18, 2021

• [FLINK-24656][docs] Add documentation for window deduplication

  Show description for 69d0918
  

  beyond1920

  authored and

  godfreyhe

  committed
  69d0918

  Copy full SHA for 69d0918

Commits on Nov 11, 2021

• [FLINK-23014][table-planner] Support streaming window Deduplicate in planner

  Show description for 9699484
  

  beyond1920

  authored and

  godfreyhe

  committed
  9699484

  Copy full SHA for 9699484

Commits on Nov 10, 2021

• [FLINK-24001][table-runtime] Window table-valued function operator support proctime window

  Show description for ad3210b
  beyond1920

  authored
  ad3210b

  Copy full SHA for ad3210b

• [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator

  Show description for cba6b2c
  beyond1920

  authored
  cba6b2c

  Copy full SHA for cba6b2c

Commits on Nov 3, 2021

• [FLINK-23015][table-runtime] Implement streaming window Deduplicate operator

  Show description for 59d6a18
  beyond1920

  authored
  59d6a18

  Copy full SHA for 59d6a18

Commits on Nov 1, 2021

• [FLINK-23919][table-planner] Fix field name conflict bug in WindowUtil

  Show description for 003df21
  

  beyond1920

  authored and

  godfreyhe

  committed
  003df21

  Copy full SHA for 003df21

Commits on Sep 18, 2021

• [FLINK-24168][table-planner] Update MATCH_ROWTIME function which could receive 0 argument or 1 argument

  Show description for 475a662
  

  beyond1920

  authored and

  godfreyhe

  committed
  475a662

  Copy full SHA for 475a662

Commits on Sep 1, 2021

• [FLINK-23750][docs][table] Add documentation for Window Top-N after Windowing TVF (apache#16983)

  beyond1920

  authored
  f946614

  Copy full SHA for f946614

Commits on Aug 31, 2021

• [FLINK-23287][docs][table] Add documentation for Window Join in SQL (apache#16997)

  beyond1920

  authored
  ebed56f

  Copy full SHA for ebed56f

Commits on Aug 30, 2021

• [FLINK-23055][docs][table] Add documentation for window tvf offset. (apache#17015)

  beyond1920

  authored
  ae1eced

  Copy full SHA for ae1eced

Commits on Aug 16, 2021

• [FLINK-21290][table-planner] Support project push down for window TVF

  Show description for 25bce2f
  

  beyond1920

  authored and

  godfreyhe

  committed
  25bce2f

  Copy full SHA for 25bce2f

• [FLINK-23247][table-planner] Materialize time attribute fields of regular join's inputs

  Show description for b3dea50
  

  beyond1920

  authored and

  godfreyhe

  committed
  b3dea50

  Copy full SHA for b3dea50

Commits on Aug 11, 2021

• [FLINK-23544][table-planner] Window TVF Supports session window in plan

  Show description for 34d5100
  

  beyond1920

  authored and

  godfreyhe

  committed
  34d5100

  Copy full SHA for 34d5100

• [FLINK-23246][table-planner] Refactor the time indicator materialization

  Show description for 3a19739
  

  beyond1920

  authored and

  godfreyhe

  committed
  3a19739

  Copy full SHA for 3a19739

Commits on Jul 27, 2021

• [FLINK-23413][table-planner] Port RelTimeIndicatorConverter from SCALA to JAVA

  Show description for f2304d8
  

  beyond1920

  authored and

  godfreyhe

  committed
  f2304d8

  Copy full SHA for f2304d8

• [FLINK-22715][table-runtime] Implement streaming window assigner table function operator

  Show description for b27aa10
  beyond1920

  authored
  b27aa10

  Copy full SHA for b27aa10

Commits on Jul 12, 2021

• [FLINK-23023][table-planner] Support offset in window TVF

  Show description for 5cc769d
  

  beyond1920

  authored and

  godfreyhe

  committed
  5cc769d

  Copy full SHA for 5cc769d

Commits on Jul 7, 2021

• [FLINK-23283][table-planner] Fix unstable case GroupWindowITCase#testWindowAggregateOnUpsertSource

  Show description for 4e9fa33
  

  beyond1920

  authored and

  godfreyhe

  committed
  4e9fa33

  Copy full SHA for 4e9fa33

Commits on Jul 6, 2021

• [FLINK-22781][table-planner-blink] Fix bug in emit behavior of GroupWindowAggregate to skip emit window result if input stream of GroupWindowAggregate contains retraction and input counter of input…

  Show description for c919edf
  

  beyond1920

  authored and

  godfreyhe

  committed
  c919edf

  Copy full SHA for c919edf

• [FLINK-22714][table-planner-blink] Simplify window TVF to a simple window assigner if successor

  Show description for f61d9af
  

  beyond1920

  authored and

  godfreyhe

  committed
  f61d9af

  Copy full SHA for f61d9af

Commits on Jun 10, 2021

• [FLINK-21301][table-planner-blink] Decouple window aggregate allow lateness with state ttl configuration

  Show description for 1455028
  beyond1920

  authored
  1455028

  Copy full SHA for 1455028

Commits on Jun 9, 2021

• [FLINK-22894][table-runtime] Fix rankEnd validation of WindowRank to support top1

  Show description for fcc4b89
  beyond1920

  authored
  fcc4b89

  Copy full SHA for fcc4b89

Commits on Jun 5, 2021

• [FLINK-22038][table-planner-blink] Update TopN to be without rowNumber if rowNumber field is never used by the successor Calc

  Show description for 92465ff
  

  beyond1920

  authored and

  godfreyhe

  committed
  92465ff

  Copy full SHA for 92465ff

• [FLINK-22680][table-planner-blink] Fix IndexOutOfBoundsException when apply WatermarkAssignerChangelogNormalizeTransposeRule

  Show description for 73d97fb
  

  beyond1920

  authored and

  godfreyhe

  committed
  73d97fb

  Copy full SHA for 73d97fb

Commits on Jun 3, 2021

• [FLINK-22038][table-planner-blink] Update TopN to be without rowNumber if rowNumber field is never used by the successor Calc

  Show description for 362aadc
  

  beyond1920

  authored and

  godfreyhe

  committed
  362aadc

  Copy full SHA for 362aadc

• [FLINK-22680][table-planner-blink] Fix IndexOutOfBoundsException when apply WatermarkAssignerChangelogNormalizeTransposeRule

  Show description for a364daa
  

  beyond1920

  authored and

  godfreyhe

  committed
  a364daa

  Copy full SHA for a364daa

Commits on May 24, 2021

• [FLINK-22719][table-planner-blink] Fall back to regular join instead of thrown exception if a join does not satisfy conditions to translate into WindowJoin

  Show description for 5ec4755
  beyond1920

  authored
  5ec4755

  Copy full SHA for 5ec4755

Commits on May 18, 2021

• [FLINK-20487][table-planner-blink] Remove restriction on StreamPhysicalGroupWindowAggregate which only supports insert-only input node

  Show description for 1a1a729
  beyond1920

  authored
  1a1a729

  Copy full SHA for 1a1a729

Commits on May 8, 2021

• [FLINK-19606][table-planner] Introduce StreamExecWindowJoin and window join it cases

  Show description for 3eef1cb
  beyond1920

  authored
  3eef1cb

  Copy full SHA for 3eef1cb

• [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder

  Show description for 89e81c2
  beyond1920

  authored
  89e81c2

  Copy full SHA for 89e81c2

Pagination

Previous

Next