beam-commits mailing list archives: December 2016

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 · 30 · 31 · 32 · 33 · 34 · Next »Thread · Author · Date
k...@apache.org [1/3] incubator-beam git commit: Actually propagate and commit state in direct runner Wed, 21 Dec, 21:12
k...@apache.org [2/3] incubator-beam git commit: Fix windowing in direct runner Stateful ParDo Wed, 21 Dec, 21:12
k...@apache.org [3/3] incubator-beam git commit: This closes #1670: Fixes for direct runner expansion and evaluation of stateful ParDo Wed, 21 Dec, 21:12
k...@apache.org [1/7] incubator-beam git commit: Add informative Instant formatter to BoundedWindow Wed, 21 Dec, 21:59
k...@apache.org [2/7] incubator-beam git commit: Hold output watermark according to pending timers Wed, 21 Dec, 21:59
k...@apache.org [3/7] incubator-beam git commit: Use informative Instant formatter in WatermarkHold Wed, 21 Dec, 21:59
k...@apache.org [4/7] incubator-beam git commit: Allow setting timer by ID in DirectTimerInternals Wed, 21 Dec, 21:59
k...@apache.org [5/7] incubator-beam git commit: Add static Window.withOutputTimeFn to match build method Wed, 21 Dec, 21:59
k...@apache.org [6/7] incubator-beam git commit: Add UsesTestStream for use with JUnit @Category Wed, 21 Dec, 21:59
k...@apache.org [7/7] incubator-beam git commit: This closes #1669: Preliminaries for timers in the direct runner Wed, 21 Dec, 21:59
k...@apache.org [01/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-core module to TestPipeline as a JUnit rule. Plus, fixed some checkstyle errors from previous modules' migration. Wed, 21 Dec, 22:49
k...@apache.org [02/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-core module to TestPipeline as a JUnit rule. Plus, fixed some checkstyle errors from previous modules' migration. Wed, 21 Dec, 22:49
k...@apache.org [03/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-core module to TestPipeline as a JUnit rule. Plus, fixed some checkstyle errors from previous modules' migration. Wed, 21 Dec, 22:49
k...@apache.org [04/51] [abbrv] incubator-beam git commit: Migrated the beam-runners-direct-java module to TestPipeline as a JUnit rule. Wed, 21 Dec, 22:49
k...@apache.org [05/51] [abbrv] incubator-beam git commit: Migrated the beam-runners-core module to TestPipeline as a JUnit rule. Wed, 21 Dec, 22:49
k...@apache.org [06/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-jms module to TestPipeline as a JUnit rule. Wed, 21 Dec, 22:49
k...@apache.org [07/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-jdbc module to TestPipeline as a JUnit rule. Wed, 21 Dec, 22:49
k...@apache.org [08/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-google-cloud-platform module to TestPipeline as a JUnit rule. Wed, 21 Dec, 22:49
k...@apache.org [09/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-extensions-sorter module to TestPipeline as a JUnit rule. Wed, 21 Dec, 22:49
k...@apache.org [10/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-extensions-join-library module to TestPipeline as a JUnit rule. Wed, 21 Dec, 22:49
k...@apache.org [11/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-java8tests module to TestPipeline as a JUnit rule + fixed WithTimestampsJava8Test.withTimestampsLambdaShouldApplyTimestamps. Wed, 21 Dec, 22:49
k...@apache.org [12/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-mongodb module to TestPipeline as a JUnit rule. Wed, 21 Dec, 22:49
k...@apache.org [13/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-kinesis module to TestPipeline as a JUnit rule. Wed, 21 Dec, 22:49
k...@apache.org [14/51] [abbrv] incubator-beam git commit: This closes #1664: [BEAM-1176] Migrating tests to use TestPipeline as a JUnit rule Wed, 21 Dec, 22:49
k...@apache.org [15/51] [abbrv] incubator-beam git commit: Add some key-preserving to KeyedPValueTrackingVisitor Wed, 21 Dec, 22:49
k...@apache.org [16/51] [abbrv] incubator-beam git commit: Propagate key through ParDo if DoFn is key-preserving Wed, 21 Dec, 22:49
k...@apache.org [17/51] [abbrv] incubator-beam git commit: Move responsibility for knowing about keyedness into EvaluationContext Wed, 21 Dec, 22:49
k...@apache.org [18/51] [abbrv] incubator-beam git commit: Port direct runner StatefulParDo to KeyedWorkItem Wed, 21 Dec, 22:49
k...@apache.org [19/51] [abbrv] incubator-beam git commit: Restore SDK's InMemoryTimerInternals, deprecated Wed, 21 Dec, 22:49
k...@apache.org [20/51] [abbrv] incubator-beam git commit: Move InMemoryTimerInternals to runners-core Wed, 21 Dec, 22:49
k...@apache.org [21/51] [abbrv] incubator-beam git commit: This closes #1652: Move InMemoryTimerInternals to runners-core Wed, 21 Dec, 22:49
k...@apache.org [22/51] [abbrv] incubator-beam git commit: This closes #1581: [BEAM-1117] Port direct runner StatefulParDo to KeyedWorkItem Wed, 21 Dec, 22:49
k...@apache.org [23/51] [abbrv] incubator-beam git commit: Fixup usage of canonical name with name since canonical name != name for inner classes. Wed, 21 Dec, 22:49
k...@apache.org [24/51] [abbrv] incubator-beam git commit: Provide a better error message for non-existing gcpTempLocation Wed, 21 Dec, 22:49
k...@apache.org [25/51] [abbrv] incubator-beam git commit: [BEAM-1097] Provide a better error message for non-existing gcpTempLocation Wed, 21 Dec, 22:49
k...@apache.org [26/51] [abbrv] incubator-beam git commit: Remove deprecated AggregatorFactory from SDK Wed, 21 Dec, 22:50
k...@apache.org [27/51] [abbrv] incubator-beam git commit: Update Dataflow worker to beam-master-20161220 Wed, 21 Dec, 22:50
k...@apache.org [28/51] [abbrv] incubator-beam git commit: This closes #1665: Remove deprecated AggregatorFactory from SDK Wed, 21 Dec, 22:50
k...@apache.org [29/51] [abbrv] incubator-beam git commit: Remove deprecated InMemoryTimerInternals from SDK Wed, 21 Dec, 22:50
k...@apache.org [30/51] [abbrv] incubator-beam git commit: Provide local tags in PInput, POutput expansions Wed, 21 Dec, 22:50
k...@apache.org [31/51] [abbrv] incubator-beam git commit: This closes #1569 Wed, 21 Dec, 22:50
k...@apache.org [32/51] [abbrv] incubator-beam git commit: This closes #1668: Remove deprecated InMemoryTimerInternals from SDK Wed, 21 Dec, 22:50
k...@apache.org [33/51] [abbrv] incubator-beam git commit: Require TimeDomain to delete a timer Wed, 21 Dec, 22:50
k...@apache.org [34/51] [abbrv] incubator-beam git commit: Move ExecutionContext and related classes to runners-core Wed, 21 Dec, 22:50
k...@apache.org [35/51] [abbrv] incubator-beam git commit: Update Dataflow worker to beam-master-20161221 Wed, 21 Dec, 22:50
k...@apache.org [36/51] [abbrv] incubator-beam git commit: This closes #1673: Require TimeDomain to delete a timer Wed, 21 Dec, 22:50
k...@apache.org [37/51] [abbrv] incubator-beam git commit: This closes #1666: Move ExecutionContext and related classes to runners-core Wed, 21 Dec, 22:50
k...@apache.org [38/51] [abbrv] incubator-beam git commit: Support set and delete of timer by ID in InMemoryTimerInternals Wed, 21 Dec, 22:50
k...@apache.org [39/51] [abbrv] incubator-beam git commit: This closes #1160: Support set and delete of timer by ID in InMemoryTimerInternals Wed, 21 Dec, 22:50
k...@apache.org [40/51] [abbrv] incubator-beam git commit: Actually propagate and commit state in direct runner Wed, 21 Dec, 22:50
k...@apache.org [41/51] [abbrv] incubator-beam git commit: Fix windowing in direct runner Stateful ParDo Wed, 21 Dec, 22:50
k...@apache.org [42/51] [abbrv] incubator-beam git commit: This closes #1670: Fixes for direct runner expansion and evaluation of stateful ParDo Wed, 21 Dec, 22:50
k...@apache.org [43/51] [abbrv] incubator-beam git commit: Add informative Instant formatter to BoundedWindow Wed, 21 Dec, 22:50
k...@apache.org [44/51] [abbrv] incubator-beam git commit: Add static Window.withOutputTimeFn to match build method Wed, 21 Dec, 22:50
k...@apache.org [45/51] [abbrv] incubator-beam git commit: Add UsesTestStream for use with JUnit @Category Wed, 21 Dec, 22:50
k...@apache.org [46/51] [abbrv] incubator-beam git commit: Allow setting timer by ID in DirectTimerInternals Wed, 21 Dec, 22:50
k...@apache.org [47/51] [abbrv] incubator-beam git commit: Hold output watermark according to pending timers Wed, 21 Dec, 22:50
k...@apache.org [48/51] [abbrv] incubator-beam git commit: Use informative Instant formatter in WatermarkHold Wed, 21 Dec, 22:50
k...@apache.org [49/51] [abbrv] incubator-beam git commit: This closes #1669: Preliminaries for timers in the direct runner Wed, 21 Dec, 22:50
k...@apache.org [50/51] [abbrv] incubator-beam git commit: Merge remote-tracking branch 'origin/master' into python-sdk Wed, 21 Dec, 22:50
k...@apache.org [51/51] [abbrv] incubator-beam git commit: This closes #1676: Merge master (57d9bbd) into python-sdk Wed, 21 Dec, 22:50
kennknowles [GitHub] incubator-beam pull request #1477: [BEAM-27] Add timerId to TimerData Thu, 01 Dec, 04:36
kennknowles [GitHub] incubator-beam pull request #1478: [BEAM-362] Moved KeyedWorkItem and relate... Thu, 01 Dec, 04:50
kennknowles [GitHub] incubator-beam pull request #1488: Fix pom syntax for excludedGroups for Spl... Fri, 02 Dec, 05:12
kennknowles [GitHub] incubator-beam pull request #1523: [BEAM-1038] Allow stateful DoFn in Datafl... Tue, 06 Dec, 22:31
kennknowles [GitHub] incubator-beam pull request #1527: [BEAM-498] Port most of DoFnRunner Javado... Wed, 07 Dec, 04:03
kennknowles [GitHub] incubator-beam pull request #1528: [BEAM-27] Add DoFn.OnTimerContext and sup... Wed, 07 Dec, 04:12
kennknowles [GitHub] incubator-beam pull request #1529: [BEAM-498] Port ParDoTest from OldDoFn to... Wed, 07 Dec, 05:02
kennknowles [GitHub] incubator-beam pull request #1536: [BEAM-664] Revise WindowedWordCount examp... Wed, 07 Dec, 18:51
kennknowles [GitHub] incubator-beam pull request #1538: [BEAM-438] Rename PTransform.apply to PTr... Wed, 07 Dec, 21:33
kennknowles [GitHub] incubator-beam pull request #1539: [BEAM-498] Remove misc occurrences of Old... Wed, 07 Dec, 22:20
kennknowles [GitHub] incubator-beam pull request #1541: [BEAM-498] Move PerKeyCombineFnRunner to ... Wed, 07 Dec, 22:23
kennknowles [GitHub] incubator-beam pull request #1543: [BEAM-25] Move CopyOnAccessStateInternals... Wed, 07 Dec, 22:30
kennknowles [GitHub] incubator-beam pull request #1550: [BEAM-27] Reject timers for ParDo in each... Thu, 08 Dec, 04:43
kennknowles [GitHub] incubator-beam pull request #1539: [BEAM-498] Remove misc occurrences of Old... Thu, 08 Dec, 17:52
kennknowles [GitHub] incubator-beam pull request #1555: [BEAM-27] Fix exclusion of UsesTimersInPa... Thu, 08 Dec, 20:43
kennknowles [GitHub] incubator-beam pull request #1556: [BEAM-23] Refactors to support key-preser... Thu, 08 Dec, 21:53
kennknowles [GitHub] incubator-beam pull request #1561: [BEAM-498] Remove misc uses of OldDoFn Fri, 09 Dec, 07:35
kennknowles [GitHub] incubator-beam-site pull request #104: [BEAM-438] Rename PTransform apply to... Fri, 09 Dec, 22:31
kennknowles [GitHub] incubator-beam pull request #1581: [BEAM-1117] Port Direct runner stateful P... Mon, 12 Dec, 21:22
kennknowles [GitHub] incubator-beam pull request #1556: [BEAM-23] Refactors to support key-preser... Mon, 12 Dec, 21:23
kennknowles [GitHub] incubator-beam pull request #1585: [BEAM-1139] Add no-arg constructor for Un... Mon, 12 Dec, 23:03
kennknowles [GitHub] incubator-beam pull request #1585: [BEAM-1139] Add no-arg constructor for Un... Mon, 12 Dec, 23:34
kennknowles [GitHub] incubator-beam pull request #1592: [BEAM-362] Move ActiveWindowSet and imple... Tue, 13 Dec, 04:21
kennknowles [GitHub] incubator-beam pull request #1597: [BEAM-1139] Revert Apex+Kryo PR and fix v... Tue, 13 Dec, 18:39
kennknowles [GitHub] incubator-beam pull request #1598: [BEAM-967] Add Jenkins postcommit for Run... Tue, 13 Dec, 19:32
kennknowles [GitHub] incubator-beam pull request #1602: [BEAM-1149] Cherry pick side inputs fix t... Tue, 13 Dec, 23:18
kennknowles [GitHub] incubator-beam pull request #1603: Revert "This closes #1541": Move PerKeyCo... Tue, 13 Dec, 23:28
kennknowles [GitHub] incubator-beam pull request #1602: [BEAM-1149] Cherry pick side inputs fix t... Tue, 13 Dec, 23:48
kennknowles [GitHub] incubator-beam pull request #1603: Revert "This closes #1541": Move PerKeyCo... Wed, 14 Dec, 00:08
kennknowles [GitHub] incubator-beam pull request #1605: Re-exclude UsesStatefulParDo tests for Da... Wed, 14 Dec, 00:10
kennknowles [GitHub] incubator-beam pull request #1606: Revert "Allow stateful DoFn in DataflowRu... Wed, 14 Dec, 00:39
kennknowles [GitHub] incubator-beam pull request #1607: Cherry pick disabling of state & state te... Wed, 14 Dec, 00:59
kennknowles [GitHub] incubator-beam pull request #1612: [BEAM-27] Support timer setting and recei... Wed, 14 Dec, 05:06
kennknowles [GitHub] incubator-beam pull request #1616: [BEAM-1149] SimpleDoFnRunner observes win... Wed, 14 Dec, 19:35
kennknowles [GitHub] incubator-beam pull request #1618: [BEAM-1149] Fix NPE in StatefulParDoEvalu... Wed, 14 Dec, 21:14
kennknowles [GitHub] incubator-beam pull request #1619: [BEAM-1149] Cherry pick some fixes to rel... Wed, 14 Dec, 22:25
kennknowles [GitHub] incubator-beam pull request #1626: Fix typo in mvn command args in Apex post... Thu, 15 Dec, 18:22
kennknowles [GitHub] incubator-beam pull request #1628: Bump 0.4.0 incubating worker Thu, 15 Dec, 18:44
kennknowles [GitHub] incubator-beam pull request #1628: Bump 0.4.0 incubating worker Thu, 15 Dec, 18:44
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 · 30 · 31 · 32 · 33 · 34 · Next »Thread · Author · Date
Box list
Jul 2019259
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