You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tajo.apache.org by hy...@apache.org on 2015/09/14 18:54:49 UTC
tajo git commit: TAJO-1841: Eliminate explicit diamond expressions in
tajo-{algebra, rpc}
Repository: tajo
Updated Branches:
refs/heads/master 8bbd51df2 -> 882eaa66a
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/882eaa66
Tree: http://git-wip-us.apache.org/repos/asf/tajo/tree/882eaa66
Diff: http://git-wip-us.apache.org/repos/asf/tajo/diff/882eaa66
Branch: refs/heads/master
Commit: 882eaa66a2a4def989e39bd9bf9f64e92a833abb
Parents: 8bbd51d
Author: Hyunsik Choi <hy...@apache.org>
Authored: Mon Sep 14 08:48:49 2015 -0700
Committer: Hyunsik Choi <hy...@apache.org>
Committed: Mon Sep 14 08:48:49 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/882eaa66/CHANGES
----------------------------------------------------------------------
diff --git a/CHANGES b/CHANGES
index 468a7a3..5b85848 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/882eaa66/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/882eaa66/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/882eaa66/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/882eaa66/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/882eaa66/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/882eaa66/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/882eaa66/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/882eaa66/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/882eaa66/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/882eaa66/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/882eaa66/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/882eaa66/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/882eaa66/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/882eaa66/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);