-
Notifications
You must be signed in to change notification settings - Fork 331
SAMZA-1880: Rename non-metrics classes which use Timer in their name #644
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
Conversation
|
@xinyuiscool @prateekm can you please take a look? |
|
@cameronlee314 Just looking at the names in the description, I'd prefer to not use
This way we're only introducing 2 new terms - schedule and callback, and both are fairly familiar concepts. |
|
Thanks for the suggestion @prateekm. I wasn't too fond of KeyScheduler either. The reason I did use that name was that when we consolidate TaskContext.scheduleCallback and TaskContext.deleteScheduledCallback into a TaskContext.something, I was thinking of using "Scheduler" for that. Now, I'm thinking that I could use something like SchedulerCallbackRegistry for that TaskContext case. |
|
@xinyuiscool @prateekm could you please take another look at this? |
prateekm
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks great, thanks for cleaning this up. Some documentation related suggestions.
samza-api/src/main/java/org/apache/samza/operators/functions/ScheduledFunction.java
Show resolved
Hide resolved
samza-api/src/main/java/org/apache/samza/operators/functions/ScheduledFunction.java
Outdated
Show resolved
Hide resolved
samza-api/src/main/java/org/apache/samza/operators/functions/ScheduledFunction.java
Outdated
Show resolved
Hide resolved
samza-core/src/main/java/org/apache/samza/task/AsyncRunLoop.java
Outdated
Show resolved
Hide resolved
samza-api/src/main/java/org/apache/samza/operators/Scheduler.java
Outdated
Show resolved
Hide resolved
samza-api/src/main/java/org/apache/samza/operators/Scheduler.java
Outdated
Show resolved
Hide resolved
samza-api/src/main/java/org/apache/samza/operators/Scheduler.java
Outdated
Show resolved
Hide resolved
cameronlee314
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for the doc suggestions. I like them much better than what I came up with.
samza-api/src/main/java/org/apache/samza/operators/functions/ScheduledFunction.java
Outdated
Show resolved
Hide resolved
samza-core/src/main/java/org/apache/samza/task/AsyncRunLoop.java
Outdated
Show resolved
Hide resolved
|
@prateekm @xinyuiscool could you please take another look? |
prateekm
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks!
Summary of API changes:
Only terminology changes are intended (e.g. classes, var names, logs). No functionality change is intended.
An upcoming PR will further update TaskContext and the access to the scheduling logic.