Google Git
Sign in
apache / beam / HEAD
  1. d3be7d1 Wrap DoFns in PTransforms by kirillkozlov · 4 years, 4 months ago
  2. 7297b86 Store DataStore key as VARBINARY by kirillkozlov · 4 years, 4 months ago
  3. 9f16306 Better conversion, support complex types by kirillkozlov · 4 years, 4 months ago
  4. 1a0ca78 Read other types by kirillkozlov · 4 years, 4 months ago
  5. 926017a buildIOWriter by kirillkozlov · 4 years, 4 months ago
  6. 7fa071a Implement getTableStatistics by kirillkozlov · 4 years, 4 months ago
  7. dde0adc Added tests by kirillkozlov · 4 years, 4 months ago
  8. cf9ae1b Create initial DataStoreV1Table by kirillkozlov · 4 years, 4 months ago
  9. 2ac548f Merge pull request #10550 from angoenka/same_pc_flatten_test by Ankur · 4 years, 3 months ago
  10. 931108c Merge pull request #10601 from acrites/window-resolution by Lukasz Cwik · 4 years, 3 months ago
  11. 104033d [BEAM-9030] Align version of protoc/protoc-gen-grpc-java to vendored version. by Luke Cwik · 4 years, 3 months ago
  12. 003c891 Merge pull request #10557 from Hannah-Jiang/cleaning_up_docker_tags by Kyle Weaver · 4 years, 3 months ago
  13. 2fd785d [BEAM-9030] Migrate Beam to use beam-vendor-grpc-1_26_0 (#10578) by Jincheng Sun · 4 years, 3 months ago
  14. a37e5c5 [BEAM-8676] sdks/java: gax and grpc upgrades (#10554) by Tomo Suzuki · 4 years, 3 months ago
  15. 17398f7 Changes watermark advance from 1001 to 1000 since Dataflow TestStream only advances watermark at 1s resolution. by Andrew Crites · 4 years, 3 months ago
  16. 773eb5f Update twine install details. by Mikhail Gryzykhin · 4 years, 3 months ago
  17. 1cd8e9b Merge pull request #9944: [BEAM-8525] Support Const base in binary_subscr by Udi Meiri · 4 years, 3 months ago
  18. 9d8bfeb Merge branch 'master' into cleaning_up_docker_tags by Hannah Jiang · 4 years, 3 months ago
  19. 2e06ca4 Moving to 2.20.0-SNAPSHOT on master branch. by Boyuan Zhang · 4 years, 3 months ago
  20. 2b07e0e Merge pull request #10581: [website] Add security page and update 2.17.0 release blog post to reference it by Ismaël Mejía · 4 years, 3 months ago
  21. e9311dc [website] Update the 2.17.0 release blog post to include security issues by Ismaël Mejía · 4 years, 3 months ago
  22. 47ef1ea [website] Added security page by Ismaël Mejía · 4 years, 3 months ago
  23. f59fa64 [BEAM-9123] HadoopResourceId returns wrong directoryName bugfix by marek.simunek · 4 years, 3 months ago
  24. 4fc64ce Merge pull request #10583: [BEAM-6008] Make sure to end stream only after sending all messages and state updates by Maximilian Michels · 4 years, 3 months ago
  25. 6bc5f6e Merge pull request #10571 [BEAM-3713] Use unittest.SkipTest instead of nose.plugins.skip.SkipTest. by tvalentyn · 4 years, 3 months ago
  26. 148cc71 Merge pull request #10584: [BEAM-9117] Sets the correct coder when clustering is enabled for the multi-partition path by Chamikara Jayalath · 4 years, 3 months ago
  27. 1e88385 Merge pull request #10573: [BEAM-8844] Update data source for SQL performance tests by Andrew Pilloud · 4 years, 3 months ago
  28. 51d194d [BEAM-7746] Fix a typing issue where SourceBase was assumed to have a coder attribute by Chad Dombrova · 4 years, 6 months ago
  29. 6e19ef2 Merge pull request #10582 for [INFRA-19670] Add .asf.yaml for Github testing Whitelist by Pablo · 4 years, 3 months ago
  30. 9d5a3e4 Merge pull request #10570 Always initalize output processor on construction. by Robert Bradshaw · 4 years, 3 months ago
  31. e44a1b6 [Go SDK Doc] Update Dead Container Link (#10585) by Robert Burke · 4 years, 3 months ago
  32. 7163ede Always initalize output processor on construction. by Robert Bradshaw · 4 years, 3 months ago
  33. d03404d Merge pull request #10367 [BEAM-7746] Add python type hints (part 2) by Robert Bradshaw · 4 years, 3 months ago
  34. 281b81a Sets the correct coder when clustering is enabled for the multi-partition path by Chamikara Jayalath · 4 years, 3 months ago
  35. 3891f9f Merge pull request #10558 [BEAM-6587] Remove hacks due to missing common string coder. by Robert Bradshaw · 4 years, 3 months ago
  36. 3d541f1 [BEAM-6008] Make sure to end stream only after sending all messages and state updates by Maximilian Michels · 4 years, 3 months ago
  37. c44175c Switch to unittest.SkipTest instead of using nose. by Valentyn Tymofieiev · 4 years, 3 months ago
  38. 7bea94c Merge pull request #10485: [BEAM-9040] Add Spark Structured Streaming to Nexmark PostCommit run by Ismaël Mejía · 4 years, 3 months ago
  39. 970e8ad [BEAM-9040] Add Spark Structured Streaming Runner to Nexmark PostCommit tests by Ismaël Mejía · 4 years, 4 months ago
  40. ca8b345 [BEAM-9040] Add skipQueries option to skip queries in a Nexmark suite by Ismaël Mejía · 4 years, 4 months ago
  41. 4d3295c [BEAM-8939] A bash script that cancels stale dataflow jobs by Kamil Wasilewski · 4 years, 3 months ago
  42. f7f8792 [BEAM-7746] Fix tests that have the same name by Chad Dombrova · 4 years, 6 months ago
  43. 3ff01eb [BEAM-7746] Fix functions that were defined twice by Chad Dombrova · 4 years, 9 months ago
  44. 6189010 [BEAM-7746] Add TODO about fixing assignment to BundleManager._skip_registration by Chad Dombrova · 4 years, 6 months ago
  45. 83866ec [BEAM-7746] Add StateHandler abstract base class by Chad Dombrova · 4 years, 5 months ago
  46. ee13d08 [BEAM-7746] Avoid reusing variables with different data types by Chad Dombrova · 4 years, 3 months ago
  47. 9f14ce9 [BEAM-7746] Non-Optional arguments cannot default to None by Chad Dombrova · 4 years, 6 months ago
  48. 80e2c2e [BEAM-7746] Remove reference to missing attribute in statesampler_slow.StateSampler.reset() by Chad Dombrova · 4 years, 6 months ago
  49. bc21b25 [BEAM-7746] Move name and coder to base StateSpec class by Chad Dombrova · 4 years, 6 months ago
  50. 374db87 [BEAM-7746] Generate files with protobuf urns as part of gen_protos build process by Chad Dombrova · 4 years, 3 months ago
  51. 29e243e [BEAM-7746] Explicitly unpack tuple to avoid inferring unbounded tuple (Tuple[str, ...]) by Chad Dombrova · 4 years, 5 months ago
  52. 8353a28 [BEAM-7746] Bugfix: coder id is expected to be str in python3 by Chad Dombrova · 4 years, 5 months ago
  53. bfc6e55 [BEAM-7746] Avoid creating attributes dynamically, so that they can be statically analyzed by Chad Dombrova · 4 years, 5 months ago
  54. 882c865 [BEAM-7746] Typing fixes that require runtime code changes by Chad Dombrova · 4 years, 4 months ago
  55. 2c00922 [BEAM-7746] Address changes in code since annotations were introduced by Chad Dombrova · 4 years, 5 months ago
  56. f2d19fd [BEAM-5605] Add support for additional parameters to SplittableDofn methods (#10556) by Lukasz Cwik · 4 years, 3 months ago
  57. 35bf2bd [BEAM-5605] Add support for channel splitting to the gRPC read "source" and propagate "split" calls to the downstream receiver (#10501) by Lukasz Cwik · 4 years, 3 months ago
  58. 1012408 Update data source for SQL performance tests by kirillkozlov · 4 years, 3 months ago
  59. 99dd538 [BEAM-9084] fix Java spotless by Hannah Jiang · 4 years, 3 months ago
  60. 4135a5d Merge pull request #10537: [BEAM-8630] Use column numbers for BeamZetaSqlCalRel by Andrew Pilloud · 4 years, 3 months ago
  61. d35195f Merge pull request #10566: [BEAM-6008] Propagate errors during pipeline execution in Java's PortableRunner by reuvenlax · 4 years, 3 months ago
  62. 5e91757 Fix lint and tests due to autoconversion. by Robert Bradshaw · 4 years, 5 months ago
  63. fad9f04 Return non-None result for Dataflow dry run. by Robert Bradshaw · 4 years, 5 months ago
  64. b3a1bdd Fix lint and tests due to autoconversion. by Robert Bradshaw · 4 years, 5 months ago
  65. efa150d A couple more conversions. by Robert Bradshaw · 4 years, 5 months ago
  66. 11f9ada Fix lint and tests due to autoconversion. by Robert Bradshaw · 4 years, 5 months ago
  67. 149b9f7 Automatic conversion of more pipelines. by Robert Bradshaw · 4 years, 5 months ago
  68. 88fa30e Quick pass through failed auto-conversions. by Robert Bradshaw · 4 years, 5 months ago
  69. 43bd561 Automatically convert to with pipeline syntax. by Robert Bradshaw · 4 years, 5 months ago
  70. 65619bd [BEAM-6587] Remove hacks due to missing common string coder. by Robert Bradshaw · 4 years, 4 months ago
  71. 04498d5 [BEAM-8740] Remove unused dependency from Spark runner (#10564) by Ismaël Mejía · 4 years, 3 months ago
  72. cc4f603 Add version guards to requirements file for integration tests. by Valentyn Tymofieiev · 4 years, 3 months ago
  73. 5fedbe2 [BEAM-8993] [SQL] MongoDB predicate push down. (#10417) by Kirill Kozlov · 4 years, 3 months ago
  74. b7b06a7 Merge pull request #10431: Light cleanup of opcodes.py by Udi Meiri · 4 years, 3 months ago
  75. 2321127 [BEAM-7390] Add code snippet for Top (#10179) by David Cavazos · 4 years, 3 months ago
  76. 0ec28de Merge pull request #10178 from davidcavazos/sum-code by Pablo · 4 years, 3 months ago
  77. 02efc22 Merge pull request #10177 from davidcavazos/min-code by Pablo · 4 years, 3 months ago
  78. 571ff82 Merge pull request #10567 Tighten language and remove distracting link. by Robert Bradshaw · 4 years, 3 months ago
  79. ce2cd50 Tighten language and remove distracting link by Elliotte Rusty Harold · 4 years, 3 months ago
  80. 194a899 Merge pull request #10562: Remove incorrectly tagged test annotation from test case by Maximilian Michels · 4 years, 3 months ago
  81. 1db2e39 [BEAM-6008] Propagate errors during pipeline execution in Java's PortableRunner by Maximilian Michels · 4 years, 3 months ago
  82. c22ba7e Merge pull request #10460: [BEAM-7115] Fix metrics being incorrectly gathered by Kasia Kucharczyk · 4 years, 3 months ago
  83. a2ae7be Remove incorrectly tagged test annotation from test case by Maximilian Michels · 4 years, 3 months ago
  84. 3484558 [BEAM-7115] Fix metrics being incorrectly gathered by Pawel Pasterz · 4 years, 4 months ago
  85. 4abc23a Merge pull request #10366: [BEAM-8956] Begin unifying contributor instructions into a single location by Ismaël Mejía · 4 years, 3 months ago
  86. 420a6e8 [BEAM-8956] Begin unifying contributor instructions into a single location by Elliotte Rusty Harold · 4 years, 5 months ago
  87. 583b0c1 [BEAM-5086] Update kudu-client to version 1.11.1 by Ismaël Mejía · 4 years, 3 months ago
  88. b67017a [BEAM-8331] rewrite the calcite JDBC urls by Kai Jiang · 4 years, 4 months ago
  89. 2babd75 [BEAM-9084] cleaning up docker image tag by Hannah Jiang · 4 years, 4 months ago
  90. 33d52b2 [BEAM-9059] Use string constants in PTransformTranslation instead of getUrn() (#10521) by Lukasz Cwik · 4 years, 4 months ago
  91. 4ff0b3a Merge pull request #10538: [BEAM-9027] Backport BigQuerySqlDialect fixes by Andrew Pilloud · 4 years, 4 months ago
  92. 0bfa5e7 [BEAM-8575] Test hot-key fanout with accumulation modes. (#10159) by bumblebee-coming · 4 years, 4 months ago
  93. a20bd7e Merge pull request #10500 from [BEAM-8745] More fine-grained controls for the size of a BigQuery Load job by Pablo · 4 years, 4 months ago
  94. 603dc2a [BEAM-9027] Backport BigQuerySqlDialect fixes by Andrew Pilloud · 4 years, 4 months ago
  95. 909c543 Merge pull request #10539: [BEAM-9027] Unparse DOY/DOW/WEEK Enums properly for ZetaSQL by Andrew Pilloud · 4 years, 4 months ago
  96. a3b0f9a [BEAM-8630] Use column numbers for BeamZetaSqlCalRel by Andrew Pilloud · 4 years, 4 months ago
  97. c287f30 [BEAM-8490] Fix instance_to_type for empty containers (#9894) by Udi Meiri · 4 years, 4 months ago
  98. 93c7229 Merge pull request #10472: junitxml_report: Add failure tag support by Udi Meiri · 4 years, 4 months ago
  99. d64759d [BEAM-8575] Added counter tests for CombineFn (#10190) by bumblebee-coming · 4 years, 4 months ago
  100. 1117768 Address comments by Mikhail Gryzykhin · 4 years, 4 months ago