Commits

Commits on Nov 16, 2017

[FLINK-8014] [table] Add Kafka010JsonTableSink.
fhueske
committedNov 16, 2017

Commits on Nov 15, 2017

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

fhueske
authored and
twalthr
committedNov 15, 2017

Commits on Nov 8, 2017

[FLINK-8002] [table] Fix join window boundary for LESS_THAN and GREATER_THAN predicates.
fhueske
committedNov 8, 2017
[FLINK-8012] [table] Fix TableSink config for tables with time attributes.
fhueske
committedNov 8, 2017

Commits on Nov 7, 2017

[hotfix] [docs] Fix UDTF join description in SQL docs.
fhueske
committedNov 7, 2017
[hotfix] [docs] Improve Supported Types section of Table API & SQL docs.
fhueske
committedNov 7, 2017

Commits on Nov 2, 2017

Commits on Oct 31, 2017

[FLINK-6563] [table] Add builders with time attribute support for KafkaTableSources.
fhueske
committedOct 31, 2017
[FLINK-7939] [table] Fix Table conversion of DataStream of AtomicType.
fhueske
committedOct 31, 2017

Commits on Oct 30, 2017

[FLINK-7548] [table] Refactor TableSource interface.
fhueske
committedOct 30, 2017

Commits on Oct 27, 2017

[hotfix] [table] Include commons-lang3 in flink-table artifact JAR.
fhueske
committedOct 27, 2017

Commits on Oct 25, 2017

Commits on Oct 24, 2017

[FLINK-7821] [table] Deprecate Table.limit() and replace it by Table.offset() and Table.fetch().
fhueske
committedOct 24, 2017
[FLINK-7755] [table] Fix NULL handling in batch joins.
fhueske
committedOct 24, 2017

Commits on Oct 13, 2017

[FLINK-7763] [table] Fix testing RowSink for enabled object reuse.
fhueske
committedOct 13, 2017

Commits on Oct 10, 2017

[FLINK-6233] [table] Add more tests for rowtime window join + minor refactoring.
fhueske
committedOct 10, 2017

Commits on Oct 4, 2017

[FLINK-7446] [table] Change DefinedRowtimeAttribute to work on existing field.
fhueske
committedOct 4, 2017
[hotfix] [hbase] Set root log level to OFF for flink-hbase tests.

fhueske
authored and
StephanEwen
committedOct 4, 2017

Commits on Sep 22, 2017

[FLINK-7656] [runtime] Switch to user classloader before calling initializeOnMaster and finalizeOnMaster.
fhueske
committedSep 22, 2017

Commits on Sep 21, 2017

[FLINK-7571] [table] Fix translation of TableSource with time indicators.
fhueske
committedSep 21, 2017

Commits on Sep 5, 2017

[FLINK-7404] [table] Generate code for non-equi join conditions only.
fhueske
committedSep 5, 2017

Commits on Aug 23, 2017

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

fhueske
authored and
twalthr
committedAug 23, 2017

Commits on Aug 11, 2017

[hotfix] [docs] Improve TableSink documentation.
fhueske
committedAug 11, 2017

Commits on Aug 7, 2017

[FLINK-7221] [jdbc] Throw exception if execution of last JDBC batch fails.
fhueske
committedAug 7, 2017

Commits on Jul 21, 2017

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

fhueske
authored and
sunjincheng121
committedJul 21, 2017
[FLINK-6747] [docs] Add documentation for dynamic tables.

fhueske
authored and
sunjincheng121
committedJul 21, 2017

Commits on Jul 18, 2017

[hotfix] [hadoopCompat] Fix tests to verify results new Hadoop input API.
fhueske
committedJul 18, 2017

Commits on Jul 17, 2017

[FLINK-6232] [table] Add SQL documentation for time window join.
fhueske
committedJul 17, 2017

Commits on Jul 13, 2017

[FLINK-6693] [table] Support dateFormat() function in Scala Table API.
fhueske
committedJul 13, 2017

Commits on Jul 10, 2017

[FLINK-6747] [docs] Add documentation for QueryConfig.
fhueske
committedJul 10, 2017

Commits on Jun 20, 2017

[FLINK-6652] [core] Fix handling of delimiters split by buffers in DelimitedInputFormat
fhueske
committedJun 20, 2017

Commits on Jun 15, 2017

[FLINK-6746] [table] [docs] Updated Table API / SQL docs: Common API
fhueske
committedJun 15, 2017