{"push_id":1252720716,"size":27,"distinct_size":27,"ref":"refs/heads/master","head":"57ea54baba58dc6cf7382ec6b6c4dbd9011fc1c5","before":"3f08b2cdde15005c878806657a67def425f48652","commits":[{"sha":"411c84b80736128949e98217775e6503ddf70c53","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@users.noreply.github.com"},"message":"Add KafkaIO to Contrib (#345)\n\nAdd KafkaIO to Contrib\r\n\r\nKafkaIO is an Unbounded source for reading from Apache Kafka.\r\n\r\nBackports KafkaIO from Apache Beam. See apache/incubator-beam\r\n7b175dff8303b24cb92702db5b5a1a4691435bb1","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/411c84b80736128949e98217775e6503ddf70c53"},{"sha":"82ab660c95c9337fe24efe824c8000f320deb55e","author":{"name":"Ian Zhou","email":"ef9ac53209b4c076b310964226c35dbec9459100@gmail.com"},"message":"Added Bigtable Read DisplayData (#349)","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/82ab660c95c9337fe24efe824c8000f320deb55e"},{"sha":"508be16b16d4cf981a593530235fc37b4ecb6837","author":{"name":"Vikas Kedigehalli","email":"5acf843928d466100f205b6d28323cee5bd7fb04@google.com"},"message":"Add option to disable cloning DoFn in DoFnTester","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/508be16b16d4cf981a593530235fc37b4ecb6837"},{"sha":"e5126d3f16a5fbdff94e4338caf4e269feab7c3d","author":{"name":"Kenn Knowles","email":"1e3c81540783908bdc2f9375ae5fffd2b10be621@kennknowles.com"},"message":"Merge pull request #350 from vikkyrk/vikasrk/dofntester\n\nAdd option to disable cloning DoFn in DoFnTester","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/e5126d3f16a5fbdff94e4338caf4e269feab7c3d"},{"sha":"c2d00d302252cf9eca177508315bbc1532a80c00","author":{"name":"Dan McGrath","email":"dfc3ad6f1272f9179ba36ff212058685311d7f50@gmail.com"},"message":"Minor nit on Datastore capitalization (#355)\n\nPrevents localization issues where the product name is translated by mistake to a local language.","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/c2d00d302252cf9eca177508315bbc1532a80c00"},{"sha":"870e1b47ced76221de7b45d50dfdee338d17e393","author":{"name":"Daniel Halperin","email":"0291491adc84a7497e89df29893a36b10448bbd8@users.noreply.github.com"},"message":"Compressed source fixes and tests (#357)\n\n* CompressedSource: CompressedReader is never splittable\r\n\r\nThe only way it's safe to split a compressed file is if the file is not compressed. This can\r\nonly happen when the source itself is splittable, and that in turn will result in the inner\r\nsource's reader being returned. A CompressedReader will only be created in the event that\r\nthe file is NOT splittable. So remove all the logic handling splittable compressed readers,\r\nand instead go with the logic when we know/assume the file is compressed.\r\n\r\n* TextIO: test compression with larger files\r\n\r\nIt is important for correctness that we test with large files\r\nbecause otherwise the compressed file may be larger than the\r\nuncompressed file, which could mask bugs\r\n\r\n* TextIOTest: flesh out more\r\n\r\n* TextIOTest: add large uncompressed file","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/870e1b47ced76221de7b45d50dfdee338d17e393"},{"sha":"a0a15a79088003cbe2646bd469d626de04f8ced3","author":{"name":"Daniel Halperin","email":"0291491adc84a7497e89df29893a36b10448bbd8@users.noreply.github.com"},"message":"Version management: update to worker container version 1.6.1 (#359)","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/a0a15a79088003cbe2646bd469d626de04f8ced3"},{"sha":"1f1e98b8e2e384fbdea8df191947fd4deab81e32","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@users.noreply.github.com"},"message":"Use EqualsTester in ProxyInvocationHandlerTest (#358)\n\nThis tests the equality groups instead of manual assertions, including\r\nsame-reference equality.","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/1f1e98b8e2e384fbdea8df191947fd4deab81e32"},{"sha":"16ee7d8b98a7bd934af1f3f1b8f8ad26ef075e78","author":{"name":"Vikas Kedigehalli","email":"3b99b331c80e3adfe090c4b667da105d84b1c306@gmail.com"},"message":"Use Datastore AncestorKey for AutoComplete example (#354)\n\n* Use Datastore AncestorKey for AutoComplete example\r\n\r\n* Remove unused import\r\n\r\n* Add ancestor key","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/16ee7d8b98a7bd934af1f3f1b8f8ad26ef075e78"},{"sha":"3452e6b1be5e81a90228000b43a2c313e108b031","author":{"name":"Vikas Kedigehalli","email":"3b99b331c80e3adfe090c4b667da105d84b1c306@gmail.com"},"message":"Datastore Read as a composite PTransform (#352)","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/3452e6b1be5e81a90228000b43a2c313e108b031"},{"sha":"436b7a2567017108374ec901f389a1ffd77cde73","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Deduplicate Unbounded Reads\n\nThis ensures that sources that produce duplicate elements that are\nmarked as requiresDeduplication are handled by the DirectRunner.","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/436b7a2567017108374ec901f389a1ffd77cde73"},{"sha":"60fa23d91fb315f056e7ed15c5d6885a8af76dca","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Remove unneccessary method in ReadEvaluatorFactories\n\nThe getTransformEvaluator() method's only call is poll on the result of\ngetTransformEvaluatorQueue (which is only ever called by\ngetTransformEvaluator). Instead, move the construction to\ngetTransformEvaluator and call poll on the result.","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/60fa23d91fb315f056e7ed15c5d6885a8af76dca"},{"sha":"2b6ef825f6a484080912529cb90824d028ecd3e1","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Remove References to Instant#now in the DirectRunner\n\nThe DirectRunner should use exclusively the configured clock to\ndetermine the processing time.","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/2b6ef825f6a484080912529cb90824d028ecd3e1"},{"sha":"44a277b459a9bb1c1215862b2092f0483c86462d","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Add DirectRunner Reuse Test\n\nTwo calls to run using the Direct Runner should be independent and\nsucceed independently.","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/44a277b459a9bb1c1215862b2092f0483c86462d"},{"sha":"fae7eb9dc082bf3707fd9a0718402dc43a9a70df","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Remove unneccssary Assignment in TransformExecutor","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/fae7eb9dc082bf3707fd9a0718402dc43a9a70df"},{"sha":"b9a5fed44706a2385119334c62550465100d41bc","author":{"name":"Daniel Halperin","email":"0291491adc84a7497e89df29893a36b10448bbd8@users.noreply.github.com"},"message":"Merge pull request #361 from tgroh/backport_473\n\nDeduplicate Unbounded Reads","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/b9a5fed44706a2385119334c62550465100d41bc"},{"sha":"1ce7fe01f90a86ef0f509c55e6d60a195b9a2333","author":{"name":"lukecwik","email":"1d2e3bdca1d6440d1a9ef85c0551ccbe539f5a14@google.com"},"message":"Merge pull request #363 from tgroh/backport_747\n\nRemove unneccessary method in ReadEvaluatorFactories","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/1ce7fe01f90a86ef0f509c55e6d60a195b9a2333"},{"sha":"26c85bbe2c684fb02706738e9590fb8863694ba8","author":{"name":"lukecwik","email":"1d2e3bdca1d6440d1a9ef85c0551ccbe539f5a14@google.com"},"message":"Merge pull request #364 from tgroh/backport_795\n\nMinor Cleanups in the Direct Runner","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/26c85bbe2c684fb02706738e9590fb8863694ba8"},{"sha":"65b885a54f31ff3f1b0a40cba205460a9ad84a5f","author":{"name":"David Rieber","email":"d1f50ad0ad134c7e0dee0093c2967778f55332d8@google.com"},"message":"Do not add DataDisks to windmill service jobs.","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/65b885a54f31ff3f1b0a40cba205460a9ad84a5f"},{"sha":"1d977f196142f6a64ce9645184ed23d257ab861d","author":{"name":"Daniel Halperin","email":"0291491adc84a7497e89df29893a36b10448bbd8@users.noreply.github.com"},"message":"Merge pull request #367 from drieber/backport-804\n\nDo not add DataDisks to windmill service jobs.","distinct":true,"url":"https://api.github.com/repos/sammcveety/DataflowJavaSDK/commits/1d977f196142f6a64ce9645184ed23d257ab861d"}]}
{"actor":{"display_login":"sammcveety"}}