beam-commits mailing list archives: October 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 · Next »Thread · Author · Date
k...@apache.org [01/18] incubator-beam git commit: Add access to values from AfterDelay triggers Tue, 18 Oct, 03:38
k...@apache.org [02/18] incubator-beam git commit: Add accessors to Repeatedly trigger Tue, 18 Oct, 03:38
k...@apache.org [03/18] incubator-beam git commit: Add direct accessors for the components of OrFinallyTrigger Tue, 18 Oct, 03:38
k...@apache.org [04/18] incubator-beam git commit: Make AfterSynchronizedProcessingTime public Tue, 18 Oct, 03:38
k...@apache.org [05/18] incubator-beam git commit: Construct AfterEachStateMachine from list of subtriggers Tue, 18 Oct, 03:38
k...@apache.org [06/18] incubator-beam git commit: Add accessors to AfterWatermark trigger Tue, 18 Oct, 03:38
k...@apache.org [07/18] incubator-beam git commit: Make OrFinallyTrigger public so it can be examined Tue, 18 Oct, 03:38
k...@apache.org [08/18] incubator-beam git commit: Construct AfterFirstStateMachine with a list of subtriggers Tue, 18 Oct, 03:38
k...@apache.org [09/18] incubator-beam git commit: Make Trigger#subTriggers public and non-null Tue, 18 Oct, 03:38
k...@apache.org [10/18] incubator-beam git commit: Construct AfterAllStateMachine with a list of subtriggers Tue, 18 Oct, 03:38
k...@apache.org [11/18] incubator-beam git commit: Add accessors for AfterPane(StateMachine) parameters Tue, 18 Oct, 03:38
k...@apache.org [12/18] incubator-beam git commit: Make return types of trigger static factory methods precise Tue, 18 Oct, 03:38
k...@apache.org [13/18] incubator-beam git commit: Accessors for AfterDelay Tue, 18 Oct, 03:38
k...@apache.org [14/18] incubator-beam git commit: Touch up javadoc for AfterDelayFromFirstElementStateMachine Tue, 18 Oct, 03:38
k...@apache.org [15/18] incubator-beam git commit: Make NeverTrigger public for translation Tue, 18 Oct, 03:38
k...@apache.org [16/18] incubator-beam git commit: Make return types more precise for AfterWatermarkTriggerStateMachine Tue, 18 Oct, 03:38
k...@apache.org [17/18] incubator-beam git commit: Add TriggerStateMachines with conversion from Trigger Tue, 18 Oct, 03:38
k...@apache.org [18/18] incubator-beam git commit: This closes #1101 Tue, 18 Oct, 03:38
k...@apache.org [1/3] incubator-beam git commit: [BEAM-595] avoid throwing Exception in waitUntilFinish in SparkRunner Tue, 18 Oct, 20:29
k...@apache.org [2/3] incubator-beam git commit: Keep throws in StreamingEvaluationContext cancel() and waitUntilFinish Tue, 18 Oct, 20:29
k...@apache.org [3/3] incubator-beam git commit: This closes #1096 Tue, 18 Oct, 20:29
k...@apache.org [1/6] incubator-beam git commit: Tighten up tests for StateId validation Thu, 20 Oct, 01:02
k...@apache.org [2/6] incubator-beam git commit: Fix condition on state/splittable ParDo validation Thu, 20 Oct, 01:02
k...@apache.org [3/6] incubator-beam git commit: Add DoFnSignatures analysis of timer declarations Thu, 20 Oct, 01:02
k...@apache.org [4/6] incubator-beam git commit: Add Timer, TimerId, TimerSpec and TimerSpecs Thu, 20 Oct, 01:02
k...@apache.org [5/6] incubator-beam git commit: Reject all timers in ParDo, for now Thu, 20 Oct, 01:02
k...@apache.org [6/6] incubator-beam git commit: This closes #1102 Thu, 20 Oct, 01:02
k...@apache.org [1/4] incubator-beam git commit: Move named DoFn classes into the tests that use them Thu, 20 Oct, 18:56
k...@apache.org [2/4] incubator-beam git commit: Add analysis and validation of State parameters to DoFn.ProcessElement Thu, 20 Oct, 18:56
k...@apache.org [3/4] incubator-beam git commit: Use the correct State class in DoFnSignatures Thu, 20 Oct, 18:56
k...@apache.org [4/4] incubator-beam git commit: This closes #1130 Thu, 20 Oct, 18:56
k...@apache.org [1/4] incubator-beam git commit: Translate ReshuffleTrigger to ReshuffleTriggerStateMachine Thu, 20 Oct, 19:51
k...@apache.org [2/4] incubator-beam git commit: Delete TriggerRunner Thu, 20 Oct, 19:51
k...@apache.org [3/4] incubator-beam git commit: Port ReduceFnRunner to TriggerStateMachine Thu, 20 Oct, 19:51
k...@apache.org [4/4] incubator-beam git commit: This closes #1138 Thu, 20 Oct, 19:51
k...@apache.org [1/2] incubator-beam git commit: Add analysis of Timer parameters to DoFn.ProcessElement Thu, 20 Oct, 20:32
k...@apache.org [2/2] incubator-beam git commit: This closes #1136 Thu, 20 Oct, 20:32
k...@apache.org [1/2] incubator-beam git commit: [BEAM-781] Remove Spark's batch unit tests and rely on ROS tests instead. Thu, 20 Oct, 23:15
k...@apache.org [2/2] incubator-beam git commit: This closes #1144 Thu, 20 Oct, 23:15
k...@apache.org [1/7] incubator-beam git commit: Add access to original DoFn on ParDo Fri, 21 Oct, 02:53
k...@apache.org [2/7] incubator-beam git commit: Rename SimpleDoFnRunner to SimpleOldDoFnRunner and remove public access Fri, 21 Oct, 02:53
k...@apache.org [3/7] incubator-beam git commit: Simplify DoFnRunners to be somewhat compositional Fri, 21 Oct, 02:53
k...@apache.org [4/7] incubator-beam git commit: Add OldDoFn.toDoFn() adapter Fri, 21 Oct, 02:53
k...@apache.org [5/7] incubator-beam git commit: Add SimpleDoFnRunner for new DoFn and construction via DoFnRunners Fri, 21 Oct, 02:53
k...@apache.org [6/7] incubator-beam git commit: Switch the DirectRunner to use new DoFnRunner code path Fri, 21 Oct, 02:53
k...@apache.org [7/7] incubator-beam git commit: This closes #1141 Fri, 21 Oct, 02:53
k...@apache.org [01/14] incubator-beam git commit: Add adapter from OldDoFn.RequiresWindowAccess to DoFn Mon, 24 Oct, 16:10
k...@apache.org [02/14] incubator-beam git commit: Port some of ParDoTest to new DoFn Mon, 24 Oct, 16:10
k...@apache.org [03/14] incubator-beam git commit: Fix NPE in SimpleDoFnRunner Mon, 24 Oct, 16:10
k...@apache.org [04/14] incubator-beam git commit: Port ReifyTimestampAndWindowsDoFn to RequiresWindowAccess Mon, 24 Oct, 16:10
k...@apache.org [05/14] incubator-beam git commit: Add setupDelegatingAggregators for DoFn (for now) Mon, 24 Oct, 16:10
k...@apache.org [06/14] incubator-beam git commit: Move AggregatorFactory to runners-core and deprecate SDK version Mon, 24 Oct, 16:11
k...@apache.org [07/14] incubator-beam git commit: Move shared DelegatingAggregator out of OldDoFn Mon, 24 Oct, 16:11
k...@apache.org [08/14] incubator-beam git commit: Fix binding of aggregator creating in OldDoFn Mon, 24 Oct, 16:11
k...@apache.org [09/14] incubator-beam git commit: Fix binding of aggregator delegation in DoFnAdapters Mon, 24 Oct, 16:11
k...@apache.org [10/14] incubator-beam git commit: Make DoFnTester aggregator initialization idempotent Mon, 24 Oct, 16:11
k...@apache.org [11/14] incubator-beam git commit: Fix flipped conditional in SimpleDoFnRunner Mon, 24 Oct, 16:11
k...@apache.org [12/14] incubator-beam git commit: Port direct runner to use new DoFn directly Mon, 24 Oct, 16:11
k...@apache.org [13/14] incubator-beam git commit: Make aggregator registration idempotent in FlinkRunner Mon, 24 Oct, 16:11
k...@apache.org [14/14] incubator-beam git commit: This closes #1157 Mon, 24 Oct, 16:11
k...@apache.org [1/3] incubator-beam git commit: Fix ReduceFnRunner.cancelEndOfWindowAndGarbageCollectionTimers() Mon, 24 Oct, 17:23
k...@apache.org [2/3] incubator-beam git commit: Fix Javadoc of ReadableState Mon, 24 Oct, 17:23
k...@apache.org [3/3] incubator-beam git commit: This closes #1166 Mon, 24 Oct, 17:23
k...@apache.org [1/5] incubator-beam git commit: Update DataflowRunner worker image Tue, 25 Oct, 17:14
k...@apache.org [2/5] incubator-beam git commit: Remove pieces of Trigger now owned by TriggerStateMachine Tue, 25 Oct, 17:14
k...@apache.org [3/5] incubator-beam git commit: Remove pieces of Trigger now owned by TriggerStateMachine Tue, 25 Oct, 17:14
k...@apache.org [4/5] incubator-beam git commit: Remove pieces of Trigger now owned by TriggerStateMachine Tue, 25 Oct, 17:14
k...@apache.org [5/5] incubator-beam git commit: This closes #1172 Tue, 25 Oct, 17:14
k...@apache.org [1/2] incubator-beam git commit: This closes #1174 Tue, 25 Oct, 17:54
k...@apache.org [2/2] incubator-beam git commit: Improve teardown behavior in DoFnLifecycleManager Tue, 25 Oct, 17:54
k...@apache.org [1/2] incubator-beam git commit: Encode bundle elements in the DirectRunner Tue, 25 Oct, 18:17
k...@apache.org [2/2] incubator-beam git commit: This closes #1095 Tue, 25 Oct, 18:17
k...@apache.org [1/2] incubator-beam git commit: This closes #1158 Tue, 25 Oct, 20:04
k...@apache.org [2/2] incubator-beam git commit: Remove unused GroupAlsoByWindowsDoFn.createDefault Tue, 25 Oct, 20:04
k...@apache.org [1/4] incubator-beam git commit: This closes #1178 Tue, 25 Oct, 20:12
k...@apache.org [2/4] incubator-beam git commit: Remove use of OldDoFn from some DirectRunner tests Tue, 25 Oct, 20:12
k...@apache.org [3/4] incubator-beam git commit: Remove OldDoFn to DoFn in DirectRunner Tue, 25 Oct, 20:12
k...@apache.org [4/4] incubator-beam git commit: Remove use of OldDoFn in ValueWithRecordId Tue, 25 Oct, 20:12
k...@apache.org [1/3] incubator-beam git commit: This closes #1195 Wed, 26 Oct, 20:43
k...@apache.org [2/3] incubator-beam git commit: Use project-wise version in SparkRunner dep on KafkaIO Wed, 26 Oct, 20:43
k...@apache.org [3/3] incubator-beam git commit: Add default version for beam-sdks-java-io-kafka Wed, 26 Oct, 20:43
k...@apache.org [1/2] incubator-beam git commit: This closes #1173 Wed, 26 Oct, 22:08
k...@apache.org [2/2] incubator-beam git commit: Port some example utils from OldDoFn to DoFn Wed, 26 Oct, 22:08
k...@apache.org [1/3] incubator-beam git commit: Make DoFnInfo carry OldDoFn or DoFn Thu, 27 Oct, 18:44
k...@apache.org [2/3] incubator-beam git commit: Update Dataflow worker image pointer Thu, 27 Oct, 18:44
k...@apache.org [3/3] incubator-beam git commit: This closes #1176 Thu, 27 Oct, 18:44
k...@apache.org [1/2] incubator-beam git commit: This closes #1196 Thu, 27 Oct, 19:50
k...@apache.org [2/2] incubator-beam git commit: Use a Constant TupleTag in GroupAlsoByWindowEvaluator Thu, 27 Oct, 19:50
k...@apache.org [1/2] incubator-beam git commit: This closes #1202 Thu, 27 Oct, 19:52
k...@apache.org [2/2] incubator-beam git commit: Use a NavigableSet Instead of a PriorityQueue in WatermarkManager Thu, 27 Oct, 19:52
k...@apache.org [1/2] incubator-beam git commit: This closes #1205 Thu, 27 Oct, 22:01
k...@apache.org [2/2] incubator-beam git commit: Separate package-info.java compilation to avoid spurious rebuilds Thu, 27 Oct, 22:01
k...@apache.org [1/2] incubator-beam git commit: Add setTimer and deleteTimer by ID in TimerInternals Mon, 31 Oct, 03:16
k...@apache.org [2/2] incubator-beam git commit: This closes #1217 Mon, 31 Oct, 03:16
k...@apache.org [1/2] incubator-beam-site git commit: Add IntelliJ Checkstyle documentation Mon, 31 Oct, 03:46
k...@apache.org [2/2] incubator-beam-site git commit: This closes #55 Mon, 31 Oct, 03:46
k...@apache.org [1/2] incubator-beam git commit: Remove unnecessary configuration properties from checkstyle.xml Mon, 31 Oct, 03:51
k...@apache.org [2/2] incubator-beam git commit: This closes #1218 Mon, 31 Oct, 03:51
k...@apache.org [1/3] incubator-beam git commit: Update shade plugin version to avoid ASM bug Mon, 31 Oct, 17:39
k...@apache.org [2/3] incubator-beam git commit: Fixes a compile error in SourceRDD Mon, 31 Oct, 17:39
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 · Next »Thread · Author · Date
Box list
Sep 2019250
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