Make return types more precise for AfterWatermarkTriggerStateMachine
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/476dcd74 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/476dcd74 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/476dcd74 Branch: refs/heads/master Commit: 476dcd740c97831a5d55953014fc5d99135addce Parents: 703c84e Author: Kenneth Knowles <k...@google.com> Authored: Thu Oct 13 22:46:08 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Mon Oct 17 19:56:36 2016 -0700 ---------------------------------------------------------------------- .../beam/runners/core/triggers/AfterWatermarkStateMachine.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/476dcd74/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.java ---------------------------------------------------------------------- diff --git a/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.java b/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.java index 5ad6214..524c057 100644 --- a/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.java +++ b/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.java @@ -93,11 +93,11 @@ public class AfterWatermarkStateMachine { this.lateTrigger = lateTrigger; } - public TriggerStateMachine withEarlyFirings(OnceTriggerStateMachine earlyTrigger) { + public AfterWatermarkEarlyAndLate withEarlyFirings(OnceTriggerStateMachine earlyTrigger) { return new AfterWatermarkEarlyAndLate(earlyTrigger, lateTrigger); } - public TriggerStateMachine withLateFirings(OnceTriggerStateMachine lateTrigger) { + public AfterWatermarkEarlyAndLate withLateFirings(OnceTriggerStateMachine lateTrigger) { return new AfterWatermarkEarlyAndLate(earlyTrigger, lateTrigger); }
