Skip to content

[BEAM-1037] Support for new State API in ApexRunner#3893

Merged
asfgit merged 1 commit intoapache:masterfrom
tweise:BEAM-1037.ApexStatefulProcessing
Sep 30, 2017
Merged

[BEAM-1037] Support for new State API in ApexRunner#3893
asfgit merged 1 commit intoapache:masterfrom
tweise:BEAM-1037.ApexStatefulProcessing

Conversation

@tweise
Copy link
Copy Markdown
Contributor

@tweise tweise commented Sep 24, 2017

Follow this checklist to help us incorporate your contribution quickly and easily:

  • Make sure there is a JIRA issue filed for the change (usually before you start working on it). Trivial changes like typos do not require a JIRA issue. Your pull request should address just this issue, without pulling in other changes.
  • Each commit in the pull request should have a meaningful subject line and body.
  • Format the pull request title like [BEAM-XXX] Fixes bug in ApproximateQuantiles, where you replace BEAM-XXX with the appropriate JIRA issue.
  • Write a pull request description that is detailed enough to understand what the pull request does, how, and why.
  • Run mvn clean verify to make sure basic checks pass. A more thorough check will be performed on your pull request automatically.
  • If this contribution is large, please file an Apache Individual Contributor License Agreement.

R: @kennknowles

@tweise tweise force-pushed the BEAM-1037.ApexStatefulProcessing branch from 0dd01bd to ee39202 Compare September 24, 2017 03:51
@coveralls
Copy link
Copy Markdown

Coverage Status

Coverage decreased (-0.02%) to 69.522% when pulling ee39202 on tweise:BEAM-1037.ApexStatefulProcessing into aa2604a on apache:master.

@kennknowles
Copy link
Copy Markdown
Member

run Apex ValidatesRunner

Copy link
Copy Markdown
Member

@kennknowles kennknowles left a comment

Choose a reason for hiding this comment

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

Simple and good. I kicked off the tests.

stateBackend.newStateInternalsFactory(keyCoder));
} else {
DoFnSignature signature = DoFnSignatures.getSignature(doFn.getClass());
if (signature.stateDeclarations().size() > 0) {
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

In review, someone suggested I add signature.usesState() to encapsulate this check. You could use it or not, I don't care so much.

@tweise tweise force-pushed the BEAM-1037.ApexStatefulProcessing branch from ee39202 to 575e36e Compare September 30, 2017 15:29
@asfgit asfgit merged commit 575e36e into apache:master Sep 30, 2017
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.

4 participants