beam-commits mailing list archives: June 2017

Site index · List index
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · Next »Thread · Author · Date
asfgit [GitHub] beam pull request #3472: Get rid of Apache Commons dependency Fri, 30 Jun, 03:38
asfgit [GitHub] beam pull request #3469: Properly convert milliseconds whether there's less ... Fri, 30 Jun, 16:00
asfgit [GitHub] beam pull request #3479: [BEAM-79] Merge master into gearpump-runner branch Fri, 30 Jun, 21:31
asfgit [GitHub] beam pull request #3355: [BEAM-1287] Add support for PipelineOptions paramet... Fri, 30 Jun, 23:04
aviemzur [GitHub] beam pull request #3343: [BEAM-2359] Fix watermark broadcasting to executors... Mon, 12 Jun, 14:06
aviem...@apache.org [1/2] beam git commit: [BEAM-2175] [BEAM-1115] Support for new State and Timer API in Spark batch mode Sat, 03 Jun, 14:43
aviem...@apache.org [2/2] beam git commit: This closes #2917 Sat, 03 Jun, 14:43
aviem...@apache.org [1/3] beam git commit: Move Spark runner streaming tests to post commit. Thu, 22 Jun, 12:33
aviem...@apache.org [2/3] beam git commit: [BEAM-2359] Fix watermark broadcasting to executors in Spark runner Thu, 22 Jun, 12:33
aviem...@apache.org [3/3] beam git commit: This closes #3343 Thu, 22 Jun, 12:33
bjchambers [GitHub] beam pull request #3307: Increase visibility of some Metrics methods Tue, 06 Jun, 22:10
chamik...@apache.org [1/2] beam git commit: [BEAM-2405] Write to BQ using the streaming API Tue, 06 Jun, 21:05
chamik...@apache.org [2/2] beam git commit: This closes #3288 Tue, 06 Jun, 21:05
chamik...@apache.org [1/2] beam git commit: [BEAM-2405] Override to sink interface in the batch dataflow BQ Wed, 07 Jun, 05:17
chamik...@apache.org [2/2] beam git commit: This closes #3306 Wed, 07 Jun, 05:17
chamik...@apache.org [1/2] beam git commit: Move Runner API protos to portability/runners/api Thu, 08 Jun, 22:30
chamik...@apache.org [2/2] beam git commit: This closes #3315 Thu, 08 Jun, 22:30
chamik...@apache.org [1/2] beam git commit: Adds ability to dynamically replace PTransforms during runtime. Tue, 13 Jun, 18:47
chamik...@apache.org [2/2] beam git commit: This closes #3333 Tue, 13 Jun, 18:47
chamik...@apache.org [1/2] beam git commit: Python streaming Create override as a composite of Impulse and a DoFn Mon, 19 Jun, 17:22
chamik...@apache.org [2/2] beam git commit: This closes #3349 Mon, 19 Jun, 17:22
chamik...@apache.org [1/2] beam git commit: Fix dataflow runner test to call pipeline.run instead of runner.run Tue, 20 Jun, 20:33
chamik...@apache.org [2/2] beam git commit: This closes #3393 Tue, 20 Jun, 20:33
chamik...@apache.org [1/2] beam git commit: Remove GroupedShuffleRangeTracker which is unused in the SDK Wed, 21 Jun, 21:06
chamik...@apache.org [2/2] beam git commit: This closes #3414 Wed, 21 Jun, 21:06
chamik...@apache.org [1/2] beam git commit: [BEAM-2497] Fix the reading of concat gzip files Fri, 23 Jun, 05:13
chamik...@apache.org [2/2] beam git commit: This closes #3428 Fri, 23 Jun, 05:13
chamikaramj [GitHub] beam pull request #3333: [BEAM-1630] Adds ability to dynamically replace PTr... Thu, 08 Jun, 22:07
chamikaramj [GitHub] beam pull request #3414: [BEAM-2494] Remove GroupedShuffleRangeTracker which... Wed, 21 Jun, 17:38
charlesccychen [GitHub] beam pull request #3299: Migrate Python tests to not depend on fix sharding ... Mon, 05 Jun, 23:36
charlesccychen [GitHub] beam pull request #3315: Move Runner API protos to portability/runners/api Wed, 07 Jun, 23:29
charlesccychen [GitHub] beam pull request #3318: Choose GroupAlsoByWindows implementation based on s... Wed, 07 Jun, 23:34
charlesccychen [GitHub] beam pull request #3321: Remove support for NativeSinks from the Python Dire... Thu, 08 Jun, 00:03
charlesccychen [GitHub] beam pull request #3322: Refine Python DirectRunner watermark advancement be... Thu, 08 Jun, 00:52
charlesccychen [GitHub] beam pull request #3346: Reverse removal of NativeWrite evaluator in Python ... Mon, 12 Jun, 21:18
charlesccychen [GitHub] beam pull request #3354: Move Runner API protos to portability/api Tue, 13 Jun, 22:06
charlesccychen [GitHub] beam pull request #3362: Migrate DirectRunner evaluators to use Beam state A... Wed, 14 Jun, 23:17
charlesccychen [GitHub] beam pull request #3370: Introduce pending bundles and RootBundleProvider in... Thu, 15 Jun, 21:37
charlesccychen [GitHub] beam pull request #3373: Populate PBegin input when decoding from Runner API Thu, 15 Jun, 22:29
charlesccychen [GitHub] beam pull request #3405: Use state / timer API for DirectRunner timer firing... Tue, 20 Jun, 22:23
charlesccychen [GitHub] beam pull request #3409: Allow production of unprocessed bundles, introduce ... Wed, 21 Jun, 00:19
charlesccychen [GitHub] beam pull request #3423: Clean up test_stream_test and remove stray print st... Thu, 22 Jun, 18:32
charlesccychen [GitHub] beam pull request #3440: Remove old deprecated PubSub code Mon, 26 Jun, 20:01
charlesccychen [GitHub] beam pull request #3444: Implement streaming GroupByKey in Python DirectRunn... Tue, 27 Jun, 00:10
charlesccychen [GitHub] beam pull request #3454: Add PubSub I/O support to Python DirectRunner Tue, 27 Jun, 22:32
cph6 [GitHub] beam pull request #3302: [BEAM-991] Raise entities limit per RPC to 9MB. Tue, 06 Jun, 12:56
cph6 [GitHub] beam pull request #3390: [BEAM-2439] Dynamic sizing of Datastore write RPCs Mon, 19 Jun, 10:42
davidcavazos [GitHub] beam pull request #3483: [BEAM-2484] Add Python mobile gaming streaming exam... Fri, 30 Jun, 20:59
da...@apache.org [1/2] beam git commit: Fetch only relevant PR Thu, 01 Jun, 21:51
da...@apache.org [2/2] beam git commit: This closes #3264 Thu, 01 Jun, 21:51
da...@apache.org [1/2] beam git commit: [BEAM-2378] support FULL OUTER JOIN Fri, 02 Jun, 17:01
da...@apache.org [2/2] beam git commit: This closes #3267 Fri, 02 Jun, 17:01
da...@apache.org [1/2] beam git commit: Generate a random table name. Assume Spanner database exists. Tue, 06 Jun, 22:45
da...@apache.org [2/2] beam git commit: This closes #3298 Tue, 06 Jun, 22:45
da...@apache.org [01/50] beam git commit: [BEAM-1347] Add additional logging Thu, 08 Jun, 01:34
da...@apache.org [02/50] beam git commit: [BEAM-1347] Add additional logging Thu, 08 Jun, 01:34
da...@apache.org [03/50] beam git commit: Add CreatePCollectionView translation Thu, 08 Jun, 01:34
da...@apache.org [04/50] beam git commit: Clarify javadoc on PTransformTranslation Thu, 08 Jun, 01:34
da...@apache.org [05/50] beam git commit: This closes #3281: [BEAM-3271] Add CreatePCollectionView translation Thu, 08 Jun, 01:34
da...@apache.org [06/50] beam git commit: [BEAM-2276] Cleanups on the windowed DefaultFilenamePolicy Thu, 08 Jun, 01:34
da...@apache.org [07/50] beam git commit: [BEAM-2276] This closes #3232 Thu, 08 Jun, 01:34
da...@apache.org [08/50] beam git commit: Remove the FnOutputT parameter from DoFnOperator Thu, 08 Jun, 01:34
da...@apache.org [09/50] beam git commit: [BEAM-1498] Use Flink-native side outputs Thu, 08 Jun, 01:34
da...@apache.org [10/50] beam git commit: This closes #3290 Thu, 08 Jun, 01:34
da...@apache.org [11/50] beam git commit: Flink runner: support MapState in FlinkStateInternals. Thu, 08 Jun, 01:35
da...@apache.org [12/50] beam git commit: This closes #3289 Thu, 08 Jun, 01:35
da...@apache.org [13/50] beam git commit: Do not fail when gen_protos cannot be imported Thu, 08 Jun, 01:35
da...@apache.org [14/50] beam git commit: This closes #3279 Thu, 08 Jun, 01:35
da...@apache.org [15/50] beam git commit: Fix RawPTransform translation Thu, 08 Jun, 01:35
da...@apache.org [16/50] beam git commit: Improve Splittable ParDo translation Thu, 08 Jun, 01:35
da...@apache.org [17/50] beam git commit: This closes #3282: [BEAM-3271] Improve Splittable ParDo translation Thu, 08 Jun, 01:35
da...@apache.org [18/50] beam git commit: Migrate Python tests to not depend on fix sharding for file output Thu, 08 Jun, 01:35
da...@apache.org [19/50] beam git commit: This closes #3299 Thu, 08 Jun, 01:35
da...@apache.org [20/50] beam git commit: soft-enable the use of streaming flag Thu, 08 Jun, 01:35
da...@apache.org [21/50] beam git commit: This closes #3305 Thu, 08 Jun, 01:35
da...@apache.org [22/50] beam git commit: [BEAM-2405] Write to BQ using the streaming API Thu, 08 Jun, 01:35
da...@apache.org [23/50] beam git commit: This closes #3288 Thu, 08 Jun, 01:35
da...@apache.org [24/50] beam git commit: Whitelist find for tox environments Thu, 08 Jun, 01:35
da...@apache.org [25/50] beam git commit: This closes #3304 Thu, 08 Jun, 01:35
da...@apache.org [26/50] beam git commit: Increase visibility of some Metrics methods Thu, 08 Jun, 01:35
da...@apache.org [27/50] beam git commit: Generate a random table name. Assume Spanner database exists. Thu, 08 Jun, 01:35
da...@apache.org [28/50] beam git commit: This closes #3298 Thu, 08 Jun, 01:35
da...@apache.org [29/50] beam git commit: Fix imports in sdk_worker. Thu, 08 Jun, 01:35
da...@apache.org [30/50] beam git commit: This closes #3308 Thu, 08 Jun, 01:35
da...@apache.org [31/50] beam git commit: Fix the staging directory path in copying from GCS Thu, 08 Jun, 01:35
da...@apache.org [32/50] beam git commit: This closes #3300 Thu, 08 Jun, 01:35
da...@apache.org [33/50] beam git commit: This closes #3307: Increase visibility of some Metrics methods Thu, 08 Jun, 01:35
da...@apache.org [34/50] beam git commit: [BEAM-2405] Override to sink interface in the batch dataflow BQ Thu, 08 Jun, 01:35
da...@apache.org [35/50] beam git commit: This closes #3306 Thu, 08 Jun, 01:35
da...@apache.org [36/50] beam git commit: [BEAM-245] Add CassandraIO Thu, 08 Jun, 01:35
da...@apache.org [37/50] beam git commit: [BEAM-245] This closes #592 Thu, 08 Jun, 01:35
da...@apache.org [38/50] beam git commit: Sort IO by alphanumeric order Thu, 08 Jun, 01:35
da...@apache.org [39/50] beam git commit: [BEAM-1231] Add missed "kind:bytes" to CloudObjectKinds/CloudObjectTranslators Thu, 08 Jun, 01:35
da...@apache.org [40/50] beam git commit: [BEAM-1231] Add missed "kind:bytes" to CloudObjectKinds/CloudObjectTranslators Thu, 08 Jun, 01:35
da...@apache.org [41/50] beam git commit: [BEAM-2407] Fix Flink CoderTyperSerializer ConfigSnapshot Thu, 08 Jun, 01:35
da...@apache.org [42/50] beam git commit: [BEAM-1779] Port UnboundedSourceWrapperTest to use Flink operator test harness Thu, 08 Jun, 01:35
da...@apache.org [43/50] beam git commit: [BEAM-2408] Fix watermark emission in Flink UnboundedSourceWrapper Thu, 08 Jun, 01:35
da...@apache.org [44/50] beam git commit: This closes #2286 Thu, 08 Jun, 01:35
da...@apache.org [45/50] beam git commit: This closes #2286 Thu, 08 Jun, 01:35
da...@apache.org [46/50] beam git commit: [BEAM-2421] Swap to use an Impulse primitive + DoFn for Create when executing with the Fn API. Thu, 08 Jun, 01:35
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · Next »Thread · Author · Date
Box list
Jan 2020292
Dec 2019281
Nov 2019299
Oct 2019545
Sep 2019348
Aug 2019351
Jul 2019387
Jun 2019332
May 2019464
Apr 2019336
Mar 2019259
Feb 2019367
Jan 2019518
Dec 2018368
Nov 2018448
Oct 20184197
Sep 20184689
Aug 20184453
Jul 20184320
Jun 20186163
May 20185547
Apr 20185962
Mar 20184479
Feb 20181955
Jan 20182670
Dec 20171428
Nov 20172364
Oct 20171972
Sep 20172095
Aug 20172291
Jul 20172998
Jun 20172879
May 20175577
Apr 20175171
Mar 20174068
Feb 20172908
Jan 20171848
Dec 20163374
Nov 20162900
Oct 20162712
Sep 20161298
Aug 20161500
Jul 20161550
Jun 20161725
May 20161092
Apr 20161731
Mar 20161158
Feb 2016294