Google Git
Sign in
apache / beam / HEAD
  1. fd06b7e Fix generic comparisons on protobuf messages by Joe Tsai · 4 years, 6 months ago
  2. 96fa3da [BEAM-8347]: Consistently advance UnboundedRabbitMqReader watermark (#9820) by Daniel Robert · 4 years, 6 months ago
  3. 2e0a983 [BEAM-6335] Added streaming GroupByKey Test that reads SyntheticSource from PubSub. Added metrics. by Kasia Kucharczyk · 4 years, 7 months ago
  4. eb9dea3 Merge pull request #10024: [BEAM-8568] Fixed problem that LocalFileSystem no longer supports wil… by David Moravek · 4 years, 6 months ago
  5. 4caefa6 [BEAM-8568] Fixed problem that LocalFileSystem no longer supports wildcard relative paths. by Cerny Ondrej · 4 years, 6 months ago
  6. 076a037 Merge pull request #9811: [BEAM-8402] Create a class hierarchy to represent Python environments by Maximilian Michels · 4 years, 6 months ago
  7. 9bceeb8 Adjust last-updated date for the Jenkins README by Maximilian Michels · 4 years, 6 months ago
  8. b02b856 Bump Dataflow python container versions by Brian Hulette · 4 years, 6 months ago
  9. 01726e9 Merge pull request #9188: [BEAM-7886] Make row coder a standard coder and implement in Python by reuvenlax · 4 years, 6 months ago
  10. 39cbc87 Merge pull request #10018: [BEAM-8574] Revert "[BEAM-8427] Create a table and a table provider for MongoDB" by Andrew Pilloud · 4 years, 6 months ago
  11. fd51123 Revert "[BEAM-8427] Create a table and a table provider for MongoDB" by Kirill Kozlov · 4 years, 6 months ago
  12. 1baad3b Option to skip display operations in beam's InteractiveRunner. This helps significantly when running large pipelines that do not need display (ie, that are not run on Jupyter/Colab). by Andre Araujo · 4 years, 6 months ago
  13. df34941 Clarify that SplitRestriction outputs Restrictions by Jonathan Alvarez-Gutierrez · 4 years, 6 months ago
  14. 8327160 Update DoFn.SplitRestriction signature by Jonathan Alvarez-Gutierrez · 4 years, 6 months ago
  15. bfc65dd [BEAM-8402] Create a class hierarchy to represent environments by Viola Lyu · 4 years, 7 months ago
  16. 49ef06e Merge pull request #9848 from je-ik/BEAM-8450: [BEAM-8450] Allow empty bundles in ParDoLifecycleTest by Jan Lukavský · 4 years, 6 months ago
  17. b3cb103 [BEAM-8450] Allow empty bundles in ParDoLifecycleTest by Jan Lukavsky · 4 years, 7 months ago
  18. fae96ed Merge pull request #9745: [BEAM-8352] Add "withMaxCapacityPerShard()" to KinesisIO.Read by Alexey Romanenko · 4 years, 6 months ago
  19. 2e5f89a Javadoc that the sdk.util package is internal by Alexey Romanenko · 4 years, 6 months ago
  20. 9ad416e Merge pull request #10006: [BEAM-8565] Update .test-infra/jenkins/README to reflect the current state by Maximilian Michels · 4 years, 6 months ago
  21. 5926ade [BEAM-8565] Update .test-infra/jenkins/README with missing entries and correct wrong entries by sunjincheng121 · 4 years, 6 months ago
  22. 79d21b1 [BEAM-8442] Remove duplicate code for bundle register in Python SDK harness by sunjincheng121 · 4 years, 6 months ago
  23. 6868333 [BEAM-8442] Update the client side implemetation of Fn API to make sure register is executed sucessfully before executing process_bundle by sunjincheng121 · 4 years, 6 months ago
  24. 22bd9b1 [Go SDK] Correctly return EOFs from boolDecoder by Robert Burke · 4 years, 6 months ago
  25. 1bff5ae Merge pull request #10001 from youngoli/patch-9 by Lukasz Cwik · 4 years, 6 months ago
  26. e79bcf8 spotlesApply by kirillkozlov · 4 years, 6 months ago
  27. 08381fd Refactoring by kirillkozlov · 4 years, 6 months ago
  28. f7ce06d Add simple beam:coder:row:v1 test to standard_coders.yaml by Brian Hulette · 4 years, 6 months ago
  29. 599bd21 Selecting fields in a different order should not drop the Calc when project push-down is not supported by kirillkozlov · 4 years, 6 months ago
  30. bbf46c2 Python: Add support for beam:coder:row:v1 in standard_coders_test.py by Brian Hulette · 4 years, 6 months ago
  31. d9e4134 Fixed a bug with selecting the same field more than once. Changed a cost model for BeamCalcRel. by kirillkozlov · 4 years, 6 months ago
  32. 5ff7428 Filter push-down should not be reliant on project push-down [BEAM-8508] by kirillkozlov · 4 years, 6 months ago
  33. 38459c0 Python: Add RowCoder by Brian Hulette · 4 years, 6 months ago
  34. 83322b9 Python: Add conversions between native types and protobuf schema representation by Brian Hulette · 4 years, 6 months ago
  35. de196e0 Java: Add suport for beam:coder:row:v1 in CommonCoderTest by Brian Hulette · 4 years, 6 months ago
  36. 7f90f2b Removing some trailing whitespace. by Daniel Oliveira · 4 years, 6 months ago
  37. 05ff238 Java: Implement RowCoder fn api translation by Brian Hulette · 4 years, 6 months ago
  38. f80b50d Add beam:coder:row:v1 to standard coders by Brian Hulette · 4 years, 6 months ago
  39. 692da20 [BEAM-8294] run Spark portable validates runner tests in parallel by Kyle Weaver · 4 years, 6 months ago
  40. c39752a Merge pull request #9941 Fix expected step name in Python PTransformTest test_read_metrics by Robert Bradshaw · 4 years, 6 months ago
  41. 326ac36 Merge pull request #9806: [BEAM-8427] Create a table and a table provider for MongoDB by Andrew Pilloud · 4 years, 6 months ago
  42. 8e49c5a [BEAM-8472] Get default GCP region from gcloud (Java) by Kyle Weaver · 4 years, 6 months ago
  43. ddd115a Merge pull request #9969 from apache/beam8539 by Lukasz Cwik · 4 years, 6 months ago
  44. 16fbe89 Merge pull request #9836 [BEAM-8435] Implement PaneInfo computation for Python. by Robert Bradshaw · 4 years, 6 months ago
  45. 1c56a76 [BEAM-8558] Fix BigQueryIOIT flakiness (#9995) by Michal Walenia · 4 years, 6 months ago
  46. fdd3570 Merge pull request #9982: Use better name for Flink current key supplier by Maximilian Michels · 4 years, 6 months ago
  47. 315566a Merge pull request #9871: [BEAM-4420] Kafka ioit jenkins job by Łukasz Gajowy · 4 years, 6 months ago
  48. 7120c2a Merge pull request #9936: [BEAM-7303] Move PortableRunner from runners.reference to runners.portability package by Maximilian Michels · 4 years, 6 months ago
  49. 9f56639 Merge pull request #9980 from mxm/BEAM-8549 by Maximilian Michels · 4 years, 6 months ago
  50. d155893 Merge pull request #9984: [BEAM-8432] Enable building kotlin examples with different java versions by Łukasz Gajowy · 4 years, 6 months ago
  51. 9233aa4 Merge pull request #9987: [BEAM-8504] Fix a bug related to zero-row responses by Chamikara Jayalath · 4 years, 6 months ago
  52. a4141ac Merge pull request #9989 [BEAM-8555] Update Python streaming limitations. by tvalentyn · 4 years, 6 months ago
  53. e29a0e9 [BEAM-8555] Update Python streaming limitations. by tvalentyn · 4 years, 6 months ago
  54. e7f1539 Merge pull request #9961 from ibzib/java-worker by Kyle Weaver · 4 years, 6 months ago
  55. 187d71e Merge pull request #9985 from aaltay/prec by Ahmet Altay · 4 years, 6 months ago
  56. 1e70f1c Fix a bug related to zero-row responses by Aryan Naraghi · 4 years, 6 months ago
  57. 9ed9dc7 [BEAM-8368] [BEAM-8392] Update pyarrow to the latest version 0.15.1 (#9970) by Ahmet Altay · 4 years, 6 months ago
  58. fc142c2 [BEAM-8435] Implement PaneInfo computation for Python. by Robert Bradshaw · 4 years, 7 months ago
  59. d024a4e Merge pull request #9958 [BEAM-8532] Output timestamp inclusive, not exclusive, end of window. by Robert Bradshaw · 4 years, 6 months ago
  60. 640ced8 Remove base tests from python precommits by Ahmet Altay · 4 years, 6 months ago
  61. c421484 Merge pull request #9966 [BEAM-8544] Use ccache for compiling the Beam Python SDK. by Robert Bradshaw · 4 years, 6 months ago
  62. eaeeb6a Update BigQueryHllSketchCompatibilityIT to cover empty sketch cases by Yueyang Qiu · 4 years, 7 months ago
  63. ad7ae0d Merge pull request #9967 Align base image requirements with Beam's setup.py. by Robert Bradshaw · 4 years, 6 months ago
  64. 664de39 Merge pull request #9930: [BEAM-8516] only consider current version in sdist build by Mark Liu · 4 years, 6 months ago
  65. 711b7aa Merge pull request #9983: [BEAM-8500] update trigger phrase for beam_PreCommit_Website_Stage_GCS in README by Mark Liu · 4 years, 6 months ago
  66. e9087a0 Merge pull request #9948: [BEAM-8526] Turn on metrics publishing in load tests on Flink by Łukasz Gajowy · 4 years, 6 months ago
  67. 535e5fb [BEAM-8432] Enable building kotlin examples with different java versions by Łukasz Gajowy · 4 years, 6 months ago
  68. 5ce20cb Bump pyyaml from 3.13 to 5.1 in /sdks/python/container by dependabot[bot] · 4 years, 6 months ago
  69. a6936c8 [BEAM-3713] Add pytest for unit tests (#9756) by Udi Meiri · 4 years, 6 months ago
  70. 7f52e45 [BEAM-4420] Fix cancelling timeouting Dataflow jobs by Łukasz Gajowy · 4 years, 6 months ago
  71. f0b1e1e [BEAM-4420] Extract common Jenkins code by Łukasz Gajowy · 4 years, 6 months ago
  72. afa759a [BEAM-4420] Create jenkins job for Kafka IOIT by Łukasz Gajowy · 4 years, 6 months ago
  73. 1ece728 [BEAM-4420] Refactor multiple things: by Łukasz Gajowy · 4 years, 6 months ago
  74. 7ffb218 [BEAM-7303] Rename runners.reference package to runners.portability by Michal Walenia · 4 years, 6 months ago
  75. d282879 [BEAM-4420] Make it possible for kafka test k8s setup to pass namespace as a parameter by Łukasz Gajowy · 4 years, 7 months ago
  76. 101165a update trigger phrase for beam_PreCommit_Website_Stage_GCS in README by yoshiki.obata · 4 years, 6 months ago
  77. 45bf690 Use better name for Flink current key supplier by Maximilian Michels · 4 years, 6 months ago
  78. c81b5f4 [BEAM-8549] Do not use keyed operator state for checkpoint buffering by Maximilian Michels · 4 years, 6 months ago
  79. 1664ce2 [BEAM-8467] Enabling reading compressed files (#9861) by Pablo · 4 years, 6 months ago
  80. 3626751 [BEAM-8491] Add ability for replacing transforms with multiple outputs (#9912) by Sam sam · 4 years, 6 months ago
  81. 3d865bc Merge pull request #9816: [BEAM-8422] Notify builds@ on ABORTED job final state by Łukasz Gajowy · 4 years, 6 months ago
  82. 902dddd Merge pull request #9862: Describe Jira priorities and release blockers on Beam site by Kenn Knowles · 4 years, 6 months ago
  83. 2564cb9 Add release blocking section to Beam site by Kenneth Knowles · 4 years, 7 months ago
  84. 1cb675a Add Jira priority explanations to Beam site by Kenneth Knowles · 4 years, 7 months ago
  85. ed8401d Merge pull request #9880: [BEAM-8503] Improve TestBigQuery and TestPubsub by Kenn Knowles · 4 years, 6 months ago
  86. 9b30d7c [BEAM-8146,BEAM-8204,BEAM-8205] Add equals and hashCode to SchemaCoder and RowCoder (#9493) by Brian Hulette · 4 years, 6 months ago
  87. 8f3818e [BEAM-8254] add workerRegion and workerZone options to Java SDK by Kyle Weaver · 4 years, 6 months ago
  88. 9d2d9df Merge pull request #9924 from davidcavazos/distinct-code by Ahmet Altay · 4 years, 6 months ago
  89. bebbba8 [BEAM-7389] Add code snippets for CombinePerKey (#9921) by David Cavazos · 4 years, 6 months ago
  90. 4b107d2 [BEAM-8532] Output timestamp should be the inclusive, not exclusive, end of window. by Robert Bradshaw · 4 years, 6 months ago
  91. a2349ea Bump jekyll from 3.2.0 to 3.6.3 in /website by dependabot[bot] · 4 years, 6 months ago
  92. dfc230c Merge pull request #9741 from [BEAM-7926] Visualize PCollection by Ning Kang · 4 years, 6 months ago
  93. 660c618 Additional logging. by Robert Bradshaw · 4 years, 6 months ago
  94. c870c63 [BEAM-7917] Fix datastore writes failing on retry (#9294) by Dmytro Sadovnychyi · 4 years, 6 months ago
  95. 980e655 Merge pull request #9939 from ibzib/xlang-version by Kyle Weaver · 4 years, 6 months ago
  96. 78ce6e0 Merge branch 'master' into metrics by Craig Chambers · 4 years, 6 months ago
  97. 295d9f8 generalized step name matching by Craig Chambers · 4 years, 6 months ago
  98. b09b1b6 [BEAM-8539] Provide an initial definition of all job states and the state transition diagram by Lukasz Cwik · 4 years, 6 months ago
  99. 10a570f Align base image requirements with Beam's setup.py. by Robert Bradshaw · 4 years, 6 months ago
  100. 81af13c [BEAM-8544] Use ccache for compiling the Beam Python SDK. by Robert Bradshaw · 4 years, 6 months ago