Interface | Description |
---|---|
FileStoreCommit |
Commit operation which provides commit and overwrite.
|
FileStoreExpire |
Expire operation which provides snapshots expire.
|
FileStoreRead<T> |
Read operation which provides
RecordReader creation. |
FileStoreScan |
Scan operation which produces a plan.
|
FileStoreScan.Plan |
Result plan of this scan.
|
FileStoreWrite<T> | |
Lock |
An interface that allows file store to use global lock to some transaction-related things.
|
Lock.Factory |
A factory to create
Lock . |
Class | Description |
---|---|
AbstractFileStoreScan |
Default implementation of
FileStoreScan . |
AbstractFileStoreWrite<T> |
Base
FileStoreWrite implementation. |
AbstractFileStoreWrite.WriterContainer<T> |
RecordWriter with the snapshot id it is created upon and the identifier of its last
modified commit. |
AppendOnlyFileStoreRead | |
AppendOnlyFileStoreScan | |
AppendOnlyFileStoreWrite | |
FileStoreCommitImpl |
Default implementation of
FileStoreCommit . |
FileStoreExpireImpl |
Default implementation of
FileStoreExpire . |
KeyValueFileStoreRead |
FileStoreRead implementation for KeyValueFileStore . |
KeyValueFileStoreScan | |
KeyValueFileStoreWrite | |
Lock.CatalogLockFactory |
A
Lock.Factory creating lock from catalog. |
Lock.CatalogLockImpl |
A
Lock to wrap CatalogLock . |
Lock.EmptyFactory |
A
Lock.Factory creating empty lock. |
Lock.EmptyLock |
An empty lock.
|
MemoryFileStoreWrite<T> |
Base
FileStoreWrite implementation which supports using shared memory and preempting
memory from other writers. |
PartitionExpire |
Expire partitions.
|
Enum | Description |
---|---|
ScanKind |
Scan which part of the snapshot.
|
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.