diff --git a/beeline/src/java/org/apache/hive/beeline/AbstractOutputFormat.java b/beeline/src/java/org/apache/hive/beeline/AbstractOutputFormat.java index b0e2357d2f..aa807808a2 100644 --- a/beeline/src/java/org/apache/hive/beeline/AbstractOutputFormat.java +++ b/beeline/src/java/org/apache/hive/beeline/AbstractOutputFormat.java @@ -28,6 +28,7 @@ */ abstract class AbstractOutputFormat implements OutputFormat { + @Override public int print(Rows rows) { int count = 0; Rows.Row header = (Rows.Row) rows.next(); diff --git a/beeline/src/java/org/apache/hive/beeline/BeeLine.java b/beeline/src/java/org/apache/hive/beeline/BeeLine.java index 65ec560950..dc79712054 100644 --- a/beeline/src/java/org/apache/hive/beeline/BeeLine.java +++ b/beeline/src/java/org/apache/hive/beeline/BeeLine.java @@ -1878,7 +1878,7 @@ static String getPromptForBeeline(String url) { */ int getSize(ResultSet rs) { try { - if (rs.getType() == rs.TYPE_FORWARD_ONLY) { + if (rs.getType() == ResultSet.TYPE_FORWARD_ONLY) { return -1; } rs.last(); diff --git a/beeline/src/java/org/apache/hive/beeline/BeeLineCompleter.java b/beeline/src/java/org/apache/hive/beeline/BeeLineCompleter.java index 9c20c57a87..9213bcf767 100644 --- a/beeline/src/java/org/apache/hive/beeline/BeeLineCompleter.java +++ b/beeline/src/java/org/apache/hive/beeline/BeeLineCompleter.java @@ -41,6 +41,7 @@ this.beeLine = beeLine; } + @Override public int complete(String buf, int pos, List cand) { if (buf != null && buf.startsWith(BeeLine.COMMAND_PREFIX) && !buf.startsWith(BeeLine.COMMAND_PREFIX + "all") diff --git a/beeline/src/java/org/apache/hive/beeline/ColorBuffer.java b/beeline/src/java/org/apache/hive/beeline/ColorBuffer.java index 1730d492d7..ba7b4be3fc 100644 --- a/beeline/src/java/org/apache/hive/beeline/ColorBuffer.java +++ b/beeline/src/java/org/apache/hive/beeline/ColorBuffer.java @@ -236,6 +236,7 @@ public String toString() { } } + @Override public int compareTo(Object other) { return getMono().compareTo(((ColorBuffer) other).getMono()); } diff --git a/beeline/src/java/org/apache/hive/beeline/IncrementalRows.java b/beeline/src/java/org/apache/hive/beeline/IncrementalRows.java index e8af3c3332..c462084a9b 100644 --- a/beeline/src/java/org/apache/hive/beeline/IncrementalRows.java +++ b/beeline/src/java/org/apache/hive/beeline/IncrementalRows.java @@ -63,6 +63,7 @@ } + @Override public boolean hasNext() { if (endOfResult) { return false; @@ -87,6 +88,7 @@ public boolean hasNext() { return (nextRow != null); } + @Override public Object next() { if (!hasNext()) { throw new NoSuchElementException(); diff --git a/beeline/src/java/org/apache/hive/beeline/ReflectiveCommandHandler.java b/beeline/src/java/org/apache/hive/beeline/ReflectiveCommandHandler.java index 2854f151c0..a37ee89142 100644 --- a/beeline/src/java/org/apache/hive/beeline/ReflectiveCommandHandler.java +++ b/beeline/src/java/org/apache/hive/beeline/ReflectiveCommandHandler.java @@ -46,6 +46,7 @@ public ReflectiveCommandHandler(BeeLine beeLine, String[] cmds, Completer[] comp this.beeLine = beeLine; } + @Override public boolean execute(String line) { lastException = null; ClientHook hook = ClientCommandHookFactory.get().getHook(beeLine, line); diff --git a/beeline/src/java/org/apache/hive/beeline/TableNameCompletor.java b/beeline/src/java/org/apache/hive/beeline/TableNameCompletor.java index 0c220e49f4..1eefe17882 100644 --- a/beeline/src/java/org/apache/hive/beeline/TableNameCompletor.java +++ b/beeline/src/java/org/apache/hive/beeline/TableNameCompletor.java @@ -37,6 +37,7 @@ this.beeLine = beeLine; } + @Override public int complete(String buf, int pos, List cand) { if (beeLine.getDatabaseConnection() == null) { return -1; diff --git a/beeline/src/java/org/apache/hive/beeline/TableOutputFormat.java b/beeline/src/java/org/apache/hive/beeline/TableOutputFormat.java index 8482f85b00..f8b8b9cb2f 100644 --- a/beeline/src/java/org/apache/hive/beeline/TableOutputFormat.java +++ b/beeline/src/java/org/apache/hive/beeline/TableOutputFormat.java @@ -37,6 +37,7 @@ this.beeLine = beeLine; } + @Override public int print(Rows rows) { int index = 0; ColorBuffer header = null; diff --git a/beeline/src/java/org/apache/hive/beeline/VerticalOutputFormat.java b/beeline/src/java/org/apache/hive/beeline/VerticalOutputFormat.java index a9488a469e..e6458ace2b 100644 --- a/beeline/src/java/org/apache/hive/beeline/VerticalOutputFormat.java +++ b/beeline/src/java/org/apache/hive/beeline/VerticalOutputFormat.java @@ -36,6 +36,7 @@ this.beeLine = beeLine; } + @Override public int print(Rows rows) { int count = 0; Rows.Row header = (Rows.Row) rows.next(); diff --git a/beeline/src/java/org/apache/hive/beeline/hs2connection/HS2ConnectionFileUtils.java b/beeline/src/java/org/apache/hive/beeline/hs2connection/HS2ConnectionFileUtils.java index 7c064cfda9..dff2e4d3e0 100644 --- a/beeline/src/java/org/apache/hive/beeline/hs2connection/HS2ConnectionFileUtils.java +++ b/beeline/src/java/org/apache/hive/beeline/hs2connection/HS2ConnectionFileUtils.java @@ -22,10 +22,7 @@ import java.util.Collections; import java.util.List; import java.util.Map; -import java.util.Map.Entry; import java.util.Properties; -import java.util.Set; - import org.apache.hive.jdbc.Utils.JdbcConnectionParams; public class HS2ConnectionFileUtils { diff --git a/beeline/src/test/org/apache/hive/beeline/ProxyAuthTest.java b/beeline/src/test/org/apache/hive/beeline/ProxyAuthTest.java index 74aed14d8d..52f3ebfe32 100644 --- a/beeline/src/test/org/apache/hive/beeline/ProxyAuthTest.java +++ b/beeline/src/test/org/apache/hive/beeline/ProxyAuthTest.java @@ -26,13 +26,10 @@ import java.sql.Statement; import org.apache.commons.io.FileUtils; -import org.apache.commons.io.IOUtils; -import org.apache.hadoop.conf.Configuration; import org.apache.hive.jdbc.HiveConnection; import org.apache.hive.service.auth.HiveAuthConstants; import org.apache.hive.service.cli.session.SessionUtils; import org.apache.hive.beeline.BeeLine; -import org.apache.hadoop.hive.shims.ShimLoader; import org.apache.hadoop.hive.shims.Utils; /** diff --git a/beeline/src/test/org/apache/hive/beeline/TestBeeLineExceptionHandling.java b/beeline/src/test/org/apache/hive/beeline/TestBeeLineExceptionHandling.java index 14124b046a..e8e56f0abf 100644 --- a/beeline/src/test/org/apache/hive/beeline/TestBeeLineExceptionHandling.java +++ b/beeline/src/test/org/apache/hive/beeline/TestBeeLineExceptionHandling.java @@ -20,15 +20,7 @@ import org.junit.Assert; import org.apache.thrift.transport.TTransportException; import org.junit.Test; -import org.mockito.ArgumentCaptor; - import java.sql.SQLException; -import java.util.ArrayList; -import java.util.List; - -import static org.mockito.Mockito.mock; -import static org.mockito.Mockito.verify; -import static org.mockito.Mockito.when; public class TestBeeLineExceptionHandling { diff --git a/beeline/src/test/org/apache/hive/beeline/TestBeeLineOpts.java b/beeline/src/test/org/apache/hive/beeline/TestBeeLineOpts.java index 5c0c9701f8..593c217ab7 100644 --- a/beeline/src/test/org/apache/hive/beeline/TestBeeLineOpts.java +++ b/beeline/src/test/org/apache/hive/beeline/TestBeeLineOpts.java @@ -18,15 +18,7 @@ package org.apache.hive.beeline; import org.junit.Assert; -import org.junit.BeforeClass; import org.junit.Test; -import org.mockito.ArgumentCaptor; - -import java.io.*; -import java.sql.Connection; -import java.sql.SQLException; -import java.util.Properties; - import static org.mockito.Mockito.*; public class TestBeeLineOpts { diff --git a/beeline/src/test/org/apache/hive/beeline/TestBeelineArgParsing.java b/beeline/src/test/org/apache/hive/beeline/TestBeelineArgParsing.java index c632dd3d12..dcedbc28ee 100644 --- a/beeline/src/test/org/apache/hive/beeline/TestBeelineArgParsing.java +++ b/beeline/src/test/org/apache/hive/beeline/TestBeelineArgParsing.java @@ -38,7 +38,6 @@ import org.slf4j.LoggerFactory; import org.apache.hive.common.util.HiveTestUtils; import org.junit.Assert; -import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; import org.junit.runners.Parameterized; diff --git a/beeline/src/test/org/apache/hive/beeline/TestBufferedRows.java b/beeline/src/test/org/apache/hive/beeline/TestBufferedRows.java index db44d6b16a..9478ec5880 100644 --- a/beeline/src/test/org/apache/hive/beeline/TestBufferedRows.java +++ b/beeline/src/test/org/apache/hive/beeline/TestBufferedRows.java @@ -87,6 +87,7 @@ private void setupMockData() throws SQLException { when(mockResultSet.next()).thenAnswer(new Answer() { private int mockRowDataIndex = 0; + @Override public Boolean answer(InvocationOnMock invocation) { if (mockRowDataIndex < mockRowData.length) { mockRow.setCurrentRowData(mockRowData[mockRowDataIndex]); @@ -99,6 +100,7 @@ public Boolean answer(InvocationOnMock invocation) { }); when(mockResultSet.getObject(Matchers.anyInt())).thenAnswer(new Answer() { + @Override public String answer(InvocationOnMock invocation) { Object[] args = invocation.getArguments(); int index = ((Integer) args[0]).intValue(); diff --git a/beeline/src/test/org/apache/hive/beeline/TestClientCommandHookFactory.java b/beeline/src/test/org/apache/hive/beeline/TestClientCommandHookFactory.java index 34f628ef1b..7b542a2326 100644 --- a/beeline/src/test/org/apache/hive/beeline/TestClientCommandHookFactory.java +++ b/beeline/src/test/org/apache/hive/beeline/TestClientCommandHookFactory.java @@ -20,10 +20,7 @@ import static org.mockito.Mockito.mock; import static org.mockito.Mockito.when; import static org.mockito.Mockito.verify; -import static org.mockito.Mockito.times; - import org.junit.Assert; -import org.junit.BeforeClass; import org.junit.Test; import org.mockito.ArgumentCaptor; diff --git a/beeline/src/test/org/apache/hive/beeline/TestShutdownHook.java b/beeline/src/test/org/apache/hive/beeline/TestShutdownHook.java index 8787cb18a9..73e6f3eb57 100644 --- a/beeline/src/test/org/apache/hive/beeline/TestShutdownHook.java +++ b/beeline/src/test/org/apache/hive/beeline/TestShutdownHook.java @@ -19,14 +19,8 @@ package org.apache.hive.beeline; import java.io.ByteArrayOutputStream; -import java.io.File; import java.io.PrintStream; -import java.io.PrintWriter; -import java.lang.reflect.Method; - -import org.junit.AfterClass; import org.junit.Assert; -import org.junit.BeforeClass; import org.junit.Test; public class TestShutdownHook {