| al...@apache.org |
[beam] branch master updated: Fix traceback.format_exc(e) call |
Wed, 02 Oct, 20:49 |
| al...@apache.org |
[beam] branch master updated (b1fe782 -> daa36e7) |
Fri, 04 Oct, 16:29 |
| al...@apache.org |
[beam] branch master updated: Update capability-matrix.yml |
Fri, 04 Oct, 16:30 |
| al...@apache.org |
[beam] branch master updated: Update fixed and sliding window examples to be consistent with the figures |
Fri, 04 Oct, 16:45 |
| al...@apache.org |
[beam] branch master updated: [BEAM-7389] Update include buttons to support multiple languages |
Fri, 04 Oct, 17:05 |
| al...@apache.org |
[beam] branch master updated: [BEAM-7389] Created elementwise for consistency with docs |
Fri, 04 Oct, 22:29 |
| al...@apache.org |
[beam] branch master updated (50c5281 -> f857f0f) |
Fri, 04 Oct, 22:38 |
| al...@apache.org |
[beam] branch master updated: Custom container docs |
Mon, 07 Oct, 19:58 |
| al...@apache.org |
svn commit: r36238 - in /release/beam: ./ 2.16.0/ 2.16.0/python/ |
Mon, 07 Oct, 21:16 |
| al...@apache.org |
[beam] branch master updated: Fix closing region tags |
Mon, 07 Oct, 21:26 |
| al...@apache.org |
[beam] branch master updated (6a3c008 -> 820bb29) |
Tue, 08 Oct, 00:35 |
| al...@apache.org |
[beam] branch master updated (b288d5a -> 9b372d6) |
Fri, 11 Oct, 16:42 |
| al...@apache.org |
[beam] branch master updated: [BEAM-8368] Add a <0.14.0 bound for pyarrow |
Mon, 14 Oct, 18:27 |
| al...@apache.org |
[beam] branch master updated: [BEAM-7389] Remove old element-wise snippets directory |
Mon, 14 Oct, 18:33 |
| al...@apache.org |
[beam] branch aaltay-patch-1 created (now 971da36) |
Tue, 15 Oct, 00:29 |
| al...@apache.org |
[beam] branch aaltay-patch-2 created (now a5f9d85) |
Tue, 15 Oct, 00:35 |
| al...@apache.org |
[beam] 01/01: Fixing a logging bug in auth |
Tue, 15 Oct, 00:35 |
| al...@apache.org |
[beam] branch master updated (1b01d91 -> e43c3cd) |
Tue, 22 Oct, 17:31 |
| al...@apache.org |
[beam] branch master updated (b3e55a3 -> 4fa1501) |
Tue, 22 Oct, 20:15 |
| al...@apache.org |
[beam] branch revert-9854-BEAM-8457 created (now 1d59072) |
Fri, 25 Oct, 00:26 |
| al...@apache.org |
[beam] 01/01: Revert "Merge pull request #9854 from [BEAM-8457] Label Dataflow jobs from Notebook" |
Fri, 25 Oct, 00:26 |
| al...@apache.org |
[beam] branch master updated (a9cace3 -> 177c134) |
Fri, 25 Oct, 00:43 |
| al...@apache.org |
[beam] branch master updated (90460b4 -> 9a9b5f4) |
Fri, 25 Oct, 15:24 |
| al...@apache.org |
[beam] branch master updated (90460b4 -> 9a9b5f4) |
Fri, 25 Oct, 15:24 |
| amaliu...@apache.org |
[beam] branch master updated: [BEAM-7073]: Add unit test for Avro logical type datum. |
Mon, 14 Oct, 20:04 |
| apill...@apache.org |
[beam] branch master updated (c1fa9b1 -> b4cd1d6) |
Wed, 02 Oct, 19:00 |
| apill...@apache.org |
[beam] branch master updated (dae22d0 -> b01cc60) |
Thu, 03 Oct, 16:42 |
| apill...@apache.org |
[beam] branch master updated (5a7bd66 -> 77f047b) |
Mon, 07 Oct, 16:34 |
| apill...@apache.org |
[beam] branch master updated (be5753d -> 5d83b15) |
Mon, 07 Oct, 21:41 |
| apill...@apache.org |
[beam] branch master updated (6b1fc06 -> 0cb56a2) |
Thu, 10 Oct, 15:28 |
| apill...@apache.org |
[beam] branch master updated (8543801 -> 1c0ab42) |
Mon, 14 Oct, 17:09 |
| apill...@apache.org |
[beam] branch master updated (8b475bc -> d2f974c) |
Tue, 15 Oct, 16:28 |
| apill...@apache.org |
[beam] branch master updated (0ff53f1 -> ab4d995) |
Tue, 15 Oct, 17:33 |
| apill...@apache.org |
[beam] branch master updated (0ff53f1 -> ab4d995) |
Tue, 15 Oct, 17:34 |
| apill...@apache.org |
[beam] branch master updated (432e17f -> f1aee7c) |
Thu, 17 Oct, 16:55 |
| apill...@apache.org |
[beam] branch master updated (432e17f -> f1aee7c) |
Thu, 17 Oct, 16:56 |
| apill...@apache.org |
[beam] branch master updated (0d4bf60 -> e4aab40) |
Mon, 21 Oct, 21:57 |
| apill...@apache.org |
[beam] branch master updated (73642eb -> 9f8fdd1) |
Fri, 25 Oct, 18:37 |
| apill...@apache.org |
[beam] branch master updated (73642eb -> 9f8fdd1) |
Fri, 25 Oct, 18:38 |
| apill...@apache.org |
[beam] branch master updated (9ffa665 -> c8bed1c) |
Tue, 29 Oct, 22:38 |
| apill...@apache.org |
[beam] branch master updated (bb4f85a -> a23d704) |
Wed, 30 Oct, 18:20 |
| aromane...@apache.org |
[beam] branch master updated (c1007b6 -> 710d400) |
Tue, 01 Oct, 12:55 |
| aromane...@apache.org |
[beam] branch master updated (a834ab3 -> e065ce8) |
Mon, 21 Oct, 10:08 |
| aromane...@apache.org |
[beam] branch master updated (7047a05 -> ff36841) |
Tue, 29 Oct, 11:31 |
| boyu...@apache.org |
[beam] branch master updated (5e94175 -> d9add56) |
Thu, 17 Oct, 19:54 |
| boyu...@apache.org |
[beam] branch master updated (5e94175 -> d9add56) |
Thu, 17 Oct, 19:55 |
| boyu...@apache.org |
[beam] branch master updated: Not inject pubsub into Impulse when in fnapi streaming mode. |
Thu, 31 Oct, 05:18 |
| chamik...@apache.org |
[beam] branch master updated (e9c7f99 -> 73642eb) |
Fri, 25 Oct, 18:00 |
| echauc...@apache.org |
[beam] branch spark-runner_structured-streaming updated (d093ffe -> ee2c0e6) |
Thu, 10 Oct, 15:48 |
| echauc...@apache.org |
[beam] 01/04: Create a Tuple2Coder to encode scale tuple2 |
Thu, 10 Oct, 15:48 |
| echauc...@apache.org |
[beam] 02/04: Apply new Encoders to GroupByKey |
Thu, 10 Oct, 15:48 |
| echauc...@apache.org |
[beam] 03/04: Apply new Encoders to Pardo. Replace Tuple2Coder with MultiOutputCoder to deal with multiple output to use in Spark Encoder for DoFnRunner |
Thu, 10 Oct, 15:49 |
| echauc...@apache.org |
[beam] 04/04: Apply spotless |
Thu, 10 Oct, 15:49 |
| echauc...@apache.org |
[beam] branch spark-runner_structured-streaming updated (ee2c0e6 -> c980d4c) |
Fri, 18 Oct, 08:27 |
| echauc...@apache.org |
[beam] 01/02: Add missing windowedValue Encoder call in Pardo |
Fri, 18 Oct, 08:27 |
| echauc...@apache.org |
[beam] 02/02: Fix typo |
Fri, 18 Oct, 08:27 |
| echauc...@apache.org |
[beam] branch spark-runner_structured-streaming updated (ee2c0e6 -> c980d4c) |
Fri, 18 Oct, 08:28 |
| echauc...@apache.org |
[beam] 01/02: Add missing windowedValue Encoder call in Pardo |
Fri, 18 Oct, 08:28 |
| echauc...@apache.org |
[beam] 02/02: Fix typo |
Fri, 18 Oct, 08:28 |
| echauc...@apache.org |
[beam] branch master updated: Fix javadoc of Pardo |
Mon, 21 Oct, 08:19 |
| echauc...@apache.org |
[beam] branch master updated: Fix javadoc of Pardo |
Mon, 21 Oct, 08:20 |
| echauc...@apache.org |
[beam] branch master updated (6df727b -> d577262) |
Mon, 21 Oct, 15:09 |
| echauc...@apache.org |
[beam] branch spark-runner_structured-streaming updated (c980d4c -> 46ed555) |
Wed, 23 Oct, 12:12 |
| echauc...@apache.org |
[beam] 01/05: Fix javadoc |
Wed, 23 Oct, 12:12 |
| echauc...@apache.org |
[beam] 02/05: Use beam encoders also in the output of the source translation |
Wed, 23 Oct, 12:12 |
| echauc...@apache.org |
[beam] 03/05: Remove unneeded cast |
Wed, 23 Oct, 12:12 |
| echauc...@apache.org |
[beam] 04/05: Fix: Remove generic hack of using object. Use actual Coder encodedType in Encoders |
Wed, 23 Oct, 12:12 |
| echauc...@apache.org |
[beam] 05/05: Remove Encoders based on kryo now that we call Beam coders in the runner |
Wed, 23 Oct, 12:12 |
| echauc...@apache.org |
[beam] branch master updated (9f27a1d -> 20b6913) |
Thu, 24 Oct, 08:11 |
| echauc...@apache.org |
[beam] branch master updated (9f27a1d -> 20b6913) |
Thu, 24 Oct, 08:12 |
| echauc...@apache.org |
[beam] branch spark-runner_structured-streaming updated (46ed555 -> 620a27a) |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 01/37: Improve Pardo translation performance: avoid calling a filter transform when there is only one output tag |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 02/37: Use "sparkMaster" in local mode to obtain number of shuffle partitions + spotless apply |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 03/37: Wrap Beam Coders into Spark Encoders using ExpressionEncoder: serialization part |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 04/37: Wrap Beam Coders into Spark Encoders using ExpressionEncoder: deserialization part |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 05/37: type erasure: spark encoders require a Class<T>, pass Object and cast to Class<T> |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 06/37: Fix scala Product in Encoders to avoid StackEverflow |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 07/37: Conform to spark ExpressionEncoders: pass classTags, implement scala Product, pass children from within the ExpressionEncoder, fix visibilities |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 08/37: Add a simple spark native test to test Beam coders wrapping into Spark Encoders |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 09/37: Fix code generation in Beam coder wrapper |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 10/37: Lazy init coder because coder instance cannot be interpolated by catalyst |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 11/37: Fix warning in coder construction by reflexion |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 12/37: Fix ExpressionEncoder generated code: typos, try catch, fqcn |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 13/37: Fix getting the output value in code generation |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 14/37: Fix beam coder lazy init using reflexion: use .clas + try catch + cast |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 15/37: Remove lazy init of beam coder because there is no generic way on instanciating a beam coder |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 16/37: Remove example code |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 17/37: Fix equal and hashcode |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 18/37: Fix generated code: uniform exceptions catching, fix parenthesis and variable declarations |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 19/37: Add an assert of equality in the encoders test |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 20/37: Apply spotless and checkstyle and add javadocs |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 21/37: Wrap exceptions in UserCoderExceptions |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 22/37: Put Encoders expressions serializable |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 23/37: Catch Exception instead of IOException because some coders to not throw Exceptions at all (e.g.VoidCoder) |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 24/37: Apply new Encoders to CombinePerKey |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 25/37: Apply new Encoders to Read source |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 26/37: Improve performance of source: the mapper already calls windowedValueCoder.decode, no need to call it also in the Spark encoder |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 27/37: Ignore long time failing test: SparkMetricsSinkTest |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 28/37: Apply new Encoders to Window assign translation |
Thu, 24 Oct, 10:08 |
| echauc...@apache.org |
[beam] 29/37: Apply new Encoders to AggregatorCombiner |
Thu, 24 Oct, 10:08 |