diff --git beeline/src/java/org/apache/hive/beeline/BeeLine.java beeline/src/java/org/apache/hive/beeline/BeeLine.java index 5773109..e0e540a 100644 --- beeline/src/java/org/apache/hive/beeline/BeeLine.java +++ beeline/src/java/org/apache/hive/beeline/BeeLine.java @@ -22,12 +22,10 @@ */ package org.apache.hive.beeline; -import java.io.ByteArrayInputStream; -import java.io.ByteArrayOutputStream; +import java.io.Closeable; import java.io.EOFException; import java.io.File; import java.io.FileInputStream; -import java.io.FileWriter; import java.io.IOException; import java.io.InputStream; import java.io.PrintStream; @@ -76,7 +74,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 +101,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 +123,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 +293,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 +307,7 @@ .withDescription("query that should be executed") .create('e')); - // -f + // -f