tajo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hyun...@apache.org
Subject tajo git commit: TAJO-1841: Eliminate explicit diamond expressions in tajo-{algebra, rpc}
Date Mon, 14 Sep 2015 17:02:04 GMT
Repository: tajo
Updated Branches:
  refs/heads/branch-0.11.0 20c7e184c -> 48c7c195a


TAJO-1841: Eliminate explicit diamond expressions in tajo-{algebra,rpc}

Closes #1841


Project: http://git-wip-us.apache.org/repos/asf/tajo/repo
Commit: http://git-wip-us.apache.org/repos/asf/tajo/commit/48c7c195
Tree: http://git-wip-us.apache.org/repos/asf/tajo/tree/48c7c195
Diff: http://git-wip-us.apache.org/repos/asf/tajo/diff/48c7c195

Branch: refs/heads/branch-0.11.0
Commit: 48c7c195a51e8113cf5fa7ebbb30fe69b855c1b8
Parents: 20c7e18
Author: Hyunsik Choi <hyunsik@apache.org>
Authored: Mon Sep 14 08:48:49 2015 -0700
Committer: Hyunsik Choi <hyunsik@apache.org>
Committed: Mon Sep 14 09:55:01 2015 -0700

----------------------------------------------------------------------
 CHANGES                                         |  3 +++
 .../org/apache/tajo/algebra/AlterTable.java     |  2 +-
 .../apache/tajo/algebra/CaseWhenPredicate.java  |  4 ++--
 .../org/apache/tajo/algebra/CreateTable.java    |  8 +++----
 .../java/org/apache/tajo/algebra/Insert.java    |  2 +-
 .../main/java/org/apache/tajo/rpc/RpcUtils.java |  2 +-
 .../org/apache/tajo/rpc/NettyClientBase.java    |  4 ++--
 .../java/org/apache/tajo/rpc/TestAsyncRpc.java  | 24 ++++++++++----------
 .../apache/tajo/rpc/TestRpcClientManager.java   |  2 +-
 .../tajo/ws/rs/netty/gson/GsonFeature.java      |  2 +-
 .../tajo/ws/rs/netty/NettyRestServerTest.java   |  2 +-
 .../ws/rs/netty/testapp1/TestApplication1.java  |  2 +-
 .../ws/rs/netty/testapp2/DirectoriesDao.java    |  2 +-
 .../rs/netty/testapp2/DirectoriesResource.java  |  2 +-
 .../testapp2/FileManagementApplication.java     |  2 +-
 15 files changed, 33 insertions(+), 30 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/tajo/blob/48c7c195/CHANGES
----------------------------------------------------------------------
diff --git a/CHANGES b/CHANGES
index 92986e0..3fece88 100644
--- a/CHANGES
+++ b/CHANGES
@@ -619,6 +619,9 @@ Release 0.11.0 - unreleased
 
   SUB TASKS
 
+    TAJO-1841: Eliminate explicit diamond expressions in tajo-{algebra,rpc}
+    (hyunsik)
+
     TAJO-1826: Revert 'refining code for Parquet 1.8.1'. 
     (Contributed by Jongyoung Park, committed by hyunsik)
 

http://git-wip-us.apache.org/repos/asf/tajo/blob/48c7c195/tajo-algebra/src/main/java/org/apache/tajo/algebra/AlterTable.java
----------------------------------------------------------------------
diff --git a/tajo-algebra/src/main/java/org/apache/tajo/algebra/AlterTable.java b/tajo-algebra/src/main/java/org/apache/tajo/algebra/AlterTable.java
index f0bd62a..af6e902 100644
--- a/tajo-algebra/src/main/java/org/apache/tajo/algebra/AlterTable.java
+++ b/tajo-algebra/src/main/java/org/apache/tajo/algebra/AlterTable.java
@@ -203,7 +203,7 @@ public class AlterTable extends Expr {
     alter.values = values;
     alter.location = location;
     if (params != null) {
-      alter.params = new HashMap<String, String>(params);
+      alter.params = new HashMap<>(params);
     }
     alter.purge = purge;
     alter.ifNotExists = ifNotExists;

http://git-wip-us.apache.org/repos/asf/tajo/blob/48c7c195/tajo-algebra/src/main/java/org/apache/tajo/algebra/CaseWhenPredicate.java
----------------------------------------------------------------------
diff --git a/tajo-algebra/src/main/java/org/apache/tajo/algebra/CaseWhenPredicate.java b/tajo-algebra/src/main/java/org/apache/tajo/algebra/CaseWhenPredicate.java
index 8e97c31..68a78a4 100644
--- a/tajo-algebra/src/main/java/org/apache/tajo/algebra/CaseWhenPredicate.java
+++ b/tajo-algebra/src/main/java/org/apache/tajo/algebra/CaseWhenPredicate.java
@@ -29,7 +29,7 @@ import java.util.List;
 
 public class CaseWhenPredicate extends Expr {
   @Expose @SerializedName("WhenExprs")
-  private List<WhenExpr> whens = new ArrayList<WhenExpr>();
+  private List<WhenExpr> whens = new ArrayList<>();
   @Expose @SerializedName("ElseExpr")
   private Expr elseResult;
 
@@ -71,7 +71,7 @@ public class CaseWhenPredicate extends Expr {
   @Override
   public Object clone() throws CloneNotSupportedException {
     CaseWhenPredicate caseWhen = (CaseWhenPredicate) super.clone();
-    caseWhen.whens = new ArrayList<WhenExpr>();
+    caseWhen.whens = new ArrayList<>();
     for (int i = 0; i < whens.size(); i++) {
       caseWhen.whens.add((WhenExpr) whens.get(i).clone());
     }

http://git-wip-us.apache.org/repos/asf/tajo/blob/48c7c195/tajo-algebra/src/main/java/org/apache/tajo/algebra/CreateTable.java
----------------------------------------------------------------------
diff --git a/tajo-algebra/src/main/java/org/apache/tajo/algebra/CreateTable.java b/tajo-algebra/src/main/java/org/apache/tajo/algebra/CreateTable.java
index ef10c4c..8e081ff 100644
--- a/tajo-algebra/src/main/java/org/apache/tajo/algebra/CreateTable.java
+++ b/tajo-algebra/src/main/java/org/apache/tajo/algebra/CreateTable.java
@@ -211,7 +211,7 @@ public class CreateTable extends Expr {
     createTable.location = location;
     createTable.subquery = subquery;
     if (params != null) {
-      createTable.params = new HashMap<String, String>(params);
+      createTable.params = new HashMap<>(params);
     }
     if (partition != null) {
       createTable.partition = (PartitionMethodDescExpr) partition.clone();
@@ -330,7 +330,7 @@ public class CreateTable extends Expr {
         }
       }
       if (specifiers != null) {
-        range.specifiers = new ArrayList<RangePartitionSpecifier>();
+        range.specifiers = new ArrayList<>();
         for (int i = 0; i < specifiers.size(); i++) {
           range.specifiers.add(specifiers.get(i));
         }
@@ -404,7 +404,7 @@ public class CreateTable extends Expr {
       }
       hash.quantity = quantity;
       if (specifiers != null) {
-        hash.specifiers = new ArrayList<PartitionSpecifier>();
+        hash.specifiers = new ArrayList<>();
         for (PartitionSpecifier specifier : specifiers) {
           hash.specifiers.add(specifier);
         }
@@ -457,7 +457,7 @@ public class CreateTable extends Expr {
         }
       }
       if (specifiers != null) {
-        listPartition.specifiers = new ArrayList<ListPartitionSpecifier>();
+        listPartition.specifiers = new ArrayList<>();
         for (ListPartitionSpecifier specifier : specifiers) {
           listPartition.specifiers.add(specifier);
         }

http://git-wip-us.apache.org/repos/asf/tajo/blob/48c7c195/tajo-algebra/src/main/java/org/apache/tajo/algebra/Insert.java
----------------------------------------------------------------------
diff --git a/tajo-algebra/src/main/java/org/apache/tajo/algebra/Insert.java b/tajo-algebra/src/main/java/org/apache/tajo/algebra/Insert.java
index 299a480..8b9df97 100644
--- a/tajo-algebra/src/main/java/org/apache/tajo/algebra/Insert.java
+++ b/tajo-algebra/src/main/java/org/apache/tajo/algebra/Insert.java
@@ -152,7 +152,7 @@ public class Insert extends Expr {
     insert.location = location;
     insert.subquery = (Expr) subquery.clone();
     if (params != null) {
-      insert.params = new HashMap<String, String>(params);
+      insert.params = new HashMap<>(params);
     }
     return insert;
   }

http://git-wip-us.apache.org/repos/asf/tajo/blob/48c7c195/tajo-rpc/tajo-rpc-common/src/main/java/org/apache/tajo/rpc/RpcUtils.java
----------------------------------------------------------------------
diff --git a/tajo-rpc/tajo-rpc-common/src/main/java/org/apache/tajo/rpc/RpcUtils.java b/tajo-rpc/tajo-rpc-common/src/main/java/org/apache/tajo/rpc/RpcUtils.java
index 74c09e5..2ceefe8 100644
--- a/tajo-rpc/tajo-rpc-common/src/main/java/org/apache/tajo/rpc/RpcUtils.java
+++ b/tajo-rpc/tajo-rpc-common/src/main/java/org/apache/tajo/rpc/RpcUtils.java
@@ -70,7 +70,7 @@ public class RpcUtils {
   // non-blocking lock which passes only a ticket before cleared or removed
   public static class Scrutineer<T> {
 
-    private final AtomicReference<T> reference = new AtomicReference<T>();
+    private final AtomicReference<T> reference = new AtomicReference<>();
 
     public T expire() {
       return reference.getAndSet(null);

http://git-wip-us.apache.org/repos/asf/tajo/blob/48c7c195/tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/NettyClientBase.java
----------------------------------------------------------------------
diff --git a/tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/NettyClientBase.java
b/tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/NettyClientBase.java
index c6d90ed..e5485da 100644
--- a/tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/NettyClientBase.java
+++ b/tajo-rpc/tajo-rpc-protobuf/src/main/java/org/apache/tajo/rpc/NettyClientBase.java
@@ -55,8 +55,8 @@ public abstract class NettyClientBase<T> implements ProtoDeclaration,
Closeable
   private boolean enableMonitor;
 
   private final ConcurrentMap<RpcConnectionKey, ChannelEventListener> channelEventListeners
=
-      new ConcurrentHashMap<RpcConnectionKey, ChannelEventListener>();
-  private final ConcurrentMap<Integer, T> requests = new ConcurrentHashMap<Integer,
T>();
+      new ConcurrentHashMap<>();
+  private final ConcurrentMap<Integer, T> requests = new ConcurrentHashMap<>();
 
   public NettyClientBase(RpcConnectionKey rpcConnectionKey, int numRetries)
       throws ClassNotFoundException, NoSuchMethodException {

http://git-wip-us.apache.org/repos/asf/tajo/blob/48c7c195/tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestAsyncRpc.java
----------------------------------------------------------------------
diff --git a/tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestAsyncRpc.java
b/tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestAsyncRpc.java
index 4f17476..8a3f385 100644
--- a/tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestAsyncRpc.java
+++ b/tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestAsyncRpc.java
@@ -214,7 +214,7 @@ public class TestAsyncRpc {
   public void testCallFuture() throws Exception {
     EchoMessage echoMessage = EchoMessage.newBuilder()
         .setMessage(MESSAGE).build();
-    CallFuture<EchoMessage> future = new CallFuture<EchoMessage>();
+    CallFuture<EchoMessage> future = new CallFuture<>();
     stub.delay(future.getController(), echoMessage, future);
 
     assertFalse(future.isDone());
@@ -225,7 +225,7 @@ public class TestAsyncRpc {
   @Test
   public void testCallFutureTimeout() throws Exception {
     boolean timeout = false;
-    CallFuture<EchoMessage> future = new CallFuture<EchoMessage>();
+    CallFuture<EchoMessage> future = new CallFuture<>();
     EchoMessage echoMessage = EchoMessage.newBuilder().setMessage(MESSAGE).build();
     try {
       stub.delay(future.getController(), echoMessage, future);
@@ -242,7 +242,7 @@ public class TestAsyncRpc {
   public void testThrowException() throws Exception {
     EchoMessage echoMessage = EchoMessage.newBuilder()
         .setMessage(MESSAGE).build();
-    CallFuture<EchoMessage> future = new CallFuture<EchoMessage>();
+    CallFuture<EchoMessage> future = new CallFuture<>();
     stub.throwException(future.getController(), echoMessage, future);
 
     assertFalse(future.isDone());
@@ -262,7 +262,7 @@ public class TestAsyncRpc {
   public void testThrowException2() throws Exception {
     EchoMessage echoMessage = EchoMessage.newBuilder()
         .setMessage(MESSAGE).build();
-    CallFuture<EchoMessage> future = new CallFuture<EchoMessage>();
+    CallFuture<EchoMessage> future = new CallFuture<>();
     stub.throwException(null, echoMessage, future);
 
     assertFalse(future.isDone());
@@ -277,7 +277,7 @@ public class TestAsyncRpc {
   public void testServerShutdown1() throws Exception {
     EchoMessage echoMessage = EchoMessage.newBuilder()
         .setMessage(MESSAGE).build();
-    CallFuture<EchoMessage> future = new CallFuture<EchoMessage>();
+    CallFuture<EchoMessage> future = new CallFuture<>();
 
     tearDownRpcServer();
 
@@ -299,7 +299,7 @@ public class TestAsyncRpc {
   public void testServerShutdown2() throws Exception {
     EchoMessage echoMessage = EchoMessage.newBuilder()
         .setMessage(MESSAGE).build();
-    CallFuture<EchoMessage> future = new CallFuture<EchoMessage>();
+    CallFuture<EchoMessage> future = new CallFuture<>();
 
     tearDownRpcServer();
 
@@ -329,7 +329,7 @@ public class TestAsyncRpc {
 
     EchoMessage echoMessage = EchoMessage.newBuilder()
         .setMessage(MESSAGE).build();
-    CallFuture<EchoMessage> future = new CallFuture<EchoMessage>();
+    CallFuture<EchoMessage> future = new CallFuture<>();
 
     //lazy startup
     Thread serverThread = new Thread(new Runnable() {
@@ -375,7 +375,7 @@ public class TestAsyncRpc {
 
     EchoMessage echoMessage = EchoMessage.newBuilder()
         .setMessage(MESSAGE).build();
-    CallFuture<EchoMessage> future = new CallFuture<EchoMessage>();
+    CallFuture<EchoMessage> future = new CallFuture<>();
 
     RpcClientManager.RpcConnectionKey rpcConnectionKey =
         new RpcClientManager.RpcConnectionKey(address, DummyProtocol.class, true);
@@ -439,7 +439,7 @@ public class TestAsyncRpc {
       Interface stub = client.getStub();
       EchoMessage echoMessage = EchoMessage.newBuilder()
           .setMessage(MESSAGE).build();
-      CallFuture<EchoMessage> future = new CallFuture<EchoMessage>();
+      CallFuture<EchoMessage> future = new CallFuture<>();
       stub.echo(future.getController(), echoMessage, future);
 
       assertFalse(future.isDone());
@@ -469,7 +469,7 @@ public class TestAsyncRpc {
 
     for (int i = 0; i < repeat; i++) {
       try {
-        CallFuture<EchoMessage> future = new CallFuture<EchoMessage>();
+        CallFuture<EchoMessage> future = new CallFuture<>();
         stub.echo(future.getController(), echoMessage, future);
         assertEquals(echoMessage, future.get());
         assertTrue(future.isDone());
@@ -531,7 +531,7 @@ public class TestAsyncRpc {
     Interface stub = client.getStub();
     EchoMessage echoMessage = EchoMessage.newBuilder()
         .setMessage(MESSAGE).build();
-    CallFuture<EchoMessage> future = new CallFuture<EchoMessage>();
+    CallFuture<EchoMessage> future = new CallFuture<>();
     stub.delay(future.getController(), echoMessage, future); //3 sec delay
     assertTrue(client.isConnected());
 
@@ -557,7 +557,7 @@ public class TestAsyncRpc {
     Interface stub = client.getStub();
     EchoMessage echoMessage = EchoMessage.newBuilder()
         .setMessage(MESSAGE).build();
-    CallFuture<EchoMessage> future = new CallFuture<EchoMessage>();
+    CallFuture<EchoMessage> future = new CallFuture<>();
     stub.busy(future.getController(), echoMessage, future); //30 sec delay
     assertFalse(future.isDone());
 

http://git-wip-us.apache.org/repos/asf/tajo/blob/48c7c195/tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestRpcClientManager.java
----------------------------------------------------------------------
diff --git a/tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestRpcClientManager.java
b/tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestRpcClientManager.java
index 71a2b6f..1053de6 100644
--- a/tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestRpcClientManager.java
+++ b/tajo-rpc/tajo-rpc-protobuf/src/test/java/org/apache/tajo/rpc/TestRpcClientManager.java
@@ -47,7 +47,7 @@ public class TestRpcClientManager {
       final InetSocketAddress address = server.getListenAddress();
       final RpcClientManager manager = RpcClientManager.getInstance();
 
-      List<Future> tasks = new ArrayList<Future>();
+      List<Future> tasks = new ArrayList<>();
       for (int i = 0; i < parallelCount; i++) {
         tasks.add(executor.submit(new Runnable() {
               @Override

http://git-wip-us.apache.org/repos/asf/tajo/blob/48c7c195/tajo-rpc/tajo-ws-rs/src/main/java/org/apache/tajo/ws/rs/netty/gson/GsonFeature.java
----------------------------------------------------------------------
diff --git a/tajo-rpc/tajo-ws-rs/src/main/java/org/apache/tajo/ws/rs/netty/gson/GsonFeature.java
b/tajo-rpc/tajo-ws-rs/src/main/java/org/apache/tajo/ws/rs/netty/gson/GsonFeature.java
index 20d7181..6db91f8 100644
--- a/tajo-rpc/tajo-ws-rs/src/main/java/org/apache/tajo/ws/rs/netty/gson/GsonFeature.java
+++ b/tajo-rpc/tajo-ws-rs/src/main/java/org/apache/tajo/ws/rs/netty/gson/GsonFeature.java
@@ -37,7 +37,7 @@ public class GsonFeature implements Feature {
   }
   
   public GsonFeature(Map<Type, GsonSerDerAdapter<?>> adapterMap) {
-    this.adapterMap = new HashMap<Type, GsonSerDerAdapter<?>>(adapterMap.size());
+    this.adapterMap = new HashMap<>(adapterMap.size());
     this.adapterMap.putAll(adapterMap);
   }
 

http://git-wip-us.apache.org/repos/asf/tajo/blob/48c7c195/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/NettyRestServerTest.java
----------------------------------------------------------------------
diff --git a/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/NettyRestServerTest.java
b/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/NettyRestServerTest.java
index d8a57bf..90d96e7 100644
--- a/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/NettyRestServerTest.java
+++ b/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/NettyRestServerTest.java
@@ -119,7 +119,7 @@ public class NettyRestServerTest {
       assertEquals(directory1.getOwner(), fetchedDirectory.getOwner());
       assertEquals(directory1.getGroup(), fetchedDirectory.getGroup());
 
-      GenericType<Collection<Directory>> directoryType = new GenericType<Collection<Directory>>(Collection.class);
+      GenericType<Collection<Directory>> directoryType = new GenericType<>(Collection.class);
       Collection<Directory> directories = restClient.target(directoriesUri).request().get(directoryType);
 
       assertEquals(1, directories.size());

http://git-wip-us.apache.org/repos/asf/tajo/blob/48c7c195/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp1/TestApplication1.java
----------------------------------------------------------------------
diff --git a/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp1/TestApplication1.java
b/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp1/TestApplication1.java
index 3531b3a..ef8421a 100644
--- a/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp1/TestApplication1.java
+++ b/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp1/TestApplication1.java
@@ -27,7 +27,7 @@ public class TestApplication1 extends Application {
   private final Set<Class<?>> classes;
 
   public TestApplication1() {
-    classes = new HashSet<Class<?>>();
+    classes = new HashSet<>();
     classes.add(TestResource1.class);
   }
 

http://git-wip-us.apache.org/repos/asf/tajo/blob/48c7c195/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp2/DirectoriesDao.java
----------------------------------------------------------------------
diff --git a/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp2/DirectoriesDao.java
b/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp2/DirectoriesDao.java
index 0e82e00..8cdcc1a 100644
--- a/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp2/DirectoriesDao.java
+++ b/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp2/DirectoriesDao.java
@@ -24,7 +24,7 @@ import java.util.concurrent.ConcurrentHashMap;
 public class DirectoriesDao {
   private static DirectoriesDao instance = new DirectoriesDao();
 
-  private final Map<String, Directory> directoryMap = new ConcurrentHashMap<String,
Directory>();
+  private final Map<String, Directory> directoryMap = new ConcurrentHashMap<>();
 
   private DirectoriesDao() {
   }

http://git-wip-us.apache.org/repos/asf/tajo/blob/48c7c195/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp2/DirectoriesResource.java
----------------------------------------------------------------------
diff --git a/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp2/DirectoriesResource.java
b/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp2/DirectoriesResource.java
index 40f1ced..fb48d62 100644
--- a/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp2/DirectoriesResource.java
+++ b/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp2/DirectoriesResource.java
@@ -34,7 +34,7 @@ public class DirectoriesResource {
   public Response getAllDirectories() {
     Collection<Directory> directories = DirectoriesDao.getInstance().getDirectoryMap().values();
     GenericEntity<Collection<Directory>> dirEntities =
-        new GenericEntity<Collection<Directory>>(directories, Collection.class);
+        new GenericEntity<>(directories, Collection.class);
     return Response.ok(dirEntities).build();
   }
 

http://git-wip-us.apache.org/repos/asf/tajo/blob/48c7c195/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp2/FileManagementApplication.java
----------------------------------------------------------------------
diff --git a/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp2/FileManagementApplication.java
b/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp2/FileManagementApplication.java
index 49026a0..0917dc1 100644
--- a/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp2/FileManagementApplication.java
+++ b/tajo-rpc/tajo-ws-rs/src/test/java/org/apache/tajo/ws/rs/netty/testapp2/FileManagementApplication.java
@@ -26,7 +26,7 @@ public class FileManagementApplication extends Application {
 
   @Override
   public Set<Class<?>> getClasses() {
-    Set<Class<?>> classes = new HashSet<Class<?>>();
+    Set<Class<?>> classes = new HashSet<>();
 
     classes.add(DirectoriesResource.class);
 


Mime
View raw message