diff --git beeline/src/java/org/apache/hive/beeline/BeeLine.java beeline/src/java/org/apache/hive/beeline/BeeLine.java index dcdd6f2..2f3350e 100644 --- beeline/src/java/org/apache/hive/beeline/BeeLine.java +++ beeline/src/java/org/apache/hive/beeline/BeeLine.java @@ -24,6 +24,7 @@ import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; +import java.io.Closeable; import java.io.EOFException; import java.io.File; import java.io.FileInputStream; @@ -76,7 +77,9 @@ import jline.Completor; import jline.ConsoleReader; import jline.FileNameCompletor; +import jline.History; import jline.SimpleCompletor; +import org.apache.hadoop.io.IOUtils; import org.apache.commons.cli.CommandLine; import org.apache.commons.cli.GnuParser; @@ -101,7 +104,7 @@ * * */ -public class BeeLine { +public class BeeLine implements Closeable { private static final ResourceBundle resourceBundle = ResourceBundle.getBundle(BeeLine.class.getSimpleName()); private final BeeLineSignalHandler signalHandler = null; @@ -123,6 +126,8 @@ private List batch = null; private final Reflector reflector; + private History history; + private static final Options options = new Options(); public static final String BEELINE_DEFAULT_JDBC_DRIVER = "org.apache.hive.jdbc.HiveDriver"; @@ -291,6 +296,13 @@ .withDescription("the authentication type") .create('a')); + // -i + options.addOption(OptionBuilder + .hasArg() + .withArgName("init") + .withDescription("script file for initialization") + .create('i')); + // -e options.addOption(OptionBuilder .hasArgs() @@ -298,7 +310,7 @@ .withDescription("query that should be executed") .create('e')); - // -f + // -f