Google Git
Sign in
apache / beam / HEAD
  1. c2e58c5 Merge pull request #10047: [BEAM-8028] Add spark_runner.py by Maximilian Michels · 4 years, 5 months ago
  2. dc1fee8 Merge pull request #9973: Bump jekyll from 3.2.0 to 3.6.3 for building website by Kenn Knowles · 4 years, 5 months ago
  3. 3265605 fix codestyle by sunjincheng121 · 4 years, 5 months ago
  4. f038020 fixup by sunjincheng121 · 4 years, 5 months ago
  5. 4013214 [BEAM-8557] Add log for the dropped unknown response by sunjincheng121 · 4 years, 5 months ago
  6. 212fb09 [BEAM-2939, BEAM-5600, BEAM-6868, BEAM-7233] Expose residual roots and bundle finalization callbacks to portable runners. by Lukasz Cwik · 4 years, 5 months ago
  7. 0ff4904 [BEAM-8597] Allow TestStream trigger tests to run on other runners. by Robert Bradshaw · 4 years, 6 months ago
  8. 385bba2 Implement portable representation of TestStream. by Robert Bradshaw · 4 years, 6 months ago
  9. 6bcf166 Add settings file by Ahmet Altay · 4 years, 5 months ago
  10. 0d4f3de Merge pull request #10033 [BEAM-8575] Discarding mode with early data trigger test. by Robert Bradshaw · 4 years, 5 months ago
  11. 090b510 [BEAM-8539] Make job state transitions in python-based runners consistent with java-based runners (#9965) by Chad Dombrova · 4 years, 6 months ago
  12. 3330e1e Separate pydocs generation from py2 precommit tests. by Ahmet Altay · 4 years, 6 months ago
  13. e852ac8 [BEAM-5600, BEAM-2939] Add SplittableParDo expansion logic to runner's core. by Lukasz Cwik · 4 years, 6 months ago
  14. ef7ec62 [BEAM-2939, BEAM-6868, BEAM-7233] Expose residual roots and bundle finalization callbacks to portable runners. by Luke Cwik · 4 years, 6 months ago
  15. 221f08d Added RowJsonTest for lofical types by kirillkozlov · 4 years, 6 months ago
  16. c7be064 Merge pull request #10036 [BEAM-8589] Print pipeline proto and pipeline options in DEBUG loglevel. by tvalentyn · 4 years, 6 months ago
  17. f95de04 [BEAM-8579] Strip UTF-8 BOM from TextSource output. by Lukasz Cwik · 4 years, 6 months ago
  18. b951993 [BEAM-8587] TestStream for Dataflow runner by Lukasz Cwik · 4 years, 6 months ago
  19. f0cf1b3 ToJson should support logical types by kirillkozlov · 4 years, 6 months ago
  20. 57d47dd spotlesApply by kirillkozlov · 4 years, 6 months ago
  21. b838375 [SQL] Implemented write functionality for MongoDbTable, updated conversion logic for RowJsonSerializer by kirillkozlov · 4 years, 6 months ago
  22. a093994 Created a MongoDbTable and a provider for it by kirillkozlov · 4 years, 6 months ago
  23. 36d6534 Merge pull request #10031: [BEAM-8427] [SQL] Create a table and a table provider for MongoDB by Andrew Pilloud · 4 years, 6 months ago
  24. 063ee99 Merge pull request #9793 from robinyqiu/tmp by Boyuan Zhang · 4 years, 6 months ago
  25. 60845e5 [BEAM-8524] Still use fake pubsub signals when using windmill appliance by Lukasz Cwik · 4 years, 6 months ago
  26. 7124651 [BEAM-8605] Function display_graph() in example do not exist by Lukasz Cwik · 4 years, 6 months ago
  27. 043fecd Add HllCount to Java transform catalog by Yueyang Qiu · 4 years, 6 months ago
  28. 47d5ee9 Merge pull request #9778 from robinyqiu/hll by Boyuan Zhang · 4 years, 6 months ago
  29. c7ffbde [BEAM-8472] test Java default GCP region by Lukasz Cwik · 4 years, 6 months ago
  30. 0a75cb6 Merge pull request #10015 from andrefaraujo/master Option to skip display operations in beam's InteractiveRunner. by Pablo · 4 years, 6 months ago
  31. 9c76dbf Add cross-language efforts to roadmap index page by Thomas Weise · 4 years, 6 months ago
  32. 7937317 Merge pull request #9885 from [BEAM-8457] Label Dataflow jobs from Notebook by Ning Kang · 4 years, 6 months ago
  33. 91fd0df fixup! Fix checkstyle & spotbugs by Luke Cwik · 4 years, 6 months ago
  34. 15b3db2 [BEAM-8472] test Java default GCP region by Kyle Weaver · 4 years, 6 months ago
  35. 0178652 Merge pull request #10004: [BEAM-8442] Unify bundle register in Python SDK harness by Maximilian Michels · 4 years, 6 months ago
  36. 53c6212 Merge pull request #10032: [BEAM-8585] Include path in error message in path_to_beam_jar by Maximilian Michels · 4 years, 6 months ago
  37. a1d8d21 Update pipeline_graph.py by RusOr10n · 4 years, 6 months ago
  38. 71fbf10 [BEAM-2535] Apply Spotless by Rehman · 4 years, 6 months ago
  39. 6e9ca40 Merge branch 'master' into time-output-timestamp by Rehman · 4 years, 6 months ago
  40. d5a8b2d Beam-2535 : Added original PR watermark hold functionality. by Zohaib · 4 years, 6 months ago
  41. ede14d4 Merge pull request #10054: [BEAM-8553] Updates cross-language transforms roadmap by Chamikara Jayalath · 4 years, 6 months ago
  42. de0b4fb Merge pull request #9960: [BEAM-3288] Guard against unsafe triggers at construction time by Kenn Knowles · 4 years, 6 months ago
  43. f481cd4 [BEAM-8602] Always use shadow configuration for direct runner dependencies by Lukasz Cwik · 4 years, 6 months ago
  44. 27c4190 Updates cross-language transforms roadmap by chamikara@google.com · 4 years, 6 months ago
  45. 4af507f Always use shadow configuration for direct runner dep by Brian Hulette · 4 years, 6 months ago
  46. 3f7cf68 Add option to test metrics on runners without gauge support. by Robert Bradshaw · 4 years, 6 months ago
  47. 1d81898 Merge pull request #9963 from apache/dependabot/pip/sdks/python/container/pyyaml-5.1 by Ahmet Altay · 4 years, 6 months ago
  48. 18de5fa Merge pull request #9781 from shusso/prog-guide-531-fix-example-code by Ahmet Altay · 4 years, 6 months ago
  49. 82359a6 Merge pull request #9950 from pgudlani/patch-1 by Ahmet Altay · 4 years, 6 months ago
  50. dc413c1 [BEAM-7224] add py wordcount tests for Spark by Kyle Weaver · 4 years, 6 months ago
  51. 82132a6 [BEAM-8028] add spark_runner.py by Kyle Weaver · 4 years, 6 months ago
  52. 4364a21 Javadoc that the sdk.util package is internal by Lukasz Cwik · 4 years, 6 months ago
  53. f31a0df Replaces unittest annotation with setting __test__ = False to prevent nosetest from trying to run the method. by Andrew Crites · 4 years, 6 months ago
  54. df0e7e8 Merge pull request #9974 from ibzib/java-default-region by Kyle Weaver · 4 years, 6 months ago
  55. 40383d8 Merge pull request #9998 from ibzib/flink-runner-test by Kyle Weaver · 4 years, 6 months ago
  56. 42da6ae BEAM-8579: Strip UTF-8 BOM from TextSource output. by Changming Ma · 4 years, 6 months ago
  57. 894e940 [BEAM-3288] Guard against unsafe triggers at construction time by Kenneth Knowles · 4 years, 6 months ago
  58. 45152b8 fixup! Lint by Luke Cwik · 4 years, 6 months ago
  59. 35da90a Merge pull request #9665: [BEAM-2879] Support writing data to BigQuery via avro by Chamikara Jayalath · 4 years, 6 months ago
  60. c32842b [BEAM-5600, BEAM-2939] Add SplittableParDo expansion logic to runner's core. by Luke Cwik · 4 years, 6 months ago
  61. 5dbaf66 Merge pull request #9996 Simplify and clean up metrics by Robert Bradshaw · 4 years, 6 months ago
  62. be08efd Fixes line-to-long lint error. by Andrew Crites · 4 years, 6 months ago
  63. d619ea1 Print pipeline proto and pipeline options in DEBUG loglevel. by Valentyn Tymofieiev · 4 years, 6 months ago
  64. d8e94bb [BEAM-5878] update dill min version to 0.3.1.1 and add test for functions with Keyword-only arguments (#9686) by yoshiki.obata · 4 years, 6 months ago
  65. 037f219 Bump Dataflow python container version by Robert Bradshaw · 4 years, 6 months ago
  66. e74f00a Remove unused metrics supported global. by Robert Bradshaw · 4 years, 6 months ago
  67. 329a8ce Simplify and improve performance of metrics. by Robert Bradshaw · 4 years, 6 months ago
  68. 2c89d7f [BEAM-6335] Added custom PubSub Matcher that stops pipeline after specified number of records or timeout. by Kasia Kucharczyk · 4 years, 6 months ago
  69. c50f045 [BEAM-6335] Changed SyntheticDataPublisher to publish String UTF values insead of pairs, which were difficult to decode. by Kasia Kucharczyk · 4 years, 6 months ago
  70. ad3fdf2 [BEAM-2879] Support writing data to BigQuery via avro by steve · 4 years, 7 months ago
  71. 19303ab [BEAM-8157] Fail if key group for state request does not match key group range by Maximilian Michels · 4 years, 6 months ago
  72. 119f41d2 Merge pull request #10008: [BEAM-8567] Do not swallow execution errors during checkpointing by Maximilian Michels · 4 years, 6 months ago
  73. 87488c4 Merge pull request #10007: [BEAM-8566] Fix checkpoint buffering when another bundle is started during checkpointing by Maximilian Michels · 4 years, 6 months ago
  74. 5a23914 [BEAM-8567] Do not swallow execution errors during checkpointing by Maximilian Michels · 4 years, 6 months ago
  75. 2deb788 [BEAM-8566] Fix checkpoint buffering when another bundle is started during checkpointing by Maximilian Michels · 4 years, 6 months ago
  76. 5aaaad1 [BEAM-8594] Remove unnecessary error check in DataFlow Runner by sunjincheng121 · 4 years, 6 months ago
  77. 66a67e6 Add portable schemas to the roadmap by Thomas Weise · 4 years, 6 months ago
  78. ccc98f0 Merge pull request #10022: Isolate sql precommit by Kenn Knowles · 4 years, 6 months ago
  79. 5bfe1b6 Exclude SQL from Java precommit by Kenneth Knowles · 4 years, 6 months ago
  80. 72eb8c7 Add separate SQL precommit by Kenneth Knowles · 4 years, 6 months ago
  81. 54e6108 Add support for exclusion in Jenkins DSL by Kenneth Knowles · 4 years, 6 months ago
  82. f6ce376 Marks run_TestStream as not a unittest, since it was trying to be 'run' when running other tests. Moves bad copy of internal/names.py to dataflow/internal/names.py, where it was supposed to go. by Andrew Crites · 4 years, 6 months ago
  83. 81aab39 [BEAM-8585] Include path in error message in path_to_beam_jar by Kyle Weaver · 4 years, 6 months ago
  84. ad84e55 Still use fake pubsub signals when using windmill appliance with dataflow streaming. by Boyuan Zhang · 4 years, 6 months ago
  85. 90d5878 Increase overhaed budget for test_sampler_transition_overhead (#10012) by Ahmet Altay · 4 years, 6 months ago
  86. 8399a12 [BEAM-8575] Add a trigger test to test Discarding accumulation mode with early data by Wenjia Liu · 4 years, 6 months ago
  87. 8a1e24c Merge pull request #10017 from ibzib/java-container-version by Kyle Weaver · 4 years, 6 months ago
  88. 6314eb2 Added IT test for BigQuery. spotlesApply. by kirillkozlov · 4 years, 6 months ago
  89. 3943893 Merge pull request #10019 from TheNeuralBit/patch-2 by Ahmet Altay · 4 years, 6 months ago
  90. c430c27 Filter push-down for BigQuery (kind of) working. by kirillkozlov · 4 years, 6 months ago
  91. 497e576 Merge pull request #9999 from ibzib/spark-parallel-test by Kyle Weaver · 4 years, 6 months ago
  92. a48662d Merge pull request #9943: [BEAM-8508] [SQL] Standalone filter push down by Andrew Pilloud · 4 years, 6 months ago
  93. 3535958 Adds TestStream support for Dataflow runner. by Andrew Crites · 4 years, 6 months ago
  94. 8fb53bf Created a MongoDbTable and a provider for it by kirillkozlov · 4 years, 6 months ago
  95. d692d2f [BEAM-8512] Add integration tests for flink_runner.py by Kyle Weaver · 4 years, 6 months ago
  96. a9ef293 flinkCompatibilityMatrix depends on Java Docker containers by Kyle Weaver · 4 years, 6 months ago
  97. 8d2f371 Use default Java container image if none is specified by Kyle Weaver · 4 years, 6 months ago
  98. 3139b43 [BEAM-8570] Use SDK version in default Java container tag by Kyle Weaver · 4 years, 6 months ago
  99. 987148a IOPushDownRule should not be applied more than once to the same IORels by kirillkozlov · 4 years, 6 months ago
  100. ec4fd27 [BEAM-8573] Updates documented signature for @SplitRestriction by Lukasz Cwik · 4 years, 6 months ago