{"push_id":2570176270,"size":505,"distinct_size":28,"ref":"refs/heads/master","head":"1e698901336b3499ad48d1bd2110963e45f364b7","before":"caf058f3e8994311e4f8a095800b031008f95e3d","commits":[{"sha":"111a93deaa3986cb532cfb1302dcc31315bbfbf1","author":{"name":"Robert Bradshaw","email":"8b939cc4a6c1d13aba31f94ae778989545ac3d9a@gmail.com"},"message":"Augment Python SDK worker to handle unwindowed coders.","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/111a93deaa3986cb532cfb1302dcc31315bbfbf1"},{"sha":"7dbcb11ff1cb9f2b5f0ffdb63bb38b686fdb0c71","author":{"name":"arkash","email":"f28705d047949586fe00e552187019f77b4ac8a4@users.noreply.github.com"},"message":"BEAM-3246 Merge splits if they exceed 15K\n    -- added checks to validate key ranges are adjacent before merging\n    -- added logic to merge adjacent splits else continue without merge\n    -- simplified merge code and loops\n    -- updated test case to verify that split sources have single adjacent ranges\n    -- Updated reduceSplits to enable easier testing\n    -- Added additional test cases to verify partial adjacent, non adjacent and all adjacent source ranges\n    -- Removed usage of tablerange from the test cases","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/7dbcb11ff1cb9f2b5f0ffdb63bb38b686fdb0c71"},{"sha":"062fa48ebc579c8d04a50f085c00ac28daa36d26","author":{"name":"Geet Kumar","email":"b406fab2b303150a7714d55727bdc32a8778ed89@gmail.com"},"message":"BEAM-4038: Support Kafka Headers in KafkaIO","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/062fa48ebc579c8d04a50f085c00ac28daa36d26"},{"sha":"d03e1f481b28335ed6925887c500f1df8e3c72d5","author":{"name":"Geet Kumar","email":"b406fab2b303150a7714d55727bdc32a8778ed89@gmail.com"},"message":"BEAM-4038: Update license information","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/d03e1f481b28335ed6925887c500f1df8e3c72d5"},{"sha":"a8023159d663257ded50eda026fb15563d29e466","author":{"name":"Geet Kumar","email":"f9d3a90407ac4c956ac211f7396fa1377da55a66@users.noreply.github.com"},"message":"Merge branch 'master' into kafka-header-support","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/a8023159d663257ded50eda026fb15563d29e466"},{"sha":"c93bcda2deaaf8b4f5d015aea600489143ba7198","author":{"name":"Geet Kumar","email":"b406fab2b303150a7714d55727bdc32a8778ed89@gmail.com"},"message":"Update code formatting","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/c93bcda2deaaf8b4f5d015aea600489143ba7198"},{"sha":"01f4ebb82e31ba2931d9af38c11c59de16c8a5ff","author":{"name":"Geet Kumar","email":"b406fab2b303150a7714d55727bdc32a8778ed89@gmail.com"},"message":"Remove custom implementations of KafkaHeader, KafkaHeaders, etc.","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/01f4ebb82e31ba2931d9af38c11c59de16c8a5ff"},{"sha":"74d68673a4c750affb6356552954cdebe39ff399","author":{"name":"Axel Magnuson","email":"9b388ea33f36232d63ae34dcf0c676a46626277e@gmail.com"},"message":"Create ArtifactSource Interface\n\nCluster engine runners will need to provide artifacts\nto a longer lived artifact service for the duration of\ntheir lifetime.  To accomplish this they will register\nan ArtifactSource with a harness manager.","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/74d68673a4c750affb6356552954cdebe39ff399"},{"sha":"c34faa5212f35d9ed5de6ba281b8f81ae3e85227","author":{"name":"Geet Kumar","email":"b406fab2b303150a7714d55727bdc32a8778ed89@gmail.com"},"message":"Changes based on review comments","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/c34faa5212f35d9ed5de6ba281b8f81ae3e85227"},{"sha":"bf144c14640d04cdb3590e7d545833589941291c","author":{"name":"Braden Bassingthwaite","email":"b5ea5503c0a559be5614ddd22a4b276e342e4b4e@vendasta.com"},"message":"Adding a go datastore io reader","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/bf144c14640d04cdb3590e7d545833589941291c"},{"sha":"79480145a4a56056b36636e2fb1e45039400fe10","author":{"name":"Thomas Groh","email":"d28e9909363a9c1600e80ac000976ccd4e3d0121@google.com"},"message":"Stop implementing EvaluatorFactory in Registry\n\nThis isn't a necessary interface, as the actual caller will always know\nif it's asking the registry. It has the same signatures as\nTransformEvaluatorFactory, but isn't appropriate to use in places where\nthose factories are appropriate.","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/79480145a4a56056b36636e2fb1e45039400fe10"},{"sha":"d6053912fa6eac7159286cf0f9395dec037db683","author":{"name":"Pablo","email":"fcf76ebfc25ef2d391e5e9e1c8a3145804b524cf@google.com"},"message":"Python Metrics now rely on StateSampler state.","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/d6053912fa6eac7159286cf0f9395dec037db683"},{"sha":"e59685037e805d3332a39478a38140510cbc24c4","author":{"name":"Henning Rohde","email":"cc74ff07599c64f633a3f6876da4eb88a647f9b9@google.com"},"message":"Rename Window to WindowingStrategy","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/e59685037e805d3332a39478a38140510cbc24c4"},{"sha":"41bbc1638e19c6f824b03727fe8816554c333c82","author":{"name":"Henning Rohde","email":"cc74ff07599c64f633a3f6876da4eb88a647f9b9@google.com"},"message":"Add WindowInto and window representations\n\n * Add windowed_wordcount example\n * Expose Window as an optional paramter in DoFns\n * TODO: runtime aspect","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/41bbc1638e19c6f824b03727fe8816554c333c82"},{"sha":"0c86434e79ad52ef8f6d9957a662379246b3b9ea","author":{"name":"Henning Rohde","email":"cc74ff07599c64f633a3f6876da4eb88a647f9b9@google.com"},"message":"Update EventTime to match Beam spec\n\n * Propogate windows in the runtime\n * Separate WindowFn from WindowingStrategy","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/0c86434e79ad52ef8f6d9957a662379246b3b9ea"},{"sha":"5323ddf70da29c39b801cc642d4668b939faf784","author":{"name":"Henning Rohde","email":"cc74ff07599c64f633a3f6876da4eb88a647f9b9@google.com"},"message":"Simplify Combine code","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/5323ddf70da29c39b801cc642d4668b939faf784"},{"sha":"6ee6d36955135af80b8e1e548d1c0d9a5525c2b7","author":{"name":"Henning Rohde","email":"cc74ff07599c64f633a3f6876da4eb88a647f9b9@google.com"},"message":"Support windowing in Go direct runner","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/6ee6d36955135af80b8e1e548d1c0d9a5525c2b7"},{"sha":"81c235c706bd235485cd974fce2b98c97a05e64e","author":{"name":"Henning Rohde","email":"cc74ff07599c64f633a3f6876da4eb88a647f9b9@google.com"},"message":"Support Go windowing on Dataflow\n\n * Fix encoding bug for GBK windowing strategy\n * Send model pipeline reference IDs for Dartaflow ParDo\n * TODO: Flink runner doesn't yet support WindowInto","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/81c235c706bd235485cd974fce2b98c97a05e64e"},{"sha":"5a70b7fc2f526e6e7059e69d7acb28058a3f0b87","author":{"name":"Thomas Groh","email":"d28e9909363a9c1600e80ac000976ccd4e3d0121@google.com"},"message":"Cleanups in GroupByKeyOnlyEvaluatorFactory\n\nRemove unused parameters for internal methods.\n\nStop duplicating `StrucutralKey` functionality.","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/5a70b7fc2f526e6e7059e69d7acb28058a3f0b87"},{"sha":"084fbbccdb944d9ed5f8c988820b08c86dfad437","author":{"name":"Daniel Oliveira","email":"a1ff13b9e7ef8bafd40876be0ea4d048d1020790@gmail.com"},"message":"[BEAM-3513] Removing PrimitiveCombineGroupedValues override w/ FnAPI.\n\nWhen using the FnAPI, make it so that Combine.GroupedValues are not\nreplaced by the Dataflow specific PTransforms. The reason for this is\nto allow the Combines to be translated to a Dataflow pipeline as the\nconstituent parts of the composite transform (in other words, send\nDataflow a GBK and a ParDo, instead of a CombineGroupedValues black\nbox).\n\nThis does not fully accomplish the final goal of portable combines since\nthis method doesn't do anything to help Combiner lifting, but it works\nfor the case of the basic Combine that has been implemented. It\nsuccessfully treats the Combine as a GBK and ParDo when not lifted.\n\nAdditional changes will need to be made to detect when we want to lift\nCombines and in those situations handle that properly, which may mean\nputting the Combines in the black box.","distinct":false,"url":"https://api.github.com/repos/youngoli/beam/commits/084fbbccdb944d9ed5f8c988820b08c86dfad437"}]}
{"actor":{"display_login":"youngoli"}}