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
Paweł Kaczmarczyk (JIRA) [jira] [Commented] (BEAM-2468) Reading Kinesis records in the background Tue, 20 Jun, 06:28
Paweł Kaczmarczyk (JIRA) [jira] [Commented] (BEAM-2469) Handling Kinesis shards splits and merges Tue, 20 Jun, 06:28
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1585) Ability to add new file systems to beamFS in the python sdk Thu, 01 Jun, 01:00
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers Thu, 01 Jun, 04:00
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2193) JOIN: inner join, left join, right join, full outer join Thu, 01 Jun, 15:52
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2367) Add python examples to snippets.py Thu, 01 Jun, 16:31
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers Thu, 01 Jun, 18:34
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1158) Add HCatalog (Hive) example using HadoopInputFormatIO Thu, 01 Jun, 18:43
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers Thu, 01 Jun, 19:44
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers Thu, 01 Jun, 22:58
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2401) Update Flink Runner to Flink 1.3.0 Fri, 02 Jun, 05:21
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1348) Model the Fn Api Fri, 02 Jun, 13:57
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2314) Add ValidatesRunner test for custom merging windows Fri, 02 Jun, 15:24
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2314) Add ValidatesRunner test for custom merging windows Fri, 02 Jun, 15:29
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2375) upgrade beam-version to 2.0.0 Fri, 02 Jun, 16:16
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-115) Beam Runner API Fri, 02 Jun, 16:18
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2378) extend join-library to support FULL OUTER JOIN Fri, 02 Jun, 17:02
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1151) BigQueryIO.Write has no way of handling failures Fri, 02 Jun, 20:55
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2375) upgrade beam-version to 2.0.0 Fri, 02 Jun, 22:45
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2305) Dinstinct transform produces unexpected output when triggered Fri, 02 Jun, 22:47
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2405) Create a BigQuery sink for streaming using PTransform Fri, 02 Jun, 23:16
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2175) Support state API in Spark batch mode. Sat, 03 Jun, 14:44
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2401) Update Flink Runner to Flink 1.3.0 Sun, 04 Jun, 06:32
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1498) Use Flink-native side outputs Sun, 04 Jun, 14:05
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-79) Gearpump runner Mon, 05 Jun, 02:21
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2406) NullPointerException when writing an empty table to BigQuery Mon, 05 Jun, 05:21
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-593) Support unblocking run() in FlinkRunner and cancel() and waitUntilFinish() in FlinkRunnerResult Mon, 05 Jun, 11:35
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api Mon, 05 Jun, 16:32
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2406) NullPointerException when writing an empty table to BigQuery Mon, 05 Jun, 17:14
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1938) Side Inputs should be part of the expanded inputs Mon, 05 Jun, 17:21
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api Mon, 05 Jun, 18:07
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2058) BigQuery load job id should be generated at run time, not submission time Mon, 05 Jun, 18:10
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2394) Postcommit_Java_JDK_Version_Test is broken since SpannerWriteIT failed Mon, 05 Jun, 19:32
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api Mon, 05 Jun, 20:08
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api Mon, 05 Jun, 22:05
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2010) expose programming interface Mon, 05 Jun, 23:37
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1158) Add HCatalog (Hive) example using HadoopInputFormatIO Tue, 06 Jun, 07:39
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2276) make it easier to specify windowed filename policy Tue, 06 Jun, 12:09
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-991) DatastoreIO Write should flush early for large batches Tue, 06 Jun, 12:57
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1498) Use Flink-native side outputs Tue, 06 Jun, 13:29
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2364) PCollectionView should not be a PValue, it should expand to its underlying PCollection Tue, 06 Jun, 17:30
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1265) Add streaming support to Python DirectRunner Tue, 06 Jun, 20:38
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1265) Add streaming support to Python DirectRunner Tue, 06 Jun, 20:58
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2405) Create a BigQuery sink for streaming using PTransform Tue, 06 Jun, 21:06
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2405) Create a BigQuery sink for streaming using PTransform Tue, 06 Jun, 21:53
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2394) Postcommit_Java_JDK_Version_Test is broken since SpannerWriteIT failed Tue, 06 Jun, 22:46
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2405) Create a BigQuery sink for streaming using PTransform Wed, 07 Jun, 05:18
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-245) Create Cassandra IO Wed, 07 Jun, 06:06
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-79) Gearpump runner Wed, 07 Jun, 07:35
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1231) Use well known coder types in Java for WindowedValue, GlobalWindow, and LengthPrefix Wed, 07 Jun, 14:54
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2375) upgrade beam-version to 2.0.0 Wed, 07 Jun, 15:22
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1231) Use well known coder types in Java for WindowedValue, GlobalWindow, and LengthPrefix Wed, 07 Jun, 16:02
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2423) Abstract StateInternalsTest for the different state internals/Runners Wed, 07 Jun, 17:35
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1779) Port UnboundedSourceWrapperTest to use Flink operator test harness Wed, 07 Jun, 17:51
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2421) Migrate Dataflow to use impulse primitive as the only root primitive Wed, 07 Jun, 20:49
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1542) Need Source/Sink for Spanner Wed, 07 Jun, 23:40
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2412) Update HBaseIO to use HBase client 1.2.6 Thu, 08 Jun, 07:24
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1941) Add Watermark Metrics in Runners Thu, 08 Jun, 08:20
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2410) Remove TransportClient from ElasticSearchIO to decouple IO and ES versions Thu, 08 Jun, 09:34
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2364) PCollectionView should not be a PValue, it should expand to its underlying PCollection Thu, 08 Jun, 16:15
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-991) DatastoreIO Write should flush early for large batches Thu, 08 Jun, 17:58
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers Thu, 08 Jun, 19:01
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers Thu, 08 Jun, 20:14
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers Thu, 08 Jun, 20:16
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2357) Add HCatalogIO (Hive) Thu, 08 Jun, 21:09
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers Thu, 08 Jun, 22:00
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1630) Add Splittable DoFn to Python SDK Thu, 08 Jun, 22:08
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2333) Rehydrate Pipeline from Runner API proto Thu, 08 Jun, 23:32
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2410) Remove TransportClient from ElasticSearchIO to decouple IO and ES versions Fri, 09 Jun, 05:32
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2360) Add guide for writing a Beam runner Fri, 09 Jun, 16:53
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers Fri, 09 Jun, 21:20
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers Sat, 10 Jun, 03:15
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2433) unify SQL/Sql words in class name Sat, 10 Jun, 06:10
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1319) PipelineOptions subclasses defined in the main session could be duplicated Sat, 10 Jun, 06:47
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2436) table is not regeisted in BeamSql.query Sat, 10 Jun, 20:49
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2359) SparkTimerInternals inputWatermarkTime does not get updated in cluster mode Mon, 12 Jun, 14:07
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-79) Gearpump runner Mon, 12 Jun, 16:56
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2433) unify SQL/Sql words in class name Mon, 12 Jun, 17:42
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2423) Abstract StateInternalsTest for the different state internals/Runners Mon, 12 Jun, 20:37
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2423) Abstract StateInternalsTest for the different state internals/Runners Tue, 13 Jun, 03:30
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2412) Update HBaseIO to use HBase client 1.2.6 Tue, 13 Jun, 06:00
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1483) Support SetState in Flink runner Tue, 13 Jun, 09:46
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2247) support date/time functions Tue, 13 Jun, 13:56
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2325) Support Set Operator: INTERSECT, EXCEPT, UNION Tue, 13 Jun, 13:58
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1319) PipelineOptions subclasses defined in the main session could be duplicated Tue, 13 Jun, 16:36
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers Tue, 13 Jun, 18:32
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers Tue, 13 Jun, 18:32
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1630) Add Splittable DoFn to Python SDK Tue, 13 Jun, 18:49
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2398) Increasing latency within DirectRunner caused by cumulated TransformWatermarks Tue, 13 Jun, 19:54
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1542) Need Source/Sink for Spanner Tue, 13 Jun, 20:43
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1287) Give new DoFn the ability to output to a particular window Wed, 14 Jun, 00:08
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2436) table is not regeisted in BeamSql.query Wed, 14 Jun, 00:18
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-92) Data-dependent sinks Wed, 14 Jun, 04:06
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2442) DSL SQL: Public classes/methods should not expose/use calcite types Wed, 14 Jun, 15:52
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2398) Increasing latency within DirectRunner caused by cumulated TransformWatermarks Wed, 14 Jun, 17:22
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1542) Need Source/Sink for Spanner Wed, 14 Jun, 20:06
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1585) Ability to add new file systems to beamFS in the python sdk Wed, 14 Jun, 21:31
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1585) Ability to add new file systems to beamFS in the python sdk Wed, 14 Jun, 21:32
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2447) Reintroduce DoFn.ProcessContinuation Wed, 14 Jun, 22:01
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-115) Beam Runner API Wed, 14 Jun, 22:05
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
Nov 2020273
Oct 2020362
Sep 2020331
Aug 2020345
Jul 2020398
Jun 2020328
May 2020369
Apr 2020435
Mar 20203566
Feb 2020812
Jan 2020365
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