You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/04/25 17:30:39 UTC
[44/50] [abbrv] beam git commit: Remove flink-annotations dependency
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 <ie...@apache.org>
Authored: Tue Apr 18 14:42:37 2017 +0200
Committer: Isma�l Mej�a <ie...@apache.org>
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) {