Commits

Branch selector

 master

User selector

fhueske

Datepicker

All time

Commit History

Commits on Nov 22, 2017

• [FLINK-2170] [connectors] Add OrcRowInputFormat and OrcTableSource.

  Show description for 200612e
  fhueske

  committed
  200612e

  Copy full SHA for 200612e

Commits on Nov 16, 2017

• [FLINK-8016] [docs] Add documentation for KafkaJsonTableSinks.

  Show description for c697bc1
  fhueske

  committed
  c697bc1

  Copy full SHA for c697bc1

• [FLINK-8014] [table] Add Kafka010JsonTableSink.

  Show description for 50fba9a
  fhueske

  committed
  50fba9a

  Copy full SHA for 50fba9a

Commits on Nov 15, 2017

• [FLINK-7490] [table] Use correct classloader to compile generated code that calls UDAGGs.

  Show description for 59df4b7
  

  fhueske

  authored and

  twalthr

  committed
  59df4b7

  Copy full SHA for 59df4b7

Commits on Nov 8, 2017

• [FLINK-8002] [table] Fix join window boundary for LESS_THAN and GREATER_THAN predicates.

  Show description for 989c779
  fhueske

  committed
  989c779

  Copy full SHA for 989c779

• [FLINK-8012] [table] Fix TableSink config for tables with time attributes.

  Show description for 8c5b547
  fhueske

  committed
  8c5b547

  Copy full SHA for 8c5b547

Commits on Nov 7, 2017

• [hotfix] [docs] Fix UDTF join description in SQL docs.

  fhueske

  committed
  81e1ac3

  Copy full SHA for 81e1ac3

• [hotfix] [docs] Improve Supported Types section of Table API & SQL docs.

  fhueske

  committed
  f1ea6a6

  Copy full SHA for f1ea6a6

Commits on Nov 2, 2017

• [FLINK-7338] [table] Fix retrieval of OVER window lower bound.

  fhueske

  committed
  16b0882

  Copy full SHA for 16b0882

• [FLINK-7421] [table] Fix serializability of AvroRowSerializationSchema + AvroRowDeserializationSchema.

  fhueske

  committed
  78c8ea2

  Copy full SHA for 78c8ea2

• [FLINK-6226] [table] Add tests for UDFs with Byte, Short, and Float arguments.

  fhueske

  committed
  6e118d1

  Copy full SHA for 6e118d1

Commits on Oct 31, 2017

• [FLINK-6563] [table] Add builders with time attribute support for KafkaTableSources.

  Show description for 0e92b66
  fhueske

  committed
  0e92b66

  Copy full SHA for 0e92b66

• [FLINK-7939] [table] Fix Table conversion of DataStream of AtomicType.

  Show description for 505d478
  fhueske

  committed
  505d478

  Copy full SHA for 505d478

Commits on Oct 30, 2017

• [FLINK-7548] [table] Refactor TableSource interface.

  Show description for 9a2ba6e
  fhueske

  committed
  9a2ba6e

  Copy full SHA for 9a2ba6e

Commits on Oct 27, 2017

• [hotfix] [table] Include commons-lang3 in flink-table artifact JAR.

  fhueske

  committed
  7997715

  Copy full SHA for 7997715

Commits on Oct 25, 2017

• [FLINK-6697] [table] Add support for group window ROWTIME to batch SQL & Table API.

  Show description for babee27
  fhueske

  committed
  babee27

  Copy full SHA for babee27

• [FLINK-6584] [docs] Add ROWTIME and PROCTIME group window functions to documentation.

  fhueske

  committed
  14e0948

  Copy full SHA for 14e0948

Commits on Oct 24, 2017

• [FLINK-7821] [table] Deprecate Table.limit() and replace it by Table.offset() and Table.fetch().

  Show description for e1c7e49
  fhueske

  committed
  e1c7e49

  Copy full SHA for e1c7e49

• [FLINK-7755] [table] Fix NULL handling in batch joins.

  Show description for 2a63815
  fhueske

  committed
  2a63815

  Copy full SHA for 2a63815

Commits on Oct 13, 2017

• [FLINK-7763] [table] Fix testing RowSink for enabled object reuse.

  fhueske

  committed
  57333c6

  Copy full SHA for 57333c6

Commits on Oct 10, 2017

• [FLINK-6233] [table] Add more tests for rowtime window join + minor refactoring.

  fhueske

  committed
  1ea7f49

  Copy full SHA for 1ea7f49

Commits on Oct 4, 2017

• [FLINK-7446] [table] Change DefinedRowtimeAttribute to work on existing field.

  Show description for dae21da
  fhueske

  committed
  dae21da

  Copy full SHA for dae21da

• [hotfix] [hbase] Set root log level to OFF for flink-hbase tests.

  Show description for 3a89ab2
  

  fhueske

  authored and

  StephanEwen

  committed
  3a89ab2

  Copy full SHA for 3a89ab2

Commits on Sep 22, 2017

• [FLINK-7656] [runtime] Switch to user classloader before calling initializeOnMaster and finalizeOnMaster.

  Show description for 4afca4b
  fhueske

  committed
  4afca4b

  Copy full SHA for 4afca4b

Commits on Sep 21, 2017

• [FLINK-7571] [table] Fix translation of TableSource with time indicators.

  Show description for 2a4ac66
  fhueske

  committed
  2a4ac66

  Copy full SHA for 2a4ac66

Commits on Sep 5, 2017

• [FLINK-7404] [table] Generate code for non-equi join conditions only.

  Show description for 4cf737c
  fhueske

  committed
  4cf737c

  Copy full SHA for 4cf737c

Commits on Aug 23, 2017

• [FLINK-7337] [table] Refactor internal handling of time indicator attributes.

  Show description for 93d0ae4
  

  fhueske

  authored and

  twalthr

  committed
  93d0ae4

  Copy full SHA for 93d0ae4

Commits on Aug 11, 2017

• [hotfix] [docs] Improve TableSink documentation.

  fhueske

  committed
  f78eb0f

  Copy full SHA for f78eb0f

Commits on Aug 7, 2017

• [FLINK-7221] [jdbc] Throw exception if execution of last JDBC batch fails.

  Show description for 6ea9dbb
  fhueske

  committed
  6ea9dbb

  Copy full SHA for 6ea9dbb

Commits on Jul 21, 2017

• [FLINK-7194] [table] Add default implementations for type hints to UDAGG interface.

  Show description for ea1edfb
  

  fhueske

  authored and

  sunjincheng121

  committed
  ea1edfb

  Copy full SHA for ea1edfb

• [FLINK-6747] [docs] Add documentation for dynamic tables.

  Show description for c472309
  

  fhueske

  authored and

  sunjincheng121

  committed
  c472309

  Copy full SHA for c472309

Commits on Jul 18, 2017

• [hotfix] [hadoopCompat] Fix tests to verify results new Hadoop input API.

  Show description for ba7ec5e
  fhueske

  committed
  ba7ec5e

  Copy full SHA for ba7ec5e

Commits on Jul 17, 2017

• [FLINK-6232] [table] Add SQL documentation for time window join.

  Show description for 471345c
  fhueske

  committed
  471345c

  Copy full SHA for 471345c

Commits on Jul 13, 2017

• [FLINK-6693] [table] Support dateFormat() function in Scala Table API.

  Show description for 3dbbeed
  fhueske

  committed
  3dbbeed

  Copy full SHA for 3dbbeed

Commits on Jul 10, 2017

• [FLINK-6747] [docs] Add documentation for QueryConfig.

  Show description for ccf1000
  fhueske

  committed
  ccf1000

  Copy full SHA for ccf1000

Pagination

Previous

Next