| Modifier and Type | Method and Description |
|---|---|
MetadataTransactionContext |
MetadataManager.beginTransaction() |
| Modifier and Type | Method and Description |
|---|---|
MetadataTransactionContext |
IMetadataManager.beginTransaction()
Begins a transaction on the metadata node.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IMetadataManager.abortTransaction(MetadataTransactionContext ctx)
Aborts a remote transaction running on the metadata node.
|
void |
IMetadataManager.addAdapter(MetadataTransactionContext mdTxnCtx,
DatasourceAdapter adapter) |
void |
IMetadataManager.addCompactionPolicy(MetadataTransactionContext ctx,
CompactionPolicy policy) |
void |
IMetadataManager.addDataset(MetadataTransactionContext ctx,
Dataset dataset)
Inserts a new dataset into the metadata.
|
void |
IMetadataManager.addDatatype(MetadataTransactionContext ctx,
Datatype datatype)
Inserts a datatype.
|
void |
IMetadataManager.addDataverse(MetadataTransactionContext ctx,
Dataverse dataverse)
Inserts a new dataverse into the metadata.
|
void |
IMetadataManager.addExternalFile(MetadataTransactionContext mdTxnCtx,
ExternalFile externalFile) |
void |
IMetadataManager.addFeed(MetadataTransactionContext ctx,
Feed feed) |
void |
IMetadataManager.addFeedPolicy(MetadataTransactionContext ctx,
FeedPolicy policy) |
void |
IMetadataManager.addFunction(MetadataTransactionContext mdTxnCtx,
Function function) |
void |
IMetadataManager.addIndex(MetadataTransactionContext ctx,
Index index)
Inserts an index into the metadata.
|
void |
IMetadataManager.addLibrary(MetadataTransactionContext ctx,
Library library)
Adds a library, acquiring local locks on behalf of the given
transaction id.
|
void |
IMetadataManager.addNode(MetadataTransactionContext ctx,
Node node)
Inserts a node (machine).
|
void |
IMetadataManager.addNodegroup(MetadataTransactionContext ctx,
NodeGroup nodeGroup)
Inserts a node group.
|
void |
IMetadataManager.commitTransaction(MetadataTransactionContext ctx)
Commits a remote transaction on the metadata node.
|
void |
IMetadataManager.dropAdapter(MetadataTransactionContext ctx,
String dataverseName,
String name) |
void |
IMetadataManager.dropDataset(MetadataTransactionContext ctx,
String dataverseName,
String datasetName)
Deletes the dataset with given name, and all it's associated indexes.
|
void |
IMetadataManager.dropDatasetExternalFiles(MetadataTransactionContext mdTxnCtx,
Dataset dataset) |
void |
IMetadataManager.dropDatatype(MetadataTransactionContext ctx,
String dataverseName,
String datatypeName)
Deletes the given datatype in given dataverse.
|
void |
IMetadataManager.dropDataverse(MetadataTransactionContext ctx,
String dataverseName)
Deletes the dataverse with given name, and all it's associated datasets,
indexes, and types.
|
void |
IMetadataManager.dropExternalFile(MetadataTransactionContext mdTxnCtx,
ExternalFile externalFile) |
void |
IMetadataManager.dropFeed(MetadataTransactionContext ctx,
String dataverse,
String feedName) |
void |
IMetadataManager.dropFunction(MetadataTransactionContext ctx,
FunctionSignature functionSignature) |
void |
IMetadataManager.dropIndex(MetadataTransactionContext ctx,
String dataverseName,
String datasetName,
String indexName)
Deletes the index with given name, in given dataverse and dataset.
|
void |
IMetadataManager.dropLibrary(MetadataTransactionContext ctx,
String dataverseName,
String libraryName)
Removes a library , acquiring local locks on behalf of the given
transaction id.
|
void |
IMetadataManager.dropNodegroup(MetadataTransactionContext ctx,
String nodeGroupName)
Deletes a node group.
|
DatasourceAdapter |
IMetadataManager.getAdapter(MetadataTransactionContext ctx,
String dataverseName,
String name) |
CompactionPolicy |
IMetadataManager.getCompactionPolicy(MetadataTransactionContext ctx,
String dataverse,
String policyName) |
Dataset |
IMetadataManager.getDataset(MetadataTransactionContext ctx,
String dataverseName,
String datasetName)
Retrieves a dataset within a given dataverse.
|
List<ExternalFile> |
IMetadataManager.getDatasetExternalFiles(MetadataTransactionContext mdTxnCtx,
Dataset dataset) |
List<Index> |
IMetadataManager.getDatasetIndexes(MetadataTransactionContext ctx,
String dataverseName,
String datasetName)
Retrieves all indexes of a dataset.
|
Datatype |
IMetadataManager.getDatatype(MetadataTransactionContext ctx,
String dataverseName,
String datatypeName)
Retrieves the datatype with given name in given dataverse.
|
Dataverse |
IMetadataManager.getDataverse(MetadataTransactionContext ctx,
String dataverseName)
Retrieves a dataverse with given name.
|
List<Dataset> |
IMetadataManager.getDataverseDatasets(MetadataTransactionContext ctx,
String dataverseName)
Retrieves all datasets belonging to the given dataverse.
|
List<Function> |
IMetadataManager.getDataverseFunctions(MetadataTransactionContext ctx,
String dataverseName) |
List<Library> |
IMetadataManager.getDataverseLibraries(MetadataTransactionContext ctx,
String dataverseName)
Retireve libraries installed in a given dataverse.
|
List<Dataverse> |
IMetadataManager.getDataverses(MetadataTransactionContext ctx)
Retrieves all dataverses
|
ExternalFile |
IMetadataManager.getExternalFile(MetadataTransactionContext mdTxnCtx,
String dataverseName,
String datasetName,
Integer fileNumber)
Get en external file
|
Feed |
IMetadataManager.getFeed(MetadataTransactionContext ctx,
String dataverse,
String feedName) |
FeedPolicy |
IMetadataManager.getFeedPolicy(MetadataTransactionContext ctx,
String dataverse,
String policyName) |
Function |
IMetadataManager.getFunction(MetadataTransactionContext ctx,
FunctionSignature functionSignature) |
Index |
IMetadataManager.getIndex(MetadataTransactionContext ctx,
String dataverseName,
String datasetName,
String indexName)
Retrieves the index with given name, in given dataverse and dataset.
|
Library |
IMetadataManager.getLibrary(MetadataTransactionContext ctx,
String dataverseName,
String libraryName) |
NodeGroup |
IMetadataManager.getNodegroup(MetadataTransactionContext ctx,
String nodeGroupName)
Retrieves a node group.
|
void |
IMetadataManager.initializeDatasetIdFactory(MetadataTransactionContext ctx) |
void |
IMetadataManager.lock(MetadataTransactionContext ctx,
byte lockMode)
Locks the metadata in given mode.
|
void |
IMetadataManager.unlock(MetadataTransactionContext ctx,
byte lockMode)
Releases all locks on the metadata held by the given transaction id.
|
void |
IMetadataManager.updateDataset(MetadataTransactionContext ctx,
Dataset dataset)
update an existing dataset in metadata.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
MetadataBootstrap.insertInitialDatasets(MetadataTransactionContext mdTxnCtx) |
static void |
MetadataBootstrap.insertInitialDatatypes(MetadataTransactionContext mdTxnCtx) |
static void |
MetadataBootstrap.insertInitialDataverses(MetadataTransactionContext mdTxnCtx) |
static void |
MetadataBootstrap.insertInitialGroups(MetadataTransactionContext mdTxnCtx) |
static void |
MetadataBootstrap.insertInitialIndexes(MetadataTransactionContext mdTxnCtx) |
static void |
MetadataBootstrap.insertNodes(MetadataTransactionContext mdTxnCtx) |
| Modifier and Type | Method and Description |
|---|---|
MetadataTransactionContext |
AqlCompiledMetadataDeclarations.getMetadataTransactionContext() |
MetadataTransactionContext |
AqlMetadataProvider.getMetadataTxnContext() |
| Modifier and Type | Method and Description |
|---|---|
DatasourceAdapter |
AqlMetadataProvider.getAdapter(MetadataTransactionContext mdTxnCtx,
String dataverseName,
String adapterName) |
void |
AqlMetadataProvider.setMetadataTxnContext(MetadataTransactionContext mdTxnCtx) |
org.apache.hyracks.dataflow.std.file.FileSplit[] |
AqlMetadataProvider.splitsForDataset(MetadataTransactionContext mdTxnCtx,
String dataverseName,
String datasetName,
String targetIdxName,
boolean temp) |
| Constructor and Description |
|---|
AqlCompiledMetadataDeclarations(MetadataTransactionContext mdTxnCtx,
String dataverseName,
org.apache.hyracks.dataflow.std.file.FileSplit outputFile,
Map<String,String> config,
Map<String,String[]> stores,
Map<String,IAType> types,
Map<String,TypeDataGen> typeDataGenMap,
org.apache.hyracks.algebricks.data.IAWriterFactory writerFactory,
boolean online) |
| Modifier and Type | Method and Description |
|---|---|
static org.apache.hyracks.algebricks.common.utils.Triple<IFeedAdapterFactory,ARecordType,DatasourceAdapter.AdapterType> |
FeedUtil.getPrimaryFeedFactoryAndOutput(PrimaryFeed feed,
FeedPolicyAccessor policyAccessor,
MetadataTransactionContext mdTxnCtx) |
static String |
FeedUtil.getSecondaryFeedOutput(SecondaryFeed feed,
FeedPolicyAccessor policyAccessor,
MetadataTransactionContext mdTxnCtx) |
static Dataset |
FeedUtil.validateIfDatasetExists(String dataverse,
String datasetName,
MetadataTransactionContext ctx) |
static Feed |
FeedUtil.validateIfFeedExists(String dataverse,
String feedName,
MetadataTransactionContext ctx) |
static FeedPolicy |
FeedUtil.validateIfPolicyExists(String dataverse,
String policyName,
MetadataTransactionContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
static org.apache.hyracks.algebricks.core.algebra.functions.IFunctionInfo |
ExternalFunctionCompilerUtil.getExternalFunctionInfo(MetadataTransactionContext txnCtx,
Function function) |
| Modifier and Type | Method and Description |
|---|---|
static org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.storage.am.lsm.common.api.ILSMMergePolicyFactory,Map<String,String>> |
DatasetUtils.getMergePolicyFactory(Dataset dataset,
MetadataTransactionContext mdTxnCtx) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.