Remove flink-annotations dependency
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/88513db3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/88513db3 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/88513db3 Branch: refs/heads/jstorm-runner Commit: 88513db31ee5301d96550b82b5f428b35966f2a7 Parents: 5fce8d2 Author: Ismaël MejÃa <[email protected]> Authored: Tue Apr 18 14:42:37 2017 +0200 Committer: Ismaël MejÃa <[email protected]> Committed: Tue Apr 18 16:12:47 2017 +0200 ---------------------------------------------------------------------- runners/flink/runner/pom.xml | 6 ------ .../translation/types/EncodedValueTypeInformation.java | 9 --------- 2 files changed, 15 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/88513db3/runners/flink/runner/pom.xml ---------------------------------------------------------------------- diff --git a/runners/flink/runner/pom.xml b/runners/flink/runner/pom.xml index 30f376c..95880f4 100644 --- a/runners/flink/runner/pom.xml +++ b/runners/flink/runner/pom.xml @@ -160,12 +160,6 @@ <version>${flink.version}</version> </dependency> - <dependency> - <groupId>org.apache.flink</groupId> - <artifactId>flink-annotations</artifactId> - <version>${flink.version}</version> - </dependency> - <!-- For testing --> <dependency> <groupId>org.apache.flink</groupId> http://git-wip-us.apache.org/repos/asf/beam/blob/88513db3/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/types/EncodedValueTypeInformation.java ---------------------------------------------------------------------- diff --git a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/types/EncodedValueTypeInformation.java b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/types/EncodedValueTypeInformation.java index 0315ae3..e24bf31 100644 --- a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/types/EncodedValueTypeInformation.java +++ b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/types/EncodedValueTypeInformation.java @@ -18,7 +18,6 @@ package org.apache.beam.runners.flink.translation.types; import org.apache.beam.sdk.coders.Coder; -import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.api.common.ExecutionConfig; import org.apache.flink.api.common.typeinfo.AtomicType; import org.apache.flink.api.common.typeinfo.TypeInformation; @@ -36,43 +35,36 @@ public class EncodedValueTypeInformation private static final long serialVersionUID = 1L; @Override - @PublicEvolving public boolean isBasicType() { return false; } @Override - @PublicEvolving public boolean isTupleType() { return false; } @Override - @PublicEvolving public int getArity() { return 0; } @Override - @PublicEvolving public int getTotalFields() { return 0; } @Override - @PublicEvolving public Class<byte[]> getTypeClass() { return byte[].class; } @Override - @PublicEvolving public boolean isKeyType() { return true; } @Override - @PublicEvolving public TypeSerializer<byte[]> createSerializer(ExecutionConfig executionConfig) { return new EncodedValueSerializer(); } @@ -98,7 +90,6 @@ public class EncodedValueTypeInformation } @Override - @PublicEvolving public TypeComparator<byte[]> createComparator( boolean sortOrderAscending, ExecutionConfig executionConfig) {
