Class LocalPersistentStore<V>
java.lang.Object
org.apache.drill.exec.store.sys.BasePersistentStore<V>
org.apache.drill.exec.store.sys.store.LocalPersistentStore<V>
- Type Parameters:
V
- store data type
- All Implemented Interfaces:
AutoCloseable
,PersistentStore<V>
,Store<V>
Local persistent store stores its data on the given file system.
Data is stored in the files with key name as a base and
ExecConstants.DRILL_SYS_FILE_SUFFIX
suffix.-
Constructor Summary
ConstructorDescriptionLocalPersistentStore
(DrillFileSystem fs, org.apache.hadoop.fs.Path base, PersistentStoreConfig<V> config) -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
boolean
Checks if lookup key is present in store.void
Removes the value corresponding to the given key if exists, nothing happens otherwise.Returns the value for the given key if exists, null otherwise.static DrillFileSystem
getFileSystem
(DrillConfig config, org.apache.hadoop.fs.Path root) static org.apache.hadoop.fs.Path
getMode()
Returns storagemode
of this store.getRange
(int skip, int take) Returns an iterator of desired number of entries offsetting by the skip value.void
Stores the (key, value) tuple in the store.boolean
putIfAbsent
(String key, V value) Stores the (key, value) tuple in the store only if it does not exists.Methods inherited from class org.apache.drill.exec.store.sys.BasePersistentStore
getAll
-
Constructor Details
-
LocalPersistentStore
public LocalPersistentStore(DrillFileSystem fs, org.apache.hadoop.fs.Path base, PersistentStoreConfig<V> config)
-
-
Method Details
-
getMode
Description copied from interface:Store
Returns storagemode
of this store. -
getLogDir
public static org.apache.hadoop.fs.Path getLogDir() -
getFileSystem
public static DrillFileSystem getFileSystem(DrillConfig config, org.apache.hadoop.fs.Path root) throws IOException - Throws:
IOException
-
getRange
Description copied from interface:Store
Returns an iterator of desired number of entries offsetting by the skip value.- Parameters:
skip
- number of records to skip from beginningtake
- max number of records to return
-
contains
Description copied from interface:PersistentStore
Checks if lookup key is present in store.- Parameters:
key
- lookup key- Returns:
- true if store contains lookup key, false otherwise
-
get
Description copied from interface:PersistentStore
Returns the value for the given key if exists, null otherwise.- Parameters:
key
- lookup key
-
put
Description copied from interface:PersistentStore
Stores the (key, value) tuple in the store. Lifetime of the tuple depends upon storemode
.- Parameters:
key
- lookup keyvalue
- value to store
-
putIfAbsent
Description copied from interface:Store
Stores the (key, value) tuple in the store only if it does not exists.- Parameters:
key
- lookup keyvalue
- value to store- Returns:
- true if put takes place, false otherwise.
-
delete
Description copied from interface:Store
Removes the value corresponding to the given key if exists, nothing happens otherwise.- Parameters:
key
- lookup key
-
close
public void close()
-