org.apache.drill.exec.store.sys.store.provider

Class LocalPersistentStoreProvider

java.lang.Object

org.apache.drill.exec.store.sys.store.provider.BasePersistentStoreProvider

org.apache.drill.exec.store.sys.store.provider.LocalPersistentStoreProvider

All Implemented Interfaces:

AutoCloseable, PersistentStoreProvider

public class LocalPersistentStoreProvider
extends BasePersistentStoreProvider

A really simple provider that stores data in the local file system, one value per file.

Constructor Summary

Constructors

Constructor and Description
LocalPersistentStoreProvider(DrillConfig config)
LocalPersistentStoreProvider(PersistentStoreRegistry<?> registry)

Method Summary

Modifier and Type	Method and Description
void	close()
<V> PersistentStore<V>	getOrCreateStore(PersistentStoreConfig<V> storeConfig) Gets or creates a persistent store for the given configuration.
<V> VersionedPersistentStore<V>	getOrCreateVersionedStore(PersistentStoreConfig<V> config) Override this method if store supports versioning and return versioning instance.

Methods inherited from class org.apache.drill.exec.store.sys.store.provider.BasePersistentStoreProvider

start

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalPersistentStoreProvider

public LocalPersistentStoreProvider(PersistentStoreRegistry<?> registry)
                             throws StoreException

Throws:

StoreException

LocalPersistentStoreProvider

public LocalPersistentStoreProvider(DrillConfig config)
                             throws StoreException

Throws:

StoreException

Method Detail

getOrCreateStore

public <V> PersistentStore<V> getOrCreateStore(PersistentStoreConfig<V> storeConfig)

Description copied from interface: PersistentStoreProvider

Gets or creates a persistent store for the given configuration. Note that implementors have liberty to cache previous store instances.

Type Parameters:

V - store value type

Parameters:

storeConfig - store configuration

Returns:

persistent store instance

getOrCreateVersionedStore

public <V> VersionedPersistentStore<V> getOrCreateVersionedStore(PersistentStoreConfig<V> config)

Description copied from interface: PersistentStoreProvider

Override this method if store supports versioning and return versioning instance. By default, undefined version wrapper will be used.

Type Parameters:

V - store value type

Parameters:

config - store configuration

Returns:

versioned persistent store instance

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Overrides:

close in class BasePersistentStoreProvider

Throws:

Exception