SparkSimbaDatabaseDialect extends Hive2SimbaDatabaseDialect { @Override public String getNativeJdbcPre() { return SparkSimbaDatabaseMeta.JDBC_URL_PREFIX; } SparkSimbaDatabaseDialect(); IDatabaseType getDatabaseType(); @Override String getNativeDriver(); @Override String getNativeJdbcPre(); @Override int getDefaultDatabasePort(); @Override String[] getUsedLibraries(); static final String DB_TYPE_NAME_SHORT; }
@Test public void getNativeJdbcPre() throws Exception { assertThat( dialect.getNativeJdbcPre(), is( "jdbc:spark: }