{"push_id":1428678983,"size":43,"distinct_size":24,"ref":"refs/heads/BEAM-606-MQTTIO","head":"72aa059d9de4dd390591ec2ee31caa8356fa2020","before":"2659835fa92fefad1bf401e554d267986ee84b8c","commits":[{"sha":"1b7b065f4ccae7c52934b1e73fd1fbfb33c3398d","author":{"name":"Kenneth Knowles","email":"7ee59cbbb0cfc706bc0a9605e2d68fae3354c025@google.com"},"message":"Remove overspecified type in ParDoEvaluator","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/1b7b065f4ccae7c52934b1e73fd1fbfb33c3398d"},{"sha":"e17dc4af9f7de717872d6c6f0ab52e0498f3b782","author":{"name":"Kenneth Knowles","email":"7ee59cbbb0cfc706bc0a9605e2d68fae3354c025@google.com"},"message":"Add State parameter support to SimpleDoFnRunner","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/e17dc4af9f7de717872d6c6f0ab52e0498f3b782"},{"sha":"7e158e4e583372dd79ffaa380ac7c2dbb4846c50","author":{"name":"Kenneth Knowles","email":"7ee59cbbb0cfc706bc0a9605e2d68fae3354c025@google.com"},"message":"Add simple tests for stateful ParDo","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/7e158e4e583372dd79ffaa380ac7c2dbb4846c50"},{"sha":"ec2c0e0698c1380b309a609eb642aba445c77e27","author":{"name":"Kenneth Knowles","email":"7ee59cbbb0cfc706bc0a9605e2d68fae3354c025@google.com"},"message":"Add support for Stateful ParDo in the Direct runner\n\nThis adds overrides and new evaluators to ensure that\nstate is accessed in a single-threaded manner per key\nand is cleaned up when a window expires.","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/ec2c0e0698c1380b309a609eb642aba445c77e27"},{"sha":"33c687069adc1ce4481a0c9637b2a77abb9450b8","author":{"name":"Kenneth Knowles","email":"7ee59cbbb0cfc706bc0a9605e2d68fae3354c025@google.com"},"message":"This closes #1399","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/33c687069adc1ce4481a0c9637b2a77abb9450b8"},{"sha":"14502a3122bd1c1652196881797ffb60d480164e","author":{"name":"Scott Wegner","email":"33f9eae64f7ae31295cdf43ca21ada514ccfbd0e@google.com"},"message":"Add direct runner dependency to starter archetype","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/14502a3122bd1c1652196881797ffb60d480164e"},{"sha":"d5aeee9c17a75307ff539e40b3ddc176790ec559","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"This closes #1414","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/d5aeee9c17a75307ff539e40b3ddc176790ec559"},{"sha":"fff577610d929e713d42bfb2a4e8428727ee7206","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"Ignore UsesStatefulParDo Tests in Flink Streaming Runner","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/fff577610d929e713d42bfb2a4e8428727ee7206"},{"sha":"060928257e809d96fea497c831309040da6fd7c8","author":{"name":"Kenneth Knowles","email":"7ee59cbbb0cfc706bc0a9605e2d68fae3354c025@google.com"},"message":"This closes #1446","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/060928257e809d96fea497c831309040da6fd7c8"},{"sha":"fcd09915fac49f66f6a65f234b34dc34f16fef18","author":{"name":"Pei He","email":"17c994c0b8f5c9ef72564c0b717afcb0ddc06269@google.com"},"message":"[BEAM-1009] Upgrade byte-buddy version to 1.5.5.","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/fcd09915fac49f66f6a65f234b34dc34f16fef18"},{"sha":"4bcef03d99e550edf888c1a0b32572f7943cdb2b","author":{"name":"Kenneth Knowles","email":"7ee59cbbb0cfc706bc0a9605e2d68fae3354c025@google.com"},"message":"This closes #1445","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/4bcef03d99e550edf888c1a0b32572f7943cdb2b"},{"sha":"0ae181248823b08803a8f8ac0d39a35a190c4acd","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Remove the Experimental Annotation from the DirectRunner","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/0ae181248823b08803a8f8ac0d39a35a190c4acd"},{"sha":"cdb7ba165fb29d7e870ff959fd7bd00416c863bb","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"This closes #1447","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/cdb7ba165fb29d7e870ff959fd7bd00416c863bb"},{"sha":"ee52318f2512c6661823e4f546f84dbc2caa955b","author":{"name":"sammcveety","email":"2608cff8576a1066ab6c2c6f7e196cc3c00d2c96@gmail.com"},"message":"Add method to output runtime options","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/ee52318f2512c6661823e4f546f84dbc2caa955b"},{"sha":"ae06f759fbf72fa31e02dc943ab46afe03471904","author":{"name":"Dan Halperin","email":"0291491adc84a7497e89df29893a36b10448bbd8@google.com"},"message":"Closes #1156","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/ae06f759fbf72fa31e02dc943ab46afe03471904"},{"sha":"f92259814964fb4d3b2381187247b3f11b5fe33f","author":{"name":"Sam McVeety","email":"242d937dc6833da7ce6add083fdb7c705f1f7bd2@google.com"},"message":"Demonstrate PubsubIO with NVP","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/f92259814964fb4d3b2381187247b3f11b5fe33f"},{"sha":"aeff1d5c219385cce20a275a4e47d9184f5cf59c","author":{"name":"Dan Halperin","email":"0291491adc84a7497e89df29893a36b10448bbd8@google.com"},"message":"Closes #1230","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/aeff1d5c219385cce20a275a4e47d9184f5cf59c"},{"sha":"b453457f5699963f9a72129ab86ef18b71c04e61","author":{"name":"DavidB","email":"f97ad9e1b2a04ab848075d15828abb6eae0806cb@gandlake.com"},"message":"[BEAM-1006] Fixing the MongoDbIO splitKeysToFilters, calling to string on the BSON document prefixed Document to the string, updated it to just get the value of ID","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/b453457f5699963f9a72129ab86ef18b71c04e61"},{"sha":"3f16f26600ac6e552f379c94cfae1bc57ed5f5f0","author":{"name":"Jean-Baptiste Onofré","email":"15f971fe3505ad4c5b59d5f7e374a55a4f1e4fe8@apache.org"},"message":"[BEAM-1006] This closes #1387","distinct":false,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/3f16f26600ac6e552f379c94cfae1bc57ed5f5f0"},{"sha":"a1a4ac0fc0376aa4c43a4357f3acc930e2b53c94","author":{"name":"Aviem Zur","email":"a5ae0c423dace0b7be6f4f23e84e14e2484eb117@gmail.com"},"message":"[BEAM-1052] Add InputDStream id to MicrobatchSource hashcode.\n\nDone to avoid collisions between splits of different sources.","distinct":true,"url":"https://api.github.com/repos/jbonofre/incubator-beam/commits/a1a4ac0fc0376aa4c43a4357f3acc930e2b53c94"}]}
{"actor":{"display_login":"jbonofre"}}