You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2016/01/06 07:20:58 UTC
incubator-apex-malhar git commit: APEXMALHAR-1945 #resolve #comment
upgraded japi version to 0.6.2 and added exclusion annotations
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 <cs...@apache.org>
Authored: Tue Jan 5 17:01:50 2016 -0800
Committer: Chandni Singh <cs...@apache.org>
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
*/
+@InterfaceStability.Evolving
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
*/
+@InterfaceStability.Evolving
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
*/
+@InterfaceStability.Evolving
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
*/
+@InterfaceStability.Evolving
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
*/
+@InterfaceStability.Evolving
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
*/
+@InterfaceStability.Evolving
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
*/
+@InterfaceStability.Evolving
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
*/
+@InterfaceStability.Evolving
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
*/
+@InterfaceStability.Evolving
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>