cascading.lingual.jdbc
Class Driver

java.lang.Object
  net.hydromatic.optiq.jdbc.UnregisteredDriver
      cascading.lingual.jdbc.Driver

All Implemented Interfaces:

Driver

public class Driver
extends net.hydromatic.optiq.jdbc.UnregisteredDriver

Lingual JDBC driver.

The JDBC Driver connection string consists of the following parts:

jdbc:lingual:[platform]

Optionally, the following parameters can be added

• catalog=[path] - the working directory where your .lingual workspace is kept
• schema=[name] - set the default schema name to use
• schemas=[path,path] - URI paths to the set of schema/tables to install in the catalog
• resultPath=[path] - temporary root path for result sets to be stored
• flowPlanPath=[path] - for debugging, print the corresponding Flow dot file here
• sqlPlanPath=[path] - for debugging, print the corresponding SQL plan file here

For example, using Cascading local mode, and to load all the subdirectories of ./employees/ as tables, use the following connection string:

jdbc:lingual:local;schemas=./employees/

This will create a schema called "employees" and every file underneath (files as opposed to directories on Hadoop) will become tables named after the base-name of the file (minus the extension).

Nested Class Summary

Nested classes/interfaces inherited from class net.hydromatic.optiq.jdbc.UnregisteredDriver

net.hydromatic.optiq.jdbc.UnregisteredDriver.JdbcVersion

Field Summary

static String	CATALOG_PROP
static String	COLLECTOR_CACHE_PROP
static String	FLOW_PLAN_PATH
static String	MAX_ROWS
static String	PLANNER_DEBUG
static String	PLATFORM_PROP
static String	RESULT_PATH_PROP
static String	SCHEMA_PROP
static String	SCHEMAS_PROP
static String	SQL_PLAN_PATH_PROP
static String	TABLES_PROP
static String	VERBOSE_PROP

Constructor Summary

Driver()

Method Summary

Connection	connect(String url, Properties info)
protected net.hydromatic.optiq.jdbc.DriverVersion	createDriverVersion()
protected net.hydromatic.linq4j.function.Function0<net.hydromatic.optiq.jdbc.OptiqPrepare>	createPrepareFactory()
protected String	getConnectStringPrefix()
protected void	register()

Methods inherited from class net.hydromatic.optiq.jdbc.UnregisteredDriver

acceptsURL, createFactory, createHandler, getDriverVersion, getFactoryClassName, getMajorVersion, getMinorVersion, getParentLogger, getPropertyInfo, instantiateFactory, jdbcCompliant

Methods inherited from class java.lang.Object

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

Field Detail

PLATFORM_PROP

public static final String PLATFORM_PROP

See Also:

Constant Field Values

CATALOG_PROP

public static final String CATALOG_PROP

See Also:

Constant Field Values

SCHEMA_PROP

public static final String SCHEMA_PROP

See Also:

Constant Field Values

SCHEMAS_PROP

public static final String SCHEMAS_PROP

See Also:

Constant Field Values

TABLES_PROP

public static final String TABLES_PROP

See Also:

Constant Field Values

VERBOSE_PROP

public static final String VERBOSE_PROP

See Also:

Constant Field Values

RESULT_PATH_PROP

public static final String RESULT_PATH_PROP

See Also:

Constant Field Values

MAX_ROWS

public static final String MAX_ROWS

See Also:

Constant Field Values

FLOW_PLAN_PATH

public static final String FLOW_PLAN_PATH

See Also:

Constant Field Values

SQL_PLAN_PATH_PROP

public static final String SQL_PLAN_PATH_PROP

See Also:

Constant Field Values

COLLECTOR_CACHE_PROP

public static final String COLLECTOR_CACHE_PROP

See Also:

Constant Field Values

PLANNER_DEBUG

public static final String PLANNER_DEBUG

See Also:

Constant Field Values

Constructor Detail

Driver

public Driver()

Method Detail

getConnectStringPrefix

protected String getConnectStringPrefix()

Specified by:

getConnectStringPrefix in class net.hydromatic.optiq.jdbc.UnregisteredDriver

register

protected void register()

Overrides:

register in class net.hydromatic.optiq.jdbc.UnregisteredDriver

createDriverVersion

protected net.hydromatic.optiq.jdbc.DriverVersion createDriverVersion()

Specified by:

createDriverVersion in class net.hydromatic.optiq.jdbc.UnregisteredDriver

createPrepareFactory

protected net.hydromatic.linq4j.function.Function0<net.hydromatic.optiq.jdbc.OptiqPrepare> createPrepareFactory()

Overrides:

createPrepareFactory in class net.hydromatic.optiq.jdbc.UnregisteredDriver

connect

public Connection connect(String url,
                          Properties info)
                   throws SQLException

Specified by:

connect in interface Driver

Overrides:

connect in class net.hydromatic.optiq.jdbc.UnregisteredDriver

Throws:

SQLException