{"push_id":1125069153,"size":32,"distinct_size":3,"ref":"refs/heads/BEAM-287-GROUPID","head":"c51bdbb048246ddad866489203e40c49d2ef5e72","before":"3188587ec6dc41bd778ad9abd56d3b837f627c0c","commits":[{"sha":"ca1b3a87fbe7218c0af912ba0f0deae8b903b1ac","author":{"email":"0ddbec4b5c187190eb270b45cab9a5c5e5367b49@google.com","name":"Kenneth Knowles"},"message":"Add accessors for sub-coders of KeyedWorkItemCoder","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/ca1b3a87fbe7218c0af912ba0f0deae8b903b1ac"},{"sha":"aad284a513e829552e9ae7fa10ea89cfd89bdb5f","author":{"email":"0ddbec4b5c187190eb270b45cab9a5c5e5367b49@google.com","name":"Kenneth Knowles"},"message":"Make in-process GroupByKey respect future Beam model\n\nThis introduces or clarifies the following transforms:\n\n - InProcessGroupByKey, which expands like GroupByKeyViaGroupByKeyOnly\n   but with different intermediate PCollection types.\n - InProcessGroupByKeyOnly, which outputs KeyedWorkItem<K, V>. This existed\n   already under a different name.\n - InProcessGroupAlsoByWindow, which is evaluated directly and\n   accepts input elements of type KeyedWorkItem<K, V>.","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/aad284a513e829552e9ae7fa10ea89cfd89bdb5f"},{"sha":"ebe69cf284e8b6a3c24d833d1eed2abec83500bf","author":{"email":"d28e9909363a9c1600e80ac000976ccd4e3d0121@google.com","name":"Thomas Groh"},"message":"Add DefaultPipelineOptionsRegistrar\n\nThis registers all of the PipelineOptions classes in the SDK.\n\nThis ensures that SDK options are registered regardless of the class\nhierarchy of registered runner options.","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/ebe69cf284e8b6a3c24d833d1eed2abec83500bf"},{"sha":"2f18cd2687a4dad0510bb29cd62c9dd2323ee70b","author":{"email":"0ddbec4b5c187190eb270b45cab9a5c5e5367b49@google.com","name":"Kenneth Knowles"},"message":"This closes #268","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/2f18cd2687a4dad0510bb29cd62c9dd2323ee70b"},{"sha":"662e493515e43b26eab9d2d44b3b01487b31a2f4","author":{"email":"0ddbec4b5c187190eb270b45cab9a5c5e5367b49@google.com","name":"Kenneth Knowles"},"message":"This closes #350","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/662e493515e43b26eab9d2d44b3b01487b31a2f4"},{"sha":"26941f152cb5bed422ff14ccb10403604a611130","author":{"email":"dc8d2fa7e38f1acfa9a4c53533749792f6efad75@google.com","name":"Mark Shields"},"message":"PubsubIO: integrate the new PubsubUnboundedSource and Sink","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/26941f152cb5bed422ff14ccb10403604a611130"},{"sha":"d0b9ca910efb5f8d2e2feb43ef586f8364b9541d","author":{"email":"1a02732a15f637c31107256cbee5819e36aa7c67@google.com","name":"Dan Halperin"},"message":"Closes #346","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/d0b9ca910efb5f8d2e2feb43ef586f8364b9541d"},{"sha":"6c10a1d73981ea6cac8b557f492c3682e9035d4d","author":{"email":"1a02732a15f637c31107256cbee5819e36aa7c67@google.com","name":"Dan Halperin"},"message":"DisplayData: a few build fixups","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/6c10a1d73981ea6cac8b557f492c3682e9035d4d"},{"sha":"402fb70c41533d8df7164f0de6106fc63cf17355","author":{"email":"1a02732a15f637c31107256cbee5819e36aa7c67@google.com","name":"Dan Halperin"},"message":"Closes #360","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/402fb70c41533d8df7164f0de6106fc63cf17355"},{"sha":"dc98211ccf17e94afb03ba51992c731684f855fa","author":{"email":"d28e9909363a9c1600e80ac000976ccd4e3d0121@google.com","name":"Thomas Groh"},"message":"Add CrashingRunner for use in TestPipeline\n\nCrashingRunner is a PipelineRunner that crashes on calls to run() with\nan IllegalArgumentException. As a runner is currently required to\nconstruct a Pipeline object, this allows removal of all Pipeline Runners\nfrom the core SDK while retaining tests that depend only on the graph\nconstruction behavior.","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/dc98211ccf17e94afb03ba51992c731684f855fa"},{"sha":"58d66a344985eecc9cc3f43c0ecd5dbc7b4fb2e6","author":{"email":"0ddbec4b5c187190eb270b45cab9a5c5e5367b49@google.com","name":"Kenneth Knowles"},"message":"Add TestFlinkPipelineRunner to FlinkRunnerRegistrar\n\nThis makes the runner available for selection by integration tests.","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/58d66a344985eecc9cc3f43c0ecd5dbc7b4fb2e6"},{"sha":"bfc1a2ba041c1b8b0033f886266321e5ee53cf6c","author":{"email":"0ddbec4b5c187190eb270b45cab9a5c5e5367b49@google.com","name":"Kenneth Knowles"},"message":"Configure RunnableOnService tests for Flink in batch mode\n\nToday Flink batch supports only global windows. This is a situation we\nintend our build to allow, eventually via JUnit category filtering.\n\nFor now all the test classes that use non-global windows are excluded\nentirely via maven configuration. In the future, it should be on a\nper-test-method basis.","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/bfc1a2ba041c1b8b0033f886266321e5ee53cf6c"},{"sha":"55f39bf7cbe65980ed4233146517d608977ddaf6","author":{"email":"0ddbec4b5c187190eb270b45cab9a5c5e5367b49@google.com","name":"Kenneth Knowles"},"message":"Remove unused threadCount from integration tests","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/55f39bf7cbe65980ed4233146517d608977ddaf6"},{"sha":"2d71af71c26992c0ccbf2ab6df8f2a0aef5e586b","author":{"email":"0ddbec4b5c187190eb270b45cab9a5c5e5367b49@google.com","name":"Kenneth Knowles"},"message":"Disable Flink streaming integration tests for now","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/2d71af71c26992c0ccbf2ab6df8f2a0aef5e586b"},{"sha":"af8e98878bbc8678e33a4c00548ccabf6cf55a17","author":{"email":"0ddbec4b5c187190eb270b45cab9a5c5e5367b49@google.com","name":"Kenneth Knowles"},"message":"Special casing job exec AssertionError in TestFlinkPipelineRunner","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/af8e98878bbc8678e33a4c00548ccabf6cf55a17"},{"sha":"1664c96db5951d74b5ab9a5850def1dbef8adea6","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"Add hamcrest dependency to Flink Runner\n\nWithout it the RunnableOnService tests seem to not work","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/1664c96db5951d74b5ab9a5850def1dbef8adea6"},{"sha":"26fa0b21cfda3049e26d47ce174a9b29fe3ec29c","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"Fix Dangling Flink DataSets","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/26fa0b21cfda3049e26d47ce174a9b29fe3ec29c"},{"sha":"4e60a497b313414aa2b2968b8def6c6f753908fe","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"Fix faulty Flink Flatten when PCollectionList is empty","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/4e60a497b313414aa2b2968b8def6c6f753908fe"},{"sha":"24bfca230d5db3cb75dd0e30093a10f7523c1238","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[BEAM-270] Support Timestamps/Windows in Flink Batch\n\nWith this change we always use WindowedValue<T> for the underlying Flink\nDataSets instead of just T. This allows us to support windowing as well.\n\nThis changes also a lot of other stuff enabled by the above:\n\n - Use WindowedValue throughout\n - Add proper translation for Window.into()\n - Make side inputs window aware\n - Make GroupByKey and Combine transformations window aware, this\n   includes support for merging windows. GroupByKey is implemented as a\n   Combine with a concatenating CombineFn, for simplicity\n\nThis removes Flink specific transformations for things that are handled\nby builtin sources/sinks, among other things this:\n\n - Removes special translation for AvroIO.Read/Write and\n   TextIO.Read/Write\n - Removes special support for Write.Bound, this was not working properly\n   and is now handled by the Beam machinery that uses DoFns for this\n - Removes special translation for binary Co-Group, the code was still\n   in there but was never used\n - Removes ConsoleIO, this can be done using a DoFn\n\nWith this change all RunnableOnService tests run on Flink Batch.","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/24bfca230d5db3cb75dd0e30093a10f7523c1238"},{"sha":"23ba976403b308103ea8b7dd0505e5847dd44952","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"Add surefire plugin to java 8 example tests\n\nWithout this the test will just pick up whathever was last written to\nbeamTestPipelineOptions.","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/23ba976403b308103ea8b7dd0505e5847dd44952"}]}
{"actor":{"display_login":"jbonofre"}}