Constructor and Description |
---|
ContinuousFileStoreSource(DataTable table,
int[][] projectedFields,
Predicate predicate,
Long limit) |
ContinuousFileStoreSource(DataTable table,
int[][] projectedFields,
Predicate predicate,
Long limit,
ContinuousDataFileSnapshotEnumerator.Factory enumeratorFactory) |
StaticFileStoreSource(DataTable table,
int[][] projectedFields,
Predicate predicate,
Long limit) |
StaticFileStoreSource(DataTable table,
int[][] projectedFields,
Predicate predicate,
Long limit,
StaticDataFileSnapshotEnumerator.Factory enumeratorFactory) |
Modifier and Type | Interface and Description |
---|---|
interface |
FileStoreTable
An abstraction layer above
FileStore to provide reading
and writing of RowData . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractFileStoreTable
Abstract
FileStoreTable . |
class |
AppendOnlyFileStoreTable
FileStoreTable for WriteMode.APPEND_ONLY write mode. |
class |
ChangelogValueCountFileStoreTable
FileStoreTable for WriteMode.CHANGE_LOG write mode without primary keys. |
class |
ChangelogWithKeyFileStoreTable
FileStoreTable for WriteMode.CHANGE_LOG write mode with primary keys. |
Modifier and Type | Method and Description |
---|---|
static StaticDataFileSnapshotEnumerator |
StaticDataFileSnapshotEnumerator.create(DataTable table,
DataTableScan scan) |
StaticDataFileSnapshotEnumerator |
StaticDataFileSnapshotEnumerator.Factory.create(DataTable table,
DataTableScan scan) |
static ContinuousDataFileSnapshotEnumerator |
ContinuousDataFileSnapshotEnumerator.create(DataTable table,
DataTableScan scan,
Long nextSnapshotId) |
ContinuousDataFileSnapshotEnumerator |
ContinuousDataFileSnapshotEnumerator.Factory.create(DataTable table,
DataTableScan scan,
Long nextSnapshotId) |
static ContinuousDataFileSnapshotEnumerator |
ContinuousDataFileSnapshotEnumerator.createWithSnapshotStarting(DataTable table,
DataTableScan scan) |
Modifier and Type | Class and Description |
---|---|
class |
AuditLogTable
A
Table for reading audit log of table. |
class |
BucketsTable
A table to produce modified partitions and buckets for each snapshot.
|
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.