Skip to content

SAMZA-2211: [Cleanup] Move RunLoop to container package#1046

Closed
mynameborat wants to merge 2 commits intoapache:masterfrom
mynameborat:move-run-loop
Closed

SAMZA-2211: [Cleanup] Move RunLoop to container package#1046
mynameborat wants to merge 2 commits intoapache:masterfrom
mynameborat:move-run-loop

Conversation

@mynameborat
Copy link
Copy Markdown
Contributor

@prateekm @xinyuiscool please take a look

Copy link
Copy Markdown
Contributor

@prateekm prateekm left a comment

Choose a reason for hiding this comment

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

Thanks for the cleanup. Minor comments.

Comment thread samza-core/src/main/java/org/apache/samza/container/RunLoop.java Outdated
}

void registerListener(TimerListener listener) {
public void registerListener(TimerListener listener) {
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

Should this class be in container instead of task as well?

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

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

I noticed we have a scheduler package and CallbackSchedulerImpl is the main consumer of this class.
Ended up moving it there. Let me know if you think we consolidate scheduler and container package.

Copy link
Copy Markdown
Contributor

@prateekm prateekm left a comment

Choose a reason for hiding this comment

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

Thanks for the cleanup.

@asfgit asfgit closed this in 21608cb May 28, 2019
@mynameborat mynameborat deleted the move-run-loop branch March 7, 2020 06:24
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants