Commits

History for

Commits on Jan 31, 2019

[FLINK-11064] [table] Setup a new flink-table module structure
twalthr
committedJan 31, 2019

Commits on Jan 30, 2019

[FLINK-11328][core] Migrate NFAStateSerializer to new TypeSerializer interface

dawidwys
authored and
tzulitai
committedJan 30, 2019
[hotfix][cep] Split NFAStateSerializer methods into smaller ones.

dawidwys
authored and
tzulitai
committedJan 30, 2019
[hotfix][cep] Close nfa in CepOperator only if not null

dawidwys
authored and
tzulitai
committedJan 30, 2019
[FLINK-11296][table] Support truncate in TableAPI and SQL

XuQianJin-Stars
authored and
wuchong
committedJan 30, 2019

Commits on Jan 27, 2019

[FLINK-11329][core] Migrate CRowSerializerConfigSnapshot to new TypeSerializerSnapshot interface
dawidwys
committedJan 27, 2019

Commits on Jan 23, 2019

Commits on Jan 22, 2019

[FLINK-11328] [core] Upgrade parameterless / singleton serializers to use new serialization compatibility APIs
tzulitai
committedJan 22, 2019

Commits on Jan 18, 2019

[FLINK-8739] [table] Optimize DISTINCE aggregates to use the same distinct accumulator if possible

dianfu
authored and
sunjincheng121
committedJan 18, 2019
[FLINK-10591][table] Introduced functions to return time attributes from MATCH_RECOGNIZE

dawidwys
authored and
pnowojski
committedJan 18, 2019
[hotfix][table] Switched from PatternSelectFunction to PatternProcessFunction

dawidwys
authored and
pnowojski
committedJan 18, 2019
[hotfix][table] Converted static generateIterativeCondition & generateOneRowPerMatchExpression methods into inner methods

dawidwys
authored and
pnowojski
committedJan 18, 2019

Commits on Jan 17, 2019

Commits on Jan 9, 2019

[FLINK-10583][table] Add State Retention support to TemporalProcessTimeJoin.
kl0u
committedJan 9, 2019
[FLINK-10584][table] Add State Retention support to TemporalRowtimeJoin.
kl0u
committedJan 9, 2019
[hotfix] Avoid redundant state access in TemporalProcessTimeJoin.
kl0u
committedJan 9, 2019
[FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator.
kl0u
committedJan 9, 2019
[FLINK-11262][py] Bump jython-standalone to 2.7.1

Fokko
authored and
zentol
committedJan 9, 2019
[FLINK-11197][tests] Improve migration test comments about how to generate snapshots

hequn8128
authored and
zentol
committedJan 9, 2019
[hotfix][cep] Renamed TimerContext to TimeContext
dawidwys
committedJan 9, 2019
[FLINK-10596][cep] Added access to timer service in IterativeCondition
dawidwys
committedJan 9, 2019
[hotfix][cep] Introduced nfa test harness
dawidwys
committedJan 9, 2019
[hotfix][cep] Change contract of cep TimerContext#timestamp to never
dawidwys
committedJan 9, 2019

Commits on Jan 8, 2019

Commits on Jan 7, 2019

[FLINK-10845] [table] Support multiple different DISTINCT aggregates for batch

xueyumusic
authored and
twalthr
committedJan 7, 2019

Commits on Jan 4, 2019

[FLINK-11124][table] Add private[flink] to TemporalTableFunction.create()

hequn8128
authored and
twalthr
committedJan 4, 2019