Adjust for merge from master.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9197d1e0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9197d1e0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/9197d1e0 Branch: refs/heads/apex-runner Commit: 9197d1e05e034f8dea0b413c09e7428e90294509 Parents: 5ccd5fb Author: Thomas Weise <t...@apache.org> Authored: Mon Nov 7 20:29:08 2016 +0100 Committer: Thomas Weise <t...@apache.org> Committed: Mon Nov 7 20:29:08 2016 +0100 ---------------------------------------------------------------------- .../translators/functions/ApexGroupByKeyOperator.java | 14 ++++++++++++++ 1 file changed, 14 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/9197d1e0/runners/apex/src/main/java/org/apache/beam/runners/apex/translators/functions/ApexGroupByKeyOperator.java ---------------------------------------------------------------------- diff --git a/runners/apex/src/main/java/org/apache/beam/runners/apex/translators/functions/ApexGroupByKeyOperator.java b/runners/apex/src/main/java/org/apache/beam/runners/apex/translators/functions/ApexGroupByKeyOperator.java index 98f3eca..4c28c85 100644 --- a/runners/apex/src/main/java/org/apache/beam/runners/apex/translators/functions/ApexGroupByKeyOperator.java +++ b/runners/apex/src/main/java/org/apache/beam/runners/apex/translators/functions/ApexGroupByKeyOperator.java @@ -60,12 +60,14 @@ import org.apache.beam.sdk.transforms.windowing.PaneInfo; import org.apache.beam.sdk.util.CoderUtils; import org.apache.beam.sdk.util.KeyedWorkItem; import org.apache.beam.sdk.util.KeyedWorkItems; +import org.apache.beam.sdk.util.TimeDomain; import org.apache.beam.sdk.util.TimerInternals; import org.apache.beam.sdk.util.WindowedValue; import org.apache.beam.sdk.util.WindowingInternals; import org.apache.beam.sdk.util.WindowingStrategy; import org.apache.beam.sdk.util.state.StateInternals; import org.apache.beam.sdk.util.state.StateInternalsFactory; +import org.apache.beam.sdk.util.state.StateNamespace; import org.apache.beam.sdk.values.KV; import org.apache.beam.sdk.values.PCollection; import org.apache.beam.sdk.values.PCollectionView; @@ -451,6 +453,18 @@ public class ApexGroupByKeyOperator<K, V> implements Operator { // TODO Auto-generated method stub return null; } + + @Override + public void setTimer(StateNamespace namespace, String timerId, Instant target, + TimeDomain timeDomain) { + throw new UnsupportedOperationException("Setting timer by ID not yet supported."); + } + + @Override + public void deleteTimer(StateNamespace namespace, String timerId) { + throw new UnsupportedOperationException("Canceling of timer by ID is not yet supported."); + } + } private class GroupByKeyStateInternalsFactory implements StateInternalsFactory<K>, Serializable {