Repository: incubator-apex-malhar Updated Branches: refs/heads/devel-3 8790077a3 -> 5efa71d99
APEXMALHAR-1945 #resolve #comment upgraded japi version to 0.6.2 and added exclusion annotations Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/5efa71d9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/5efa71d9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/5efa71d9 Branch: refs/heads/devel-3 Commit: 5efa71d99ae79c081dd9d50a84313bc505c971e7 Parents: 8790077 Author: Chandni Singh <[email protected]> Authored: Tue Jan 5 17:01:50 2016 -0800 Committer: Chandni Singh <[email protected]> Committed: Tue Jan 5 17:01:50 2016 -0800 ---------------------------------------------------------------------- .../java/com/datatorrent/lib/db/jdbc/JdbcPOJOInputOperator.java | 3 +++ .../main/java/com/datatorrent/lib/fileaccess/DTFileReader.java | 2 ++ .../main/java/com/datatorrent/lib/fileaccess/FileAccess.java | 2 ++ .../java/com/datatorrent/lib/fileaccess/FileAccessFSImpl.java | 2 ++ .../src/main/java/com/datatorrent/lib/fileaccess/TFileImpl.java | 2 ++ .../main/java/com/datatorrent/lib/fileaccess/TFileReader.java | 2 ++ .../main/java/com/datatorrent/lib/fileaccess/TFileWriter.java | 2 ++ .../main/java/com/datatorrent/lib/util/WindowDataManager.java | 2 ++ .../main/java/org/apache/hadoop/io/file/tfile/CacheManager.java | 3 +++ pom.xml | 5 +++-- 10 files changed, 23 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/5efa71d9/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOInputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOInputOperator.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOInputOperator.java index 46c18dc..3568b62 100644 --- a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOInputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOInputOperator.java @@ -36,6 +36,8 @@ import javax.validation.constraints.NotNull; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import org.apache.hadoop.classification.InterfaceStability; + import com.google.common.base.Preconditions; import com.google.common.collect.Lists; import com.google.common.collect.Maps; @@ -64,6 +66,7 @@ import com.datatorrent.lib.util.PojoUtils; * @tags database, sql, pojo, jdbc * @since 2.1.0 */ [email protected] public class JdbcPOJOInputOperator extends AbstractJdbcInputOperator<Object> implements Operator.ActivationListener<Context.OperatorContext> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/5efa71d9/library/src/main/java/com/datatorrent/lib/fileaccess/DTFileReader.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/fileaccess/DTFileReader.java b/library/src/main/java/com/datatorrent/lib/fileaccess/DTFileReader.java index 6dca462..7fff4e0 100644 --- a/library/src/main/java/com/datatorrent/lib/fileaccess/DTFileReader.java +++ b/library/src/main/java/com/datatorrent/lib/fileaccess/DTFileReader.java @@ -22,6 +22,7 @@ import java.io.IOException; import java.util.Arrays; import java.util.TreeMap; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FSDataInputStream; import org.apache.hadoop.io.file.tfile.DTFile; @@ -42,6 +43,7 @@ import com.datatorrent.netlet.util.Slice; * * @since 2.0.0 */ [email protected] public class DTFileReader implements FileAccess.FileReader { private final Reader reader; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/5efa71d9/library/src/main/java/com/datatorrent/lib/fileaccess/FileAccess.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/fileaccess/FileAccess.java b/library/src/main/java/com/datatorrent/lib/fileaccess/FileAccess.java index fff81ca..d4c7810 100644 --- a/library/src/main/java/com/datatorrent/lib/fileaccess/FileAccess.java +++ b/library/src/main/java/com/datatorrent/lib/fileaccess/FileAccess.java @@ -24,6 +24,7 @@ import java.io.DataOutputStream; import java.io.IOException; import java.util.TreeMap; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.LocatedFileStatus; import org.apache.hadoop.fs.RemoteIterator; @@ -34,6 +35,7 @@ import com.datatorrent.netlet.util.Slice; * * @since 2.0.0 */ [email protected] public interface FileAccess extends Closeable { void init(); http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/5efa71d9/library/src/main/java/com/datatorrent/lib/fileaccess/FileAccessFSImpl.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/fileaccess/FileAccessFSImpl.java b/library/src/main/java/com/datatorrent/lib/fileaccess/FileAccessFSImpl.java index 5c7e8d3..74ab238 100644 --- a/library/src/main/java/com/datatorrent/lib/fileaccess/FileAccessFSImpl.java +++ b/library/src/main/java/com/datatorrent/lib/fileaccess/FileAccessFSImpl.java @@ -22,6 +22,7 @@ import java.io.IOException; import javax.validation.constraints.NotNull; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FSDataInputStream; import org.apache.hadoop.fs.FSDataOutputStream; @@ -39,6 +40,7 @@ import com.datatorrent.netlet.util.DTThrowable; * * @since 2.0.0 */ [email protected] public abstract class FileAccessFSImpl implements FileAccess { @NotNull http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/5efa71d9/library/src/main/java/com/datatorrent/lib/fileaccess/TFileImpl.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/fileaccess/TFileImpl.java b/library/src/main/java/com/datatorrent/lib/fileaccess/TFileImpl.java index 5526832..2a3fd0e 100644 --- a/library/src/main/java/com/datatorrent/lib/fileaccess/TFileImpl.java +++ b/library/src/main/java/com/datatorrent/lib/fileaccess/TFileImpl.java @@ -20,6 +20,7 @@ package com.datatorrent.lib.fileaccess; import java.io.IOException; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FSDataInputStream; import org.apache.hadoop.fs.FSDataOutputStream; @@ -37,6 +38,7 @@ import org.apache.hadoop.io.file.tfile.TFile.Writer; * * @since 2.0.0 */ [email protected] public abstract class TFileImpl extends FileAccessFSImpl { private int minBlockSize = 64 * 1024; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/5efa71d9/library/src/main/java/com/datatorrent/lib/fileaccess/TFileReader.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/fileaccess/TFileReader.java b/library/src/main/java/com/datatorrent/lib/fileaccess/TFileReader.java index 37fd950..9ab6f82 100644 --- a/library/src/main/java/com/datatorrent/lib/fileaccess/TFileReader.java +++ b/library/src/main/java/com/datatorrent/lib/fileaccess/TFileReader.java @@ -21,6 +21,7 @@ package com.datatorrent.lib.fileaccess; import java.io.IOException; import java.util.TreeMap; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FSDataInputStream; import org.apache.hadoop.io.file.tfile.TFile.Reader; @@ -34,6 +35,7 @@ import com.datatorrent.netlet.util.Slice; * * @since 2.0.0 */ [email protected] public class TFileReader implements FileAccess.FileReader { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/5efa71d9/library/src/main/java/com/datatorrent/lib/fileaccess/TFileWriter.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/fileaccess/TFileWriter.java b/library/src/main/java/com/datatorrent/lib/fileaccess/TFileWriter.java index b362987..6566ae0 100644 --- a/library/src/main/java/com/datatorrent/lib/fileaccess/TFileWriter.java +++ b/library/src/main/java/com/datatorrent/lib/fileaccess/TFileWriter.java @@ -20,6 +20,7 @@ package com.datatorrent.lib.fileaccess; import java.io.IOException; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FSDataOutputStream; import org.apache.hadoop.io.file.tfile.TFile.Writer; @@ -29,6 +30,7 @@ import org.apache.hadoop.io.file.tfile.TFile.Writer; * * @since 2.0.0 */ [email protected] public final class TFileWriter implements FileAccess.FileWriter { private Writer writer; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/5efa71d9/library/src/main/java/com/datatorrent/lib/util/WindowDataManager.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/util/WindowDataManager.java b/library/src/main/java/com/datatorrent/lib/util/WindowDataManager.java index 26a2e32..fce1b01 100644 --- a/library/src/main/java/com/datatorrent/lib/util/WindowDataManager.java +++ b/library/src/main/java/com/datatorrent/lib/util/WindowDataManager.java @@ -27,6 +27,7 @@ import java.util.Set; import javax.validation.constraints.NotNull; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.fs.FileSystem; @@ -57,6 +58,7 @@ import com.datatorrent.lib.io.fs.AbstractFileInputOperator; * * @since 2.0.0 */ [email protected] public interface WindowDataManager extends StorageAgent, Component<Context.OperatorContext> { /** http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/5efa71d9/library/src/main/java/org/apache/hadoop/io/file/tfile/CacheManager.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/hadoop/io/file/tfile/CacheManager.java b/library/src/main/java/org/apache/hadoop/io/file/tfile/CacheManager.java index 2f47a76..70fe83d 100644 --- a/library/src/main/java/org/apache/hadoop/io/file/tfile/CacheManager.java +++ b/library/src/main/java/org/apache/hadoop/io/file/tfile/CacheManager.java @@ -22,6 +22,8 @@ import java.lang.management.ManagementFactory; import java.util.Collection; import com.google.common.annotations.VisibleForTesting; + +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.io.file.tfile.DTBCFile.Reader.BlockReader; import com.google.common.cache.Cache; import com.google.common.cache.CacheBuilder; @@ -39,6 +41,7 @@ import com.google.common.cache.Weigher; * * @since 2.0.0 */ [email protected] public class CacheManager { public static final int STRING_OVERHEAD = 64; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/5efa71d9/pom.xml ---------------------------------------------------------------------- diff --git a/pom.xml b/pom.xml index 874f30f..19a10ae 100644 --- a/pom.xml +++ b/pom.xml @@ -102,7 +102,7 @@ <plugin> <groupId>com.github.siom79.japicmp</groupId> <artifactId>japicmp-maven-plugin</artifactId> - <version>0.5.3</version> + <version>0.6.2</version> <configuration> <oldVersion> <dependency> @@ -125,10 +125,11 @@ <includeSynthetic>false</includeSynthetic> <ignoreMissingClasses>true</ignoreMissingClasses> <excludes> - <exclude>*POJO*</exclude> <exclude>com.datatorrent.contrib.converter.Converter</exclude> <exclude>com.datatorrent.contrib.schema.*</exclude> <exclude>org.apache.hadoop.io.file.tfile.*</exclude> + <exclude>@org.apache.hadoop.classification.InterfaceStability.Evolving</exclude> + <exclude>@org.apache.hadoop.classification.InterfaceStability.Unstable</exclude> </excludes> </parameter> <skip>${semver.plugin.skip}</skip>
