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

[BEAM-9320] Add AlwaysFetched annotation #10862

Merged
merged 4 commits into from
Feb 16, 2020

Conversation

reuvenlax
Copy link
Contributor

No description provided.

@reuvenlax reuvenlax changed the title Add AlwaysFetched annotation [BEAM-9320] Add AlwaysFetched annotation Feb 14, 2020
@reuvenlax
Copy link
Contributor Author

R: @dpmills

* choose to defer fetching state until read() is called. Annotating a state argument with this
* parameter provides a hint to the runner that the state is always fetched. This may cause the
* runner to prefetch all the state before calling the processElement or processTimer method,
* improving performance. See the following code for an example:
Copy link
Contributor

Choose a reason for hiding this comment

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

Add a comment that the annotation only works for ReadableState

Copy link
Contributor Author

Choose a reason for hiding this comment

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

done

@reuvenlax
Copy link
Contributor Author

run dataflow validatesrunner

@reuvenlax
Copy link
Contributor Author

run flink validatesrunner

@reuvenlax
Copy link
Contributor Author

Run Java PreCommit

@reuvenlax
Copy link
Contributor Author

Run Java_Examples_Dataflow PreCommit

@reuvenlax
Copy link
Contributor Author

Run Java PreCommit

@reuvenlax
Copy link
Contributor Author

run dataflow validatesrunner

@reuvenlax
Copy link
Contributor Author

run flink validatesrunner

@reuvenlax
Copy link
Contributor Author

Run Java PreCommit

@reuvenlax reuvenlax merged commit 52fea0e into apache:master Feb 16, 2020
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.

None yet

2 participants