{"push_id":2193664837,"size":13,"distinct_size":13,"ref":"refs/heads/remote_stage_executor-backup","head":"cd9af45077914da20aa6cfba0e3bca7a25016fad","before":"311bba4c75627dc32de9d82ac38abf70585655f3","commits":[{"sha":"7fb8f7b6b3280ff991bd90e39006e72e4126697e","author":{"name":"Eugene Kirpichov","email":"894747bb4c3458838d5b868e800da2320dcadb48@google.com"},"message":"Replaces BoundedSource with a composite transform when using Fn API","distinct":true,"url":"https://api.github.com/repos/tgroh/beam/commits/7fb8f7b6b3280ff991bd90e39006e72e4126697e"},{"sha":"60dd7c4035a8d320b01823cbd4c959d0ef09cf26","author":{"name":"Robert Bradshaw","email":"bfaa95ed6c8132cec2402027b8b83267a0660b8d@gmail.com"},"message":"Minor changes to the FnApi Runner to allow Java to run. (#4220)\n\n* Minor changes to the FnApi Runner to allow Java to run.\r\n\r\n* Aligned the GBK urn.\r\n* Started a logging service, which Java can't run without.\r\n* Added some logging that was helpful for debugging.","distinct":true,"url":"https://api.github.com/repos/tgroh/beam/commits/60dd7c4035a8d320b01823cbd4c959d0ef09cf26"},{"sha":"a6469f054a51f4b9e07080dbff1b334d67cdc3e4","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Add RemoteGrpcPort[Read/Write] abstractions\n\nThese are utility classes to create portability-layer PTransforms which\nrepresent an execution-time port read or write.\n\nUse the classes in FnDataReadRunner and WriteRunner.","distinct":true,"url":"https://api.github.com/repos/tgroh/beam/commits/a6469f054a51f4b9e07080dbff1b334d67cdc3e4"},{"sha":"737893829d64b824fa23aafbb416d5162d364efd","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Add a ReferenceRunner class\n\nThis runs a Pipeline via the Portability Framework.\n\nThis runner is not yet implemented. This change exists to construct the\nappropriate module.","distinct":true,"url":"https://api.github.com/repos/tgroh/beam/commits/737893829d64b824fa23aafbb416d5162d364efd"},{"sha":"6cfe6b74a05b6799d11f324b1fd7b1c034130424","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Implement JobService#run in the ReferenceRunner","distinct":true,"url":"https://api.github.com/repos/tgroh/beam/commits/6cfe6b74a05b6799d11f324b1fd7b1c034130424"},{"sha":"d72ef12fdde7bfb9bfa9db6c687c592f56a179c2","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Start Servers only in a ServerFactory","distinct":true,"url":"https://api.github.com/repos/tgroh/beam/commits/d72ef12fdde7bfb9bfa9db6c687c592f56a179c2"},{"sha":"88e15874e18099389945b15098a4738ddde665e9","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Move BeamFnDataGrpcMultiplexer to java-fn-execution\n\nThis can be used by both ends of the Data Service.","distinct":true,"url":"https://api.github.com/repos/tgroh/beam/commits/88e15874e18099389945b15098a4738ddde665e9"},{"sha":"d7fa35d9cfeac76f16ab3348775388476100c960","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Remove ApiServiceDescriptor from DataGrpcMultiplexer\n\nIt's not necessarily available, and is only debugging information.","distinct":true,"url":"https://api.github.com/repos/tgroh/beam/commits/d7fa35d9cfeac76f16ab3348775388476100c960"},{"sha":"c601fca5e750cb4516de1cad937742cec6584e12","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Use FnDataReceiver in the SDK Harness\n\nThis brings additional symmetry to the data client and server.\n\nIntroduce MultiplexingFnDataReceiver to hide the use of non-closeable\nconsumers within the SDK Harness.","distinct":true,"url":"https://api.github.com/repos/tgroh/beam/commits/c601fca5e750cb4516de1cad937742cec6584e12"},{"sha":"4964a6aef2cd56626e3dd159451ce94b52e0f5bb","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Add InboundDataClient\n\nThis replaces CompletableFuture<Void> (or any type of Void future) for\nuse of an active stream that can be completed or cancelled by both\nends.","distinct":true,"url":"https://api.github.com/repos/tgroh/beam/commits/4964a6aef2cd56626e3dd159451ce94b52e0f5bb"},{"sha":"c2eab7fcde6d820fc09768551929b7d219406a9d","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Move BeamFnDataInboundObserver to java-fn-execution\n\nThis is used on both the client and the server","distinct":true,"url":"https://api.github.com/repos/tgroh/beam/commits/c2eab7fcde6d820fc09768551929b7d219406a9d"},{"sha":"5f28dac696038f12a7dd9a48e56388975346ca01","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Add an implementation of the Fn API Data Service","distinct":true,"url":"https://api.github.com/repos/tgroh/beam/commits/5f28dac696038f12a7dd9a48e56388975346ca01"},{"sha":"cd9af45077914da20aa6cfba0e3bca7a25016fad","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"WIP: Remote Stage Execution","distinct":true,"url":"https://api.github.com/repos/tgroh/beam/commits/cd9af45077914da20aa6cfba0e3bca7a25016fad"}]}
{"actor":{"display_login":"tgroh"}}