org.apache.hive.beeline

Class BeeLine

java.lang.Object

org.apache.hive.beeline.BeeLine

All Implemented Interfaces:

Closeable, AutoCloseable

public class BeeLine
extends Object
implements Closeable

A console SQL shell with command completion.

TODO:

• User-friendly connection prompts
• Page results
• Handle binary data (blob fields)
• Implement command aliases
• Stored procedure execution
• Binding parameters to prepared statements
• Scripting language
• XA transactions

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	BeeLine.BeelineParser

Field Summary

Fields

Modifier and Type	Field and Description
static String	BEELINE_DEFAULT_JDBC_DRIVER
static String	BEELINE_DEFAULT_JDBC_URL
static String	COMMAND_PREFIX

Constructor Summary

Constructors

Constructor and Description
BeeLine()

Method Summary

Methods

Modifier and Type	Method and Description
void	addLocalDriverClazz(String driverClazz)
int	begin(String[] args, InputStream inputStream) Start accepting input from stdin, and dispatch it to the appropriate CommandHandler until the global variable exit is true.
void	close()
Driver	findLocalDriver(String url)
String[]	getConnectionURLExamples()
jline.console.ConsoleReader	getConsoleReader(InputStream inputStream)
String[]	getIsolationLevels()
String[]	getMetadataMethodNames()
org.apache.hive.beeline.BeeLineOpts	getOpts()
protected org.apache.hive.beeline.Reflector	getReflector()
static String	getSeparator()
boolean	isExit()
boolean	isSupportedLocalDriver(Driver driver)
protected String	locElapsedTime(long milliseconds)
static void	main(String[] args) Starts the program.
static void	mainWithInputRedirection(String[] args, InputStream inputStream) Starts the program with redirected input.
int	runCommands(List<String> cmds)
int	runCommands(String[] cmds)
void	setErrorStream(PrintStream errorStream)
void	setExit(boolean exit)
void	setOutputStream(PrintStream outputStream)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

COMMAND_PREFIX

public static final String COMMAND_PREFIX

See Also:

Constant Field Values

BEELINE_DEFAULT_JDBC_DRIVER

public static final String BEELINE_DEFAULT_JDBC_DRIVER

See Also:

Constant Field Values

BEELINE_DEFAULT_JDBC_URL

public static final String BEELINE_DEFAULT_JDBC_URL

See Also:

Constant Field Values

Constructor Detail

BeeLine

public BeeLine()

Method Detail

locElapsedTime

protected String locElapsedTime(long milliseconds)

main

public static void main(String[] args)
                 throws IOException

Starts the program.

Throws:

IOException

mainWithInputRedirection

public static void mainWithInputRedirection(String[] args,
                            InputStream inputStream)
                                     throws IOException

Starts the program with redirected input. For redirected output, setOutputStream() and setErrorStream can be used. Exits with 0 on success, 1 on invalid arguments, and 2 on any other error

Parameters:

args - same as main()

inputStream - redirected input, or null to use standard input

Throws:

IOException

getIsolationLevels

public String[] getIsolationLevels()

getMetadataMethodNames

public String[] getMetadataMethodNames()

getConnectionURLExamples

public String[] getConnectionURLExamples()

begin

public int begin(String[] args,
        InputStream inputStream)
          throws IOException

Start accepting input from stdin, and dispatch it to the appropriate CommandHandler until the global variable exit is true.

Throws:

IOException

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

getConsoleReader

public jline.console.ConsoleReader getConsoleReader(InputStream inputStream)
                                             throws IOException

Throws:

IOException

findLocalDriver

public Driver findLocalDriver(String url)
                       throws Exception

Throws:

Exception

isSupportedLocalDriver

public boolean isSupportedLocalDriver(Driver driver)

addLocalDriverClazz

public void addLocalDriverClazz(String driverClazz)

runCommands

public int runCommands(String[] cmds)

runCommands

public int runCommands(List<String> cmds)

getOpts

public org.apache.hive.beeline.BeeLineOpts getOpts()

isExit

public boolean isExit()

setExit

public void setExit(boolean exit)

getSeparator

public static String getSeparator()

setOutputStream

public void setOutputStream(PrintStream outputStream)

setErrorStream

public void setErrorStream(PrintStream errorStream)

getReflector

protected org.apache.hive.beeline.Reflector getReflector()