gonzojive commented on PR #22057: URL: https://github.com/apache/beam/pull/22057#issuecomment-1182042840
What if this change was pulled in, but the function to override the default stream factory is unexported (lower cased) for now. This will make it easier for me to patch the package in my fork without a complicated diff that requires maintenance. On Thu, Jun 30, 2022 at 9:49 AM Robert Burke ***@***.***> wrote: > Really, what I'd want to tell you instead is to contribute to the Go > Direct runner to resolve this for local single machine runs, but I'm > working on a portability based replacement (in Go). > > Unfortunately it's not yet ready for migrating to the beam repo, and is > very test focused. > > Read: currently everything is in memory, no parallelism, and doesn't do > DoFn Graph fusion optimizations, each DoFn is executed one at a time. My > intent is to allow it to be much more configurable though, for robustness, > and be able to actuate all the various Beam FnAPI features. In this case, > have it be able to spill out to disk. > > — > Reply to this email directly, view it on GitHub > <https://github.com/apache/beam/pull/22057#issuecomment-1171455914>, or > unsubscribe > <https://github.com/notifications/unsubscribe-auth/AAAUO54PO7ST64SLJAM4W5TVRXFZVANCNFSM5Z2TT4DQ> > . > You are receiving this because you authored the thread.Message ID: > ***@***.***> > -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
