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

minor refactoring in MicroBatches class to prep for Spark3 streaming change #2620

Merged
merged 2 commits into from
May 24, 2021

Conversation

SreeramGarlapati
Copy link
Collaborator

  1. StreamingOffset stores file index as long - so changing MicroBatches.startFileIndex from int to long.
  2. renaming MicroBatches.isStarting to MicroBatches.scanAllFiles - as isStarting is when it is used, in terms of the callers state - whereas, scanAllFiles is the actual what MicroBatches.generate should do.

this is part of effort #2611 & is copied from #2272.

@github-actions github-actions bot added the core label May 21, 2021
@rdsr
Copy link
Contributor

rdsr commented May 21, 2021

Generally looks to me, but do we know why we are not checking this in as part of #2272 ?

@SreeramGarlapati
Copy link
Collaborator Author

Generally looks to me, but do we know why we are not checking this in as part of #2272 ?

@rdsr - #2272 is spark2. Its a matter of time @XuQianJin-Stars - resolves the comments and pushes it. I am trying to push spark3 connector - for SalesForce needs & needing this change.

@RussellSpitzer
Copy link
Member

I'm ok with merging this in, but let's try to wrap future patches in more logical and testable chunks.

@SreeramGarlapati
Copy link
Collaborator Author

SreeramGarlapati commented May 21, 2021

I'm ok with merging this in, but let's try to wrap future patches in more logical and testable chunks.

ack. - will keep this in mind @RussellSpitzer.

@RussellSpitzer RussellSpitzer merged commit e8b3d1e into apache:master May 24, 2021
@RussellSpitzer
Copy link
Member

Thanks @SreeramGarlapati for making progress here, but like I mentioned please try to make changes a bit more grouped in the future and testable :)

@SreeramGarlapati SreeramGarlapati deleted the refactor.microbatches branch May 24, 2021 20:53
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants