public interface MetadataStorageConnector
Modifier and Type | Field and Description |
---|---|
static String |
CONFIG_TABLE_KEY_COLUMN |
static String |
CONFIG_TABLE_VALUE_COLUMN |
Modifier and Type | Method and Description |
---|---|
default boolean |
compareAndSwap(List<MetadataCASUpdate> updates)
Atomic compare-and-swap variant of insertOrUpdate().
|
void |
createAuditTable() |
void |
createConfigTable() |
void |
createDataSourceTable() |
void |
createPendingSegmentsTable() |
void |
createRulesTable() |
void |
createSegmentTable() |
void |
createSupervisorsTable() |
void |
createTaskTables() |
void |
deleteAllRecords(String tableName) |
Void |
insertOrUpdate(String tableName,
String keyColumn,
String valueColumn,
String key,
byte[] value) |
byte[] |
lookup(String tableName,
String keyColumn,
String valueColumn,
String key) |
static final String CONFIG_TABLE_KEY_COLUMN
static final String CONFIG_TABLE_VALUE_COLUMN
Void insertOrUpdate(String tableName, String keyColumn, String valueColumn, String key, byte[] value) throws Exception
Exception
default boolean compareAndSwap(List<MetadataCASUpdate> updates) throws Exception
updates
- Set of updates to be made. If compare checks succeed for all updates, perform all updates.
If any compare check fails, reject all updates.Exception
void createDataSourceTable()
void createPendingSegmentsTable()
void createSegmentTable()
void createRulesTable()
void createConfigTable()
void createTaskTables()
void createAuditTable()
void createSupervisorsTable()
void deleteAllRecords(String tableName)
Copyright © 2011–2018. All rights reserved.