@Test public void testDefaultSocketTimeout() { Map<String, String> options = dialect.getDatabaseType().getDefaultOptions(); assertThat( options, IsMapWithSize.aMapWithSize( 1 ) ); assertThat( options, IsMapContaining.hasEntry( Joiner.on( "." ).join( SparkSimbaDatabaseDialect.DB_TYPE_NAME_SHORT, Hive2SimbaDatabaseDialect.SOCKET_TIMEOUT_OPTION ), Hive2SimbaDatabaseDialect.DEFAULT_SOCKET_TIMEOUT ) ); }
public IDatabaseType getDatabaseType() { return DBTYPE; }
SparkSimbaDatabaseDialect extends Hive2SimbaDatabaseDialect { public IDatabaseType getDatabaseType() { return DBTYPE; } }
SparkSimbaDatabaseDialect extends Hive2SimbaDatabaseDialect { public IDatabaseType getDatabaseType() { return DBTYPE; } SparkSimbaDatabaseDialect(); }
SparkSimbaDatabaseDialect extends Hive2SimbaDatabaseDialect { public IDatabaseType getDatabaseType() { return DBTYPE; } SparkSimbaDatabaseDialect(); IDatabaseType getDatabaseType(); @Override String getNativeDriver(); @Override String getNativeJdbcPre(); @Override int getDefaultDatabasePort(); @Override String[] getUsedLibraries(); }
SparkSimbaDatabaseDialect extends Hive2SimbaDatabaseDialect { public IDatabaseType getDatabaseType() { return DBTYPE; } SparkSimbaDatabaseDialect(); IDatabaseType getDatabaseType(); @Override String getNativeDriver(); @Override String getNativeJdbcPre(); @Override int getDefaultDatabasePort(); @Override String[] getUsedLibraries(); static final String DB_TYPE_NAME_SHORT; }