Skip to content

Conversation

lizhou1111
Copy link
Contributor

@lizhou1111 lizhou1111 commented May 9, 2024

Aggregatefunction any, any_last support changelog.

drop stream if exists test2;
create stream if not exists test2(id int, value string) primary key id settings mode = 'changelog_kv';
select first_value(value) from test2;

Output:

┌─last_value(value)─┐
│                 2 │
└───────────────────┘
┌─last_value(value)─┐
│                 3 │
└───────────────────┘
┌─last_value(value)─┐
│                 1 │
└───────────────────┘
┌─last_value(value)─┐
│                 1 │
└───────────────────┘
┌─last_value(value)─┐
│                 1 │
└───────────────────┘

No retraction operation, we just ignore the data with -1 _tp_delta value, it will implement later.
replate to #678

@lizhou1111 lizhou1111 self-assigned this May 9, 2024
@lizhou1111 lizhou1111 requested a review from yl-lisen May 9, 2024 05:07
@lizhou1111 lizhou1111 added the enhancement New feature or request label May 9, 2024
@Jasmine-ge Jasmine-ge assigned Jasmine-ge and unassigned lizhou1111 Aug 13, 2024
@Jasmine-ge Jasmine-ge force-pushed the feature/issue-678-latest-function-support-changelog branch from 35974fd to 48ab1ef Compare November 1, 2024 08:59
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants