Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[HZ-707] HOP window function support #20342

Merged
merged 57 commits into from
Jan 27, 2022

Conversation

Fly-Style
Copy link
Member

@Fly-Style Fly-Style commented Jan 11, 2022

Checklist:

  • Labels (Team:, Type:, Source:, Module:) and Milestone set
  • Label Add to Release Notes or Not Release Notes content set
  • Request reviewers if possible

Also, fixes #19943

@Fly-Style Fly-Style added this to the 5.1 milestone Jan 11, 2022
@Fly-Style Fly-Style self-assigned this Jan 11, 2022
@mmedenjak mmedenjak added Source: Internal PR or issue was opened by an employee Team: SQL Type: Enhancement labels Jan 11, 2022
@hazelcast hazelcast deleted a comment from hz-devops-test Jan 15, 2022
@hazelcast hazelcast deleted a comment from hz-devops-test Jan 17, 2022
@Fly-Style Fly-Style marked this pull request as ready for review January 18, 2022 08:26
@hazelcast hazelcast deleted a comment from hz-devops-test Jan 18, 2022
@Fly-Style Fly-Style linked an issue Jan 20, 2022 that may be closed by this pull request
@@ -42,7 +42,7 @@
};

public ImposeOrderFunction() {
super("IMPOSE_ORDER", new WindowOperandMetadata(PARAMETERS), RETURN_TYPE_INFERENCE);
super("IMPOSE_ORDER", new WindowOperandMetadata(PARAMETERS, new int[]{2}), RETURN_TYPE_INFERENCE);
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Think the new int[]{2} bit needs a comment with explanation. Or better yet a constant.

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The argument taking this value is documented...

@Override
public Void visitInputRef(RexInputRef inputRef) {
if (arrayIndexOf(inputRef.getIndex(), indexes) >= 0) {
res[0] = true;
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Any reason this has to be an array? Just checking.

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@ivanthescientist outer variable should be effective final to be accessible within the anonymous class/lambda context

@Fly-Style Fly-Style merged commit f49305d into hazelcast:master Jan 27, 2022
@Fly-Style Fly-Style deleted the vilo-hop-aggregation branch January 27, 2022 08:10
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Reorder HOP function arguments com.hazelcast.jet.sql.impl.connector.kafka.SqlKafkaAggregateTest.test
4 participants