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
al...@apache.org [2/2] beam git commit: This closes #3445 Tue, 27 Jun, 17:18
al...@apache.org [1/2] beam git commit: Use installed distribution name for sdk name Tue, 27 Jun, 19:29
al...@apache.org [2/2] beam git commit: This closes #3448 Tue, 27 Jun, 19:29
al...@apache.org [1/2] beam git commit: Add PubSub I/O support to Python DirectRunner Thu, 29 Jun, 16:46
al...@apache.org [2/2] beam git commit: This closes #3454 Thu, 29 Jun, 16:46
al...@apache.org [1/2] beam git commit: Use SDK harness container for FnAPI jobs when worker_harness_container_image is not specified. Add a separate image tag to use with the SDK harness container. Thu, 29 Jun, 17:36
al...@apache.org [2/2] beam git commit: This closes #3468 Thu, 29 Jun, 17:36
al...@apache.org [1/2] beam git commit: Select SDK distribution based on the selected SDK name Thu, 29 Jun, 19:46
al...@apache.org [2/2] beam git commit: This closes #3474 Thu, 29 Jun, 19:46
antonymayi [GitHub] beam pull request #3450: [BEAM-2522] upgrading jackson to 2.8.9 (mitigating ... Tue, 27 Jun, 14:55
antonymayi [GitHub] beam pull request #3450: [BEAM-2522] upgrading jackson to 2.8.9 (mitigating ... Tue, 27 Jun, 16:09
antonymayi [GitHub] beam pull request #3451: [BEAM-2522] upgrading jackson to 2.8.9 (mitigating ... Tue, 27 Jun, 16:14
app-tarush [GitHub] beam pull request #3301: Beam-2383 round function Tue, 06 Jun, 05:04
app-tarush [GitHub] beam pull request #3236: Beam-2329 ABS function Tue, 06 Jun, 09:51
app-tarush [GitHub] beam pull request #3301: Beam-2383 round function Thu, 08 Jun, 06:17
app-tarush [GitHub] beam pull request #3326: Beam-2383 Round function Thu, 08 Jun, 06:48
app-tarush [GitHub] beam pull request #3175: Beam-2171 power function Fri, 09 Jun, 16:05
app-tarush [GitHub] beam pull request #3336: Beam-2171 Power function Fri, 09 Jun, 16:07
app-tarush [GitHub] beam pull request #3326: Beam-2383 Round function Fri, 16 Jun, 17:14
app-tarush [GitHub] beam pull request #3386: Beam-2424 Cast Operator Sat, 17 Jun, 08:20
app-tarush [GitHub] beam pull request #3387: Beam-2461 Ln function Sun, 18 Jun, 17:14
app-tarush [GitHub] beam pull request #3400: Beam-2480 ACOS, ASIN, ATAN, COS, COT, DEGREES, RADI... Tue, 20 Jun, 09:11
app-tarush [GitHub] beam pull request #3387: Beam-2461 Ln function Thu, 22 Jun, 06:08
app-tarush [GitHub] beam pull request #3400: Beam-2480 ACOS, ASIN, ATAN, COS, COT, DEGREES, RADI... Mon, 26 Jun, 05:41
asfgit [GitHub] beam pull request #3251: Rename class Logger object names to the standard co... Thu, 01 Jun, 12:01
asfgit [GitHub] beam pull request #3261: Rephrases messages on RetryHttpRequestInitializer Thu, 01 Jun, 15:21
asfgit [GitHub] beam pull request #3230: [BEAM-2367] Add template examples to snippets.py Thu, 01 Jun, 16:30
asfgit [GitHub] beam pull request #3278: fix python lint errors Thu, 01 Jun, 18:17
asfgit [GitHub] beam pull request #3274: [BEAM-2371] Add WriteFiles translation Thu, 01 Jun, 18:33
asfgit [GitHub] beam pull request #3264: Fetch only relevant PR Thu, 01 Jun, 21:51
asfgit [GitHub] beam pull request #3280: [BEAM-2371] Add GroupByKey translation Thu, 01 Jun, 22:57
asfgit [GitHub] beam pull request #3271: [BEAM-1348] Add Runner API constructs to ProcessBun... Fri, 02 Jun, 13:56
asfgit [GitHub] beam pull request #3222: [BEAM-115] Unify Java and Python WindowingStrategy ... Fri, 02 Jun, 16:17
asfgit [GitHub] beam pull request #3267: [BEAM-2378] support FULL OUTER JOIN Fri, 02 Jun, 17:01
asfgit [GitHub] beam pull request #3265: Property names cleanup Fri, 02 Jun, 18:33
asfgit [GitHub] beam pull request #1609: BEAM-1151 Add failure handling to BigQueryIO.Write Fri, 02 Jun, 20:54
asfgit [GitHub] beam pull request #3165: [BEAM-2305] Allow the Distinct transform to dedupli... Fri, 02 Jun, 22:46
asfgit [GitHub] beam pull request #2917: [BEAM-2175] [BEAM-1115] Support for new State and T... Sat, 03 Jun, 14:43
asfgit [GitHub] beam pull request #3284: [BEAM-2401] Update Flink Runner to Flink 1.3.0 Sun, 04 Jun, 06:31
asfgit [GitHub] beam pull request #3245: Flink runner: specify CheckpointingMode and Checkpo... Sun, 04 Jun, 08:20
asfgit [GitHub] beam pull request #3283: [BEAM-3271] Add TestStream translation Mon, 05 Jun, 04:48
asfgit [GitHub] beam pull request #3293: [BEAM-2406] Fix NullPointerException when writing a... Mon, 05 Jun, 17:13
asfgit [GitHub] beam pull request #3272: [BEAM-1938] Remove the requirement to visit PCollec... Mon, 05 Jun, 17:20
asfgit [GitHub] beam pull request #2657: [BEAM-2058] Generate BigQuery load job at runtime Mon, 05 Jun, 18:10
asfgit [GitHub] beam pull request #3297: [BEAM-1347] Migrate to Runner API constructs within... Mon, 05 Jun, 20:07
asfgit [GitHub] beam pull request #3296: [BEAM-1347] Add additional logging Mon, 05 Jun, 22:04
asfgit [GitHub] beam pull request #3281: [BEAM-3271] Add CreatePCollectionView translation Tue, 06 Jun, 03:06
asfgit [GitHub] beam-site pull request #249: [BEAM-1158]HCatalog example using HadoopIputFor... Tue, 06 Jun, 07:39
asfgit [GitHub] beam pull request #3232: [BEAM-2276] Cleanups to windowed DefaultFilenamePol... Tue, 06 Jun, 12:09
asfgit [GitHub] beam pull request #3290: [BEAM-1498] Use Flink-native side outputs Tue, 06 Jun, 13:29
asfgit [GitHub] beam pull request #3289: Flink runner: support MapState in FlinkStateInterna... Tue, 06 Jun, 15:21
asfgit [GitHub] beam pull request #3279: Do not fail when gen_protos cannot be imported Tue, 06 Jun, 19:59
asfgit [GitHub] beam pull request #3282: [BEAM-3271] Improve Splittable ParDo translation Tue, 06 Jun, 20:28
asfgit [GitHub] beam pull request #3299: Migrate Python tests to not depend on fix sharding ... Tue, 06 Jun, 20:56
asfgit [GitHub] beam pull request #3305: [BEAM-1265] soft-enable the use of streaming flag Tue, 06 Jun, 20:57
asfgit [GitHub] beam pull request #3288: [BEAM-2405] Write to BQ using the streaming API Tue, 06 Jun, 21:06
asfgit [GitHub] beam pull request #3304: Whitelist find for tox environments Tue, 06 Jun, 21:14
asfgit [GitHub] beam pull request #3298: [BEAM-2394] Support concurrent execution of Spanner... Tue, 06 Jun, 22:45
asfgit [GitHub] beam pull request #3308: Fix imports in sdk_worker. Tue, 06 Jun, 23:13
asfgit [GitHub] beam pull request #3300: Fix the staging directory path in copying from GCS Tue, 06 Jun, 23:44
asfgit [GitHub] beam pull request #3307: Increase visibility of some Metrics methods Wed, 07 Jun, 03:08
asfgit [GitHub] beam pull request #3306: [BEAM-2405] Override to sink interface in batch dat... Wed, 07 Jun, 05:18
asfgit [GitHub] beam pull request #592: [BEAM-245] Add Cassandra IO Wed, 07 Jun, 06:05
asfgit [GitHub] beam pull request #3310: [BEAM-1231] Add missed "kind:bytes" to CloudObjectK... Wed, 07 Jun, 16:02
asfgit [GitHub] beam pull request #2286: [BEAM-1779] Port UnboundedSourceWrapperTest to use ... Wed, 07 Jun, 17:50
asfgit [GitHub] beam pull request #3312: [BEAM-2421] Swap to use an Impulse primitive + DoFn... Wed, 07 Jun, 20:48
asfgit [GitHub] beam pull request #3294: Shutdown Flink Streaming Pipeline when reaching +In... Wed, 07 Jun, 21:19
asfgit [GitHub] beam pull request #3314: sync-up DSL_SQL from Master Thu, 08 Jun, 01:35
asfgit [GitHub] beam pull request #3321: Remove support for NativeSinks from the Python Dire... Thu, 08 Jun, 01:46
asfgit [GitHub] beam pull request #3316: Make BytesCoder to be a known type Thu, 08 Jun, 03:09
asfgit [GitHub] beam pull request #3317: python pubsub io fixes for streaming Thu, 08 Jun, 05:55
asfgit [GitHub] beam pull request #3323: upgrade to 2.1.0-SNAPSHOT Thu, 08 Jun, 11:44
asfgit [GitHub] beam pull request #3303: [BEAM-2364] Expand all PValues to component PCollec... Thu, 08 Jun, 16:14
asfgit [GitHub] beam pull request #3324: Avoid flakiness in data channel for empty streams. Thu, 08 Jun, 17:09
asfgit [GitHub] beam pull request #3322: Refine Python DirectRunner watermark advancement be... Thu, 08 Jun, 17:56
asfgit [GitHub] beam pull request #3302: [BEAM-991] Raise entities limit per RPC to 9MB. Thu, 08 Jun, 17:57
asfgit [GitHub] beam pull request #3239: [BEAM-2371] Port DirectRunner override matchers to ... Thu, 08 Jun, 19:01
asfgit [GitHub] beam pull request #3325: Use inner module for non-public coders. Thu, 08 Jun, 20:59
asfgit [GitHub] beam pull request #3220: [BEAM-2357]HiveIO implementation using native API -... Thu, 08 Jun, 21:08
asfgit [GitHub] beam pull request #3331: Slight debuggability improvements in BigtableIO Thu, 08 Jun, 22:29
asfgit [GitHub] beam pull request #3315: Move Runner API protos to portability/runners/api Thu, 08 Jun, 22:30
asfgit [GitHub] beam pull request #3328: [BEAM-2410] Remove TransportClient from ElasticSear... Fri, 09 Jun, 05:31
asfgit [GitHub] beam-site pull request #251: [BEAM-2360] Add Beam Runner Guide Fri, 09 Jun, 16:52
asfgit [GitHub] beam pull request #3320: Fix Flink compile error occurs in some JDK versions Fri, 09 Jun, 18:33
asfgit [GitHub] beam pull request #3332: Use beam.Map rather than beam.ParDo for PubSub enco... Fri, 09 Jun, 20:01
asfgit [GitHub] beam pull request #3329: Visit a Transform Hierarchy in Topological Order Fri, 09 Jun, 21:59
asfgit [GitHub] beam pull request #3337: Include Additional PTransform Inputs in Transform N... Fri, 09 Jun, 22:30
asfgit [GitHub] beam-site pull request #255: Update IO with CassandraIO Sat, 10 Jun, 00:20
asfgit [GitHub] beam pull request #3338: [BEAM-2371] Port some DirectRunner overrides to SDK... Sat, 10 Jun, 03:14
asfgit [GitHub] beam pull request #3292: [BEAM-79] Merge master into gearpump-runner Mon, 12 Jun, 16:55
asfgit [GitHub] beam pull request #3313: [BEAM-2423] Abstract StateInternalsTest for the dif... Mon, 12 Jun, 20:36
asfgit [GitHub] beam pull request #3346: Reverse removal of NativeWrite evaluator in Python ... Mon, 12 Jun, 22:44
asfgit [GitHub] beam pull request #3345: Cleanups to CombineTest Mon, 12 Jun, 22:49
asfgit [GitHub] beam pull request #3347: Check for Deferral on Non-additional inputs Tue, 13 Jun, 03:21
asfgit [GitHub] beam pull request #3327: [BEAM-2412] Update HBaseIO to use HBase client 1.2.... Tue, 13 Jun, 05:59
asfgit [GitHub] beam pull request #3309: [BEAM-1483] Support SetState in Flink runner Tue, 13 Jun, 09:45
asfgit [GitHub] beam pull request #3339: Actually test the fn_api_runner. Tue, 13 Jun, 15:57
asfgit [GitHub] beam pull request #3341: [BEAM-1319] Make unique test names for value-provid... Tue, 13 Jun, 16:35
asfgit [GitHub] beam pull request #3350: Fix WindowValueCoder for large timestamps Tue, 13 Jun, 17:12
asfgit [GitHub] beam pull request #3333: [BEAM-1630] Adds ability to dynamically replace PTr... Tue, 13 Jun, 18:48
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