org.apache.beam.sdk.io.hcatalog.test

Class EmbeddedMetastoreService

java.lang.Object

org.apache.beam.sdk.io.hcatalog.test.EmbeddedMetastoreService

All Implemented Interfaces:

java.lang.AutoCloseable

@Internal
public final class EmbeddedMetastoreService
extends java.lang.Object
implements java.lang.AutoCloseable

Implementation of a light-weight embedded metastore. This class is a trimmed-down version of https://github.com/apache/hive/blob/master/hcatalog/core/src/test/java/org/apache/hive/hcatalog/mapreduce/HCatBaseTest.java

Used only for testing.

Constructor Summary

Constructors

Constructor and Description
EmbeddedMetastoreService(java.lang.String baseDirPath)

Method Summary

Modifier and Type	Method and Description
void	close()
void	executeQuery(java.lang.String query) Executes the passed query on the embedded metastore service.
org.apache.hadoop.hive.conf.HiveConf	getHiveConf() Returns the HiveConf object for the embedded metastore.
java.util.Map<java.lang.String,java.lang.String>	getHiveConfAsMap()

Methods inherited from class java.lang.Object

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

Constructor Detail

EmbeddedMetastoreService

public EmbeddedMetastoreService(java.lang.String baseDirPath)
                         throws java.io.IOException

Throws:

java.io.IOException

Method Detail

executeQuery

public void executeQuery(java.lang.String query)

Executes the passed query on the embedded metastore service.

getHiveConf

public org.apache.hadoop.hive.conf.HiveConf getHiveConf()

Returns the HiveConf object for the embedded metastore.

getHiveConfAsMap

public java.util.Map<java.lang.String,java.lang.String> getHiveConfAsMap()

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception