Commits

Branch selector

 master

User selector

godfreyhe

Datepicker

All time

Commit History

Commits on Feb 3, 2021

• [FLINK-21092][table-planner-blink] Move the spec classes in exec.utils to exec.spec package

  Show description for 99c1b2f
  godfreyhe

  committed
  99c1b2f

  Copy full SHA for 99c1b2f

• [FLINK-21096][table-planner-blink] Introduce ExecNodeGraphJsonPlanGenerator to serialize ExecNodeGraph to json plan and deserialize json plan to ExecNodeGraph

  Show description for 0150ae4
  godfreyhe

  committed
  0150ae4

  Copy full SHA for 0150ae4

• [FLINK-21094][table-planner-blink] Support StreamExecSink json serialization/deserialization

  Show description for cae2388
  godfreyhe

  committed
  cae2388

  Copy full SHA for cae2388

• [FLINK-21093][table-planner-blink] Support StreamExecTableSource json serialization/deserialization

  Show description for c37905e
  godfreyhe

  committed
  c37905e

  Copy full SHA for c37905e

• [FLINK-21092][table-planner-blink] Introduce getJsonPlan, explainJsonPlan and executeJsonPlan in TableEnvironmentInternal

  Show description for e16e45f
  godfreyhe

  committed
  e16e45f

  Copy full SHA for e16e45f

Commits on Feb 1, 2021

• [FLINK-21150][table-planner-blink] Introduce ExecEdge to connect two ExecNodes

  Show description for 52c540a
  godfreyhe

  authored
  52c540a

  Copy full SHA for 52c540a

Commits on Jan 27, 2021

• [FLINK-21105][table-planner-blink] Rename ExecEdge to InputProperty and rename RequiredShuffle to RequiredDistribution

  Show description for f083c67
  godfreyhe

  authored
  f083c67

  Copy full SHA for f083c67

Commits on Jan 26, 2021

• [minor][table-planner-blink] Minor code cleanup for some exec nodes and physical nodes

  Show description for cacfef2
  godfreyhe

  committed
  cacfef2

  Copy full SHA for cacfef2

• [minor][table-planner-blink] Move CommonPhysicalJoin and CommonPhysicalLookupJoin to nodes.physical.common package

  Show description for 40c3068
  godfreyhe

  committed
  40c3068

  Copy full SHA for 40c3068

• [FLINK-20968][table-planner-blink] Rename ExecNode#getDesc to ExecNode#getDescription

  Show description for e6e9c7a
  godfreyhe

  committed
  e6e9c7a

  Copy full SHA for e6e9c7a

• [FLINK-20968][table-planner-blink] Remove legacy exec nodes

  Show description for 5ed569f
  godfreyhe

  committed
  5ed569f

  Copy full SHA for 5ed569f

Commits on Jan 21, 2021

• [FLINK-21041][table-planner-blink] Introduce ExecNodeGraph to wrap the ExecNode topology

  Show description for 842f5cd
  godfreyhe

  authored
  842f5cd

  Copy full SHA for 842f5cd

Commits on Jan 19, 2021

• [FLINK-20949][table-planner-blink] BatchCommonSubGraphBasedOptimizer should also consider Sink node

  Show description for 53ab259
  godfreyhe

  committed
  53ab259

  Copy full SHA for 53ab259

• [FLINK-20949][table-planner-blink] Introduce BatchPhysicalLegacySink, and make BatchExecLegacySink only extended from ExecNode

  Show description for 45bf1b2
  godfreyhe

  committed
  45bf1b2

  Copy full SHA for 45bf1b2

• [FLINK-20949][table-planner-blink] Introduce StreamPhysicalLegacySink, and make StreamExecLegacySink only extended from ExecNode

  Show description for e99b6e1
  godfreyhe

  committed
  e99b6e1

  Copy full SHA for e99b6e1

• [FLINK-20949][table-planner-blink] Introduce BatchPhysicalSink, and make BatchExecSink only extended from ExecNode

  Show description for 4d9a763
  godfreyhe

  committed
  4d9a763

  Copy full SHA for 4d9a763

• [FLINK-20949][table-planner-blink] Introduce StreamPhysicalSink, and make StreamExecSink only extended from ExecNode

  Show description for 95257a2
  godfreyhe

  committed
  95257a2

  Copy full SHA for 95257a2

Commits on Jan 18, 2021

• [FLINK-20966][table-planner-blink] Rename BatchExecIntermediateTableScan to BatchPhysicalIntermediateTableScan

  Show description for b0f889a
  godfreyhe

  committed
  b0f889a

  Copy full SHA for b0f889a

• [FLINK-20966][table-planner-blink] Rename StreamExecIntermediateTableScan to StreamPhysicalIntermediateTableScan

  Show description for 2417d2e
  godfreyhe

  committed
  2417d2e

  Copy full SHA for 2417d2e

Commits on Jan 15, 2021

• [FLINK-20941][table-planner-blink] Introduce StreamPhysicalMatch, and make StreamExecMatch only extended from ExecNode

  Show description for ef6d6e2
  godfreyhe

  authored
  ef6d6e2

  Copy full SHA for ef6d6e2

Commits on Jan 14, 2021

• [FLINK-20948][table-planner-blink] Introduce StreamPhysicalDeduplicate, and make StreamExecDeduplicate only extended from ExecNode

  Show description for 500c30c
  godfreyhe

  authored
  500c30c

  Copy full SHA for 500c30c

• [FLINK-20883][table-planner-blink] Rename OverWindowITCase to OverAggregateITCase, rename OverWindowTest to OverAggregateTest, and rename OverWindowHarnessTest to OverAggregateHarnessTest

  Show description for 0cf6b6d
  godfreyhe

  committed
  0cf6b6d

  Copy full SHA for 0cf6b6d

• [FLINK-20883][table-planner-blink] Introduce BatchPhysicalPythonOverAggregate, and make BatchExecPythonOverAggregate only extended from ExecNode

  Show description for 2e1a06f
  godfreyhe

  committed
  2e1a06f

  Copy full SHA for 2e1a06f

• [FLINK-20883][table-planner-blink] Introduce BatchPhysicalOverAggregate, and make BatchExecOverAggregate only extended from ExecNode

  Show description for a4ad7ab
  godfreyhe

  committed
  a4ad7ab

  Copy full SHA for a4ad7ab

• [FLINK-20883][table-planner-blink] Introduce StreamPhysicalPythonOverAggregate, and make StreamExecPythonOverAggregate only extended from ExecNode

  Show description for 15bca56
  godfreyhe

  committed
  15bca56

  Copy full SHA for 15bca56

• [FLINK-20883][table-planner-blink] Introduce StreamPhysicalOverAggregate, and make StreamExecOverAggregate only extended from ExecNode

  Show description for 284b58b
  godfreyhe

  committed
  284b58b

  Copy full SHA for 284b58b

Commits on Jan 9, 2021

• [FLINK-20857][table-planner-blink] Introduce BatchPhysicalPythonGroupWindowAggregate, and make BatchExecPythonGroupWindowAggregate only extended from ExecNode

  Show description for 8184934
  godfreyhe

  committed
  8184934

  Copy full SHA for 8184934

• [FLINK-20857][table-planner-blink] Introduce BatchPhysicalSortWindowAggregate & BatchPhysicalLocalSortWindowAggregate, and make BatchExecSortWindowAggregate only extended from ExecNode

  Show description for 36352a3
  godfreyhe

  committed
  36352a3

  Copy full SHA for 36352a3

• [FLINK-20857][table-planner-blink] Introduce BatchPhysicalHashWindowAggregate & BatchPhysicalLocalHashWindowAggregate, and make BatchExecHashWindowAggregate only extended from ExecNode

  Show description for a8e591a
  godfreyhe

  committed
  a8e591a

  Copy full SHA for a8e591a

• [FLINK-20857][table-planner-blink] Rename BatchExecWindowAggregateBase to BatchPhysicalWindowAggregateBase and do some refactoring

  Show description for 2906582
  godfreyhe

  committed
  2906582

  Copy full SHA for 2906582

Commits on Jan 8, 2021

• [FLINK-20856][table-planner-blink] Introduce StreamPhysicalPythonGroupWindowAggregate, and make StreamExecPythonGroupWindowAggregate only extended from ExecNode

  Show description for 85b6a3b
  godfreyhe

  committed
  85b6a3b

  Copy full SHA for 85b6a3b

• [FLINK-20856][table-planner-blink] Introduce StreamPhysicalGroupWindowAggregate & StreamPhysicalGroupWindowTableAggregate, and make StreamExecGroupWindowAggregate only extended from ExecNode

  Show description for 447cc15
  godfreyhe

  committed
  447cc15

  Copy full SHA for 447cc15

Commits on Jan 7, 2021

• [FLINK-20738][table-planner-blink] Introduce BatchPhysicalPythonGroupAggregate, and make BatchExecPythonGroupAggregate only extended from ExecNode

  Show description for 049a61a
  godfreyhe

  committed
  049a61a

  Copy full SHA for 049a61a

• [FLINK-20738][table-planner-blink] Introduce BatchPhysicalLocalSortAggregate, and make BatchPhysicalLocalSortAggregate only extended from FlinkPhysicalRel

  Show description for 63875b3
  godfreyhe

  committed
  63875b3

  Copy full SHA for 63875b3

• [FLINK-20738][table-planner-blink] Introduce BatchPhysicalSortAggregate, and make BatchExecSortAggregate only extended from ExecNode

  Show description for 29c81fe
  godfreyhe

  committed
  29c81fe

  Copy full SHA for 29c81fe

Pagination

Previous

Next