| Modifier and Type | Method and Description |
|---|---|
void |
MetadataNode.addAdapter(JobId jobId,
DatasourceAdapter adapter) |
void |
MetadataManager.addAdapter(MetadataTransactionContext mdTxnCtx,
DatasourceAdapter adapter) |
void |
MetadataNode.addCompactionPolicy(JobId jobId,
CompactionPolicy compactionPolicy) |
void |
MetadataManager.addCompactionPolicy(MetadataTransactionContext mdTxnCtx,
CompactionPolicy compactionPolicy) |
void |
MetadataNode.addDataset(JobId jobId,
Dataset dataset) |
void |
MetadataManager.addDataset(MetadataTransactionContext ctx,
Dataset dataset) |
void |
MetadataNode.addDatatype(JobId jobId,
Datatype datatype) |
void |
MetadataManager.addDatatype(MetadataTransactionContext ctx,
Datatype datatype) |
void |
MetadataNode.addDataverse(JobId jobId,
Dataverse dataverse) |
void |
MetadataManager.addDataverse(MetadataTransactionContext ctx,
Dataverse dataverse) |
void |
MetadataNode.addExternalFile(JobId jobId,
ExternalFile externalFile) |
void |
MetadataManager.addExternalFile(MetadataTransactionContext ctx,
ExternalFile externalFile) |
void |
MetadataNode.addFeed(JobId jobId,
Feed feed) |
void |
MetadataManager.addFeed(MetadataTransactionContext ctx,
Feed feed) |
void |
MetadataNode.addFeedPolicy(JobId jobId,
FeedPolicy feedPolicy) |
void |
MetadataManager.addFeedPolicy(MetadataTransactionContext mdTxnCtx,
FeedPolicy feedPolicy) |
void |
MetadataNode.addFunction(JobId jobId,
Function function) |
void |
MetadataManager.addFunction(MetadataTransactionContext mdTxnCtx,
Function function) |
void |
MetadataNode.addIndex(JobId jobId,
Index index) |
void |
MetadataManager.addIndex(MetadataTransactionContext ctx,
Index index) |
void |
MetadataNode.addLibrary(JobId jobId,
Library library) |
void |
MetadataManager.addLibrary(MetadataTransactionContext ctx,
Library library) |
void |
MetadataNode.addNode(JobId jobId,
Node node) |
void |
MetadataManager.addNode(MetadataTransactionContext ctx,
Node node) |
void |
MetadataNode.addNodeGroup(JobId jobId,
NodeGroup nodeGroup) |
void |
MetadataManager.addNodegroup(MetadataTransactionContext ctx,
NodeGroup nodeGroup) |
void |
MetadataNode.dropAdapter(JobId jobId,
String dataverseName,
String adapterName) |
void |
MetadataManager.dropAdapter(MetadataTransactionContext ctx,
String dataverseName,
String name) |
void |
MetadataNode.dropDataset(JobId jobId,
String dataverseName,
String datasetName) |
void |
MetadataManager.dropDataset(MetadataTransactionContext ctx,
String dataverseName,
String datasetName) |
void |
MetadataManager.dropDatasetExternalFiles(MetadataTransactionContext mdTxnCtx,
Dataset dataset) |
void |
MetadataNode.dropDatatype(JobId jobId,
String dataverseName,
String datatypeName) |
void |
MetadataManager.dropDatatype(MetadataTransactionContext ctx,
String dataverseName,
String datatypeName) |
void |
MetadataNode.dropDataverse(JobId jobId,
String dataverseName) |
void |
MetadataManager.dropDataverse(MetadataTransactionContext ctx,
String dataverseName) |
void |
MetadataNode.dropExternalFile(JobId jobId,
String dataverseName,
String datasetName,
int fileNumber) |
void |
MetadataManager.dropExternalFile(MetadataTransactionContext ctx,
ExternalFile externalFile) |
void |
MetadataNode.dropExternalFiles(JobId jobId,
Dataset dataset) |
void |
MetadataNode.dropFeed(JobId jobId,
String dataverse,
String feedName) |
void |
MetadataManager.dropFeed(MetadataTransactionContext ctx,
String dataverse,
String feedName) |
void |
MetadataNode.dropFeedPolicy(JobId jobId,
String dataverseName,
String policyName) |
void |
MetadataManager.dropFeedPolicy(MetadataTransactionContext mdTxnCtx,
String dataverseName,
String policyName) |
void |
MetadataNode.dropFunction(JobId jobId,
FunctionSignature functionSignature) |
void |
MetadataManager.dropFunction(MetadataTransactionContext ctx,
FunctionSignature functionSignature) |
void |
MetadataNode.dropIndex(JobId jobId,
String dataverseName,
String datasetName,
String indexName) |
void |
MetadataManager.dropIndex(MetadataTransactionContext ctx,
String dataverseName,
String datasetName,
String indexName) |
void |
MetadataNode.dropLibrary(JobId jobId,
String dataverseName,
String libraryName) |
void |
MetadataManager.dropLibrary(MetadataTransactionContext ctx,
String dataverseName,
String libraryName) |
void |
MetadataNode.dropNodegroup(JobId jobId,
String nodeGroupName) |
void |
MetadataManager.dropNodegroup(MetadataTransactionContext ctx,
String nodeGroupName) |
DatasourceAdapter |
MetadataNode.getAdapter(JobId jobId,
String dataverseName,
String adapterName) |
DatasourceAdapter |
MetadataManager.getAdapter(MetadataTransactionContext ctx,
String dataverseName,
String name) |
CompactionPolicy |
MetadataNode.getCompactionPolicy(JobId jobId,
String dataverse,
String policyName) |
CompactionPolicy |
MetadataManager.getCompactionPolicy(MetadataTransactionContext ctx,
String dataverse,
String policyName) |
Dataset |
MetadataNode.getDataset(JobId jobId,
String dataverseName,
String datasetName) |
Dataset |
MetadataManager.getDataset(MetadataTransactionContext ctx,
String dataverseName,
String datasetName) |
List<ExternalFile> |
MetadataManager.getDatasetExternalFiles(MetadataTransactionContext mdTxnCtx,
Dataset dataset) |
List<Index> |
MetadataNode.getDatasetIndexes(JobId jobId,
String dataverseName,
String datasetName) |
List<Index> |
MetadataManager.getDatasetIndexes(MetadataTransactionContext ctx,
String dataverseName,
String datasetName) |
List<String> |
MetadataNode.getDatasetNamesPartitionedOnThisNodeGroup(JobId jobId,
String nodegroup) |
Datatype |
MetadataNode.getDatatype(JobId jobId,
String dataverseName,
String datatypeName) |
Datatype |
MetadataManager.getDatatype(MetadataTransactionContext ctx,
String dataverseName,
String datatypeName) |
List<String> |
MetadataNode.getDatatypeNamesUsingThisDatatype(JobId jobId,
String dataverseName,
String datatypeName) |
Dataverse |
MetadataNode.getDataverse(JobId jobId,
String dataverseName) |
Dataverse |
MetadataManager.getDataverse(MetadataTransactionContext ctx,
String dataverseName) |
List<DatasourceAdapter> |
MetadataNode.getDataverseAdapters(JobId jobId,
String dataverseName) |
List<DatasourceAdapter> |
MetadataManager.getDataverseAdapters(MetadataTransactionContext mdTxnCtx,
String dataverse) |
List<Dataset> |
MetadataNode.getDataverseDatasets(JobId jobId,
String dataverseName) |
List<Dataset> |
MetadataManager.getDataverseDatasets(MetadataTransactionContext ctx,
String dataverseName) |
List<Feed> |
MetadataNode.getDataverseFeeds(JobId jobId,
String dataverseName) |
List<Function> |
MetadataNode.getDataverseFunctions(JobId jobId,
String dataverseName) |
List<Function> |
MetadataManager.getDataverseFunctions(MetadataTransactionContext ctx,
String dataverseName) |
List<Library> |
MetadataNode.getDataverseLibraries(JobId jobId,
String dataverseName) |
List<Library> |
MetadataManager.getDataverseLibraries(MetadataTransactionContext ctx,
String dataverseName) |
List<FeedPolicy> |
MetadataNode.getDataversePolicies(JobId jobId,
String dataverse) |
List<FeedPolicy> |
MetadataManager.getDataversePolicies(MetadataTransactionContext mdTxnCtx,
String dataverse) |
List<Dataverse> |
MetadataNode.getDataverses(JobId jobId) |
List<Dataverse> |
MetadataManager.getDataverses(MetadataTransactionContext ctx) |
ExternalFile |
MetadataNode.getExternalFile(JobId jobId,
String dataverseName,
String datasetName,
Integer fileNumber) |
ExternalFile |
MetadataManager.getExternalFile(MetadataTransactionContext ctx,
String dataverseName,
String datasetName,
Integer fileNumber) |
List<ExternalFile> |
MetadataNode.getExternalFiles(JobId jobId,
Dataset dataset) |
Feed |
MetadataNode.getFeed(JobId jobId,
String dataverse,
String feedName) |
Feed |
MetadataManager.getFeed(MetadataTransactionContext ctx,
String dataverse,
String feedName) |
FeedPolicy |
MetadataNode.getFeedPolicy(JobId jobId,
String dataverse,
String policyName) |
FeedPolicy |
MetadataManager.getFeedPolicy(MetadataTransactionContext ctx,
String dataverse,
String policyName) |
Function |
MetadataNode.getFunction(JobId jobId,
FunctionSignature functionSignature) |
Function |
MetadataManager.getFunction(MetadataTransactionContext ctx,
FunctionSignature functionSignature) |
Index |
MetadataNode.getIndex(JobId jobId,
String dataverseName,
String datasetName,
String indexName) |
Index |
MetadataManager.getIndex(MetadataTransactionContext ctx,
String dataverseName,
String datasetName,
String indexName) |
Library |
MetadataNode.getLibrary(JobId jobId,
String dataverseName,
String libraryName) |
Library |
MetadataManager.getLibrary(MetadataTransactionContext ctx,
String dataverseName,
String libraryName) |
int |
MetadataNode.getMostRecentDatasetId() |
int |
MetadataManager.getMostRecentDatasetId() |
NodeGroup |
MetadataNode.getNodeGroup(JobId jobId,
String nodeGroupName) |
NodeGroup |
MetadataManager.getNodegroup(MetadataTransactionContext ctx,
String nodeGroupName) |
void |
MetadataManager.init() |
void |
MetadataNode.initializeDatasetIdFactory(JobId jobId) |
void |
MetadataManager.initializeDatasetIdFactory(MetadataTransactionContext ctx) |
void |
MetadataNode.updateDataset(JobId jobId,
Dataset dataset) |
void |
MetadataManager.updateDataset(MetadataTransactionContext ctx,
Dataset dataset) |
| Modifier and Type | Method and Description |
|---|---|
void |
IMetadataNode.addAdapter(JobId jobId,
DatasourceAdapter adapter) |
void |
IMetadataManager.addAdapter(MetadataTransactionContext mdTxnCtx,
DatasourceAdapter adapter) |
void |
IMetadataNode.addCompactionPolicy(JobId jobId,
CompactionPolicy compactionPolicy) |
void |
IMetadataManager.addCompactionPolicy(MetadataTransactionContext ctx,
CompactionPolicy policy) |
void |
IMetadataNode.addDataset(JobId jobId,
Dataset dataset)
Inserts a new dataset into the metadata, acquiring local locks on behalf
of the given transaction id.
|
void |
IMetadataManager.addDataset(MetadataTransactionContext ctx,
Dataset dataset)
Inserts a new dataset into the metadata.
|
void |
IMetadataNode.addDatatype(JobId jobId,
Datatype datatype)
Inserts a datatype, acquiring local locks on behalf of the given
transaction id.
|
void |
IMetadataManager.addDatatype(MetadataTransactionContext ctx,
Datatype datatype)
Inserts a datatype.
|
void |
IMetadataNode.addDataverse(JobId jobId,
Dataverse dataverse)
Inserts a new dataverse into the metadata, acquiring local locks on
behalf of the given transaction id.
|
void |
IMetadataManager.addDataverse(MetadataTransactionContext ctx,
Dataverse dataverse)
Inserts a new dataverse into the metadata.
|
void |
IMetadataNode.addExternalFile(JobId jobId,
ExternalFile externalFile) |
void |
IMetadataManager.addExternalFile(MetadataTransactionContext mdTxnCtx,
ExternalFile externalFile) |
void |
IMetadataNode.addFeed(JobId jobId,
Feed feed) |
void |
IMetadataManager.addFeed(MetadataTransactionContext ctx,
Feed feed) |
void |
IMetadataNode.addFeedPolicy(JobId jobId,
FeedPolicy feedPolicy) |
void |
IMetadataManager.addFeedPolicy(MetadataTransactionContext ctx,
FeedPolicy policy) |
void |
IMetadataNode.addFunction(JobId jobId,
Function function) |
void |
IMetadataManager.addFunction(MetadataTransactionContext mdTxnCtx,
Function function) |
void |
IMetadataNode.addIndex(JobId jobId,
Index index)
Inserts an index into the metadata, acquiring local locks on behalf of
the given transaction id.
|
void |
IMetadataManager.addIndex(MetadataTransactionContext ctx,
Index index)
Inserts an index into the metadata.
|
void |
IMetadataNode.addLibrary(JobId jobId,
Library library)
Adds a library, acquiring local locks on behalf of the given
transaction id.
|
void |
IMetadataManager.addLibrary(MetadataTransactionContext ctx,
Library library)
Adds a library, acquiring local locks on behalf of the given
transaction id.
|
void |
IMetadataNode.addNode(JobId jobId,
Node node)
Inserts a node (compute node), acquiring local locks on behalf of the
given transaction id.
|
void |
IMetadataManager.addNode(MetadataTransactionContext ctx,
Node node)
Inserts a node (machine).
|
void |
IMetadataNode.addNodeGroup(JobId jobId,
NodeGroup nodeGroup)
Inserts a node group, acquiring local locks on behalf of the given
transaction id.
|
void |
IMetadataManager.addNodegroup(MetadataTransactionContext ctx,
NodeGroup nodeGroup)
Inserts a node group.
|
void |
IMetadataManager.cleanupTempDatasets()
Clean up temporary datasets that have not been active for a long time.
|
void |
IMetadataNode.dropAdapter(JobId jobId,
String dataverseName,
String adapterName)
Deletes a adapter , acquiring local locks on behalf of the given
transaction id.
|
void |
IMetadataManager.dropAdapter(MetadataTransactionContext ctx,
String dataverseName,
String name) |
void |
IMetadataNode.dropDataset(JobId jobId,
String dataverseName,
String datasetName)
Deletes the dataset with given name, and all it's associated indexes,
acquiring local locks on behalf of the given transaction id.
|
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 |
IMetadataNode.dropDatatype(JobId jobId,
String dataverseName,
String datatypeName)
Deletes the given datatype in given dataverse, acquiring local locks on
behalf of the given transaction id.
|
void |
IMetadataManager.dropDatatype(MetadataTransactionContext ctx,
String dataverseName,
String datatypeName)
Deletes the given datatype in given dataverse.
|
void |
IMetadataNode.dropDataverse(JobId jobId,
String dataverseName)
Deletes the dataverse with given name, and all it's associated datasets,
indexes, and types, acquiring local locks on behalf of the given
transaction id.
|
void |
IMetadataManager.dropDataverse(MetadataTransactionContext ctx,
String dataverseName)
Deletes the dataverse with given name, and all it's associated datasets,
indexes, and types.
|
void |
IMetadataNode.dropExternalFile(JobId jobId,
String dataverseName,
String datasetName,
int fileNumber)
Deletes an externalFile , acquiring local locks on behalf of the given
transaction id.
|
void |
IMetadataManager.dropExternalFile(MetadataTransactionContext mdTxnCtx,
ExternalFile externalFile) |
void |
IMetadataNode.dropExternalFiles(JobId jobId,
Dataset dataset)
Deletes all external files belonging to a dataset, acquiring local locks on behalf of the given
transaction id.
|
void |
IMetadataNode.dropFeed(JobId jobId,
String dataverse,
String feedName) |
void |
IMetadataManager.dropFeed(MetadataTransactionContext ctx,
String dataverse,
String feedName) |
void |
IMetadataNode.dropFeedPolicy(JobId jobId,
String dataverseName,
String policyName)
delete a give feed (ingestion) policy
|
void |
IMetadataNode.dropFunction(JobId jobId,
FunctionSignature functionSignature)
Deletes a function, acquiring local locks on behalf of the given
transaction id.
|
void |
IMetadataManager.dropFunction(MetadataTransactionContext ctx,
FunctionSignature functionSignature) |
void |
IMetadataNode.dropIndex(JobId jobId,
String dataverseName,
String datasetName,
String indexName)
Deletes the index with given name, in given dataverse and dataset,
acquiring local locks on behalf of the given transaction id.
|
void |
IMetadataManager.dropIndex(MetadataTransactionContext ctx,
String dataverseName,
String datasetName,
String indexName)
Deletes the index with given name, in given dataverse and dataset.
|
void |
IMetadataNode.dropLibrary(JobId jobId,
String dataverseName,
String libraryName)
Removes a library , acquiring local locks on behalf of the given
transaction id.
|
void |
IMetadataManager.dropLibrary(MetadataTransactionContext ctx,
String dataverseName,
String libraryName)
Removes a library , acquiring local locks on behalf of the given
transaction id.
|
void |
IMetadataNode.dropNodegroup(JobId jobId,
String nodeGroupName)
Deletes a node group, acquiring local locks on behalf of the given
transaction id.
|
void |
IMetadataManager.dropNodegroup(MetadataTransactionContext ctx,
String nodeGroupName)
Deletes a node group.
|
DatasourceAdapter |
IMetadataNode.getAdapter(JobId jobId,
String dataverseName,
String adapterName) |
DatasourceAdapter |
IMetadataManager.getAdapter(MetadataTransactionContext ctx,
String dataverseName,
String name) |
CompactionPolicy |
IMetadataNode.getCompactionPolicy(JobId jobId,
String dataverse,
String policy) |
CompactionPolicy |
IMetadataManager.getCompactionPolicy(MetadataTransactionContext ctx,
String dataverse,
String policyName) |
Dataset |
IMetadataNode.getDataset(JobId jobId,
String dataverseName,
String datasetName)
Retrieves a dataset within a given dataverse, acquiring local locks on
behalf of the given transaction id.
|
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> |
IMetadataNode.getDatasetIndexes(JobId jobId,
String dataverseName,
String datasetName)
Retrieves all indexes of a dataset, acquiring local locks on behalf of
the given transaction id.
|
List<Index> |
IMetadataManager.getDatasetIndexes(MetadataTransactionContext ctx,
String dataverseName,
String datasetName)
Retrieves all indexes of a dataset.
|
Datatype |
IMetadataNode.getDatatype(JobId jobId,
String dataverseName,
String datatypeName)
Retrieves the datatype with given name in given dataverse, acquiring
local locks on behalf of the given transaction id.
|
Datatype |
IMetadataManager.getDatatype(MetadataTransactionContext ctx,
String dataverseName,
String datatypeName)
Retrieves the datatype with given name in given dataverse.
|
Dataverse |
IMetadataNode.getDataverse(JobId jobId,
String dataverseName)
Retrieves a dataverse with given name, acquiring local locks on behalf of
the given transaction id.
|
Dataverse |
IMetadataManager.getDataverse(MetadataTransactionContext ctx,
String dataverseName)
Retrieves a dataverse with given name.
|
List<DatasourceAdapter> |
IMetadataNode.getDataverseAdapters(JobId jobId,
String dataverseName) |
List<Dataset> |
IMetadataNode.getDataverseDatasets(JobId jobId,
String dataverseName)
Retrieves all datasets belonging to the given dataverse, acquiring local
locks on behalf of the given transaction id.
|
List<Dataset> |
IMetadataManager.getDataverseDatasets(MetadataTransactionContext ctx,
String dataverseName)
Retrieves all datasets belonging to the given dataverse.
|
List<Feed> |
IMetadataNode.getDataverseFeeds(JobId jobId,
String dataverseName) |
List<Function> |
IMetadataNode.getDataverseFunctions(JobId jobId,
String dataverseName) |
List<Function> |
IMetadataManager.getDataverseFunctions(MetadataTransactionContext ctx,
String dataverseName) |
List<Library> |
IMetadataNode.getDataverseLibraries(JobId jobId,
String dataverseName)
Retireve libraries installed in a given dataverse.
|
List<Library> |
IMetadataManager.getDataverseLibraries(MetadataTransactionContext ctx,
String dataverseName)
Retireve libraries installed in a given dataverse.
|
List<FeedPolicy> |
IMetadataNode.getDataversePolicies(JobId jobId,
String dataverse) |
List<Dataverse> |
IMetadataNode.getDataverses(JobId jobId)
Retrieves all dataverses, acquiring local locks on behalf of
the given transaction id.
|
List<Dataverse> |
IMetadataManager.getDataverses(MetadataTransactionContext ctx)
Retrieves all dataverses
|
ExternalFile |
IMetadataNode.getExternalFile(JobId jobId,
String dataverseName,
String datasetName,
Integer fileNumber)
Retrieves the file with given number, in given dataverse and dataset,
acquiring local locks on behalf of the given transaction id.
|
ExternalFile |
IMetadataManager.getExternalFile(MetadataTransactionContext mdTxnCtx,
String dataverseName,
String datasetName,
Integer fileNumber)
Get en external file
|
List<ExternalFile> |
IMetadataNode.getExternalFiles(JobId jobId,
Dataset dataset) |
Feed |
IMetadataNode.getFeed(JobId jobId,
String dataverse,
String feedName) |
Feed |
IMetadataManager.getFeed(MetadataTransactionContext ctx,
String dataverse,
String feedName) |
FeedPolicy |
IMetadataNode.getFeedPolicy(JobId jobId,
String dataverse,
String policy) |
FeedPolicy |
IMetadataManager.getFeedPolicy(MetadataTransactionContext ctx,
String dataverse,
String policyName) |
Function |
IMetadataNode.getFunction(JobId jobId,
FunctionSignature functionSignature) |
Function |
IMetadataManager.getFunction(MetadataTransactionContext ctx,
FunctionSignature functionSignature) |
Index |
IMetadataNode.getIndex(JobId jobId,
String dataverseName,
String datasetName,
String indexName)
Retrieves the index with given name, in given dataverse and dataset,
acquiring local locks on behalf of the given transaction id.
|
Index |
IMetadataManager.getIndex(MetadataTransactionContext ctx,
String dataverseName,
String datasetName,
String indexName)
Retrieves the index with given name, in given dataverse and dataset.
|
Library |
IMetadataNode.getLibrary(JobId jobId,
String dataverseName,
String libraryName) |
Library |
IMetadataManager.getLibrary(MetadataTransactionContext ctx,
String dataverseName,
String libraryName) |
T |
IMetadataEntityTupleTranslator.getMetadataEntityFromTuple(org.apache.hyracks.dataflow.common.data.accessors.ITupleReference tuple)
Transforms a metadata entity of type T from a given tuple to a Java
object (deserializing the appropriate field(s) in the tuple as
necessary).
|
int |
IMetadataNode.getMostRecentDatasetId() |
int |
IMetadataManager.getMostRecentDatasetId() |
NodeGroup |
IMetadataNode.getNodeGroup(JobId jobId,
String nodeGroupName)
Retrieves a node group, acquiring local locks on behalf of the given
transaction id.
|
NodeGroup |
IMetadataManager.getNodegroup(MetadataTransactionContext ctx,
String nodeGroupName)
Retrieves a node group.
|
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference |
IMetadataEntityTupleTranslator.getTupleFromMetadataEntity(T metadataEntity)
Serializes the given metadata entity of type T into an appropriate tuple
representation (i.e., some number of fields containing bytes).
|
T |
IValueExtractor.getValue(JobId jobId,
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference tuple)
Extracts an object of type T from a given tuple.
|
void |
IMetadataManager.init()
Initializes the metadata manager, e.g., finds the remote metadata node.
|
void |
IMetadataNode.initializeDatasetIdFactory(JobId jobId) |
void |
IMetadataManager.initializeDatasetIdFactory(MetadataTransactionContext ctx) |
void |
IMetadataNode.updateDataset(JobId jobId,
Dataset dataset)
update an existing dataset in the metadata, acquiring local locks on behalf
of 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 |
MetadataSecondaryIndexes.init()
Create all metadata secondary index descriptors.
|
static void |
MetadataPrimaryIndexes.init()
Create all metadata primary index descriptors.
|
static void |
MetadataRecordTypes.init()
Create all metadata record types.
|
static void |
MetadataBootstrap.startDDLRecovery() |
| Modifier and Type | Method and Description |
|---|---|
DatasourceAdapter |
AqlMetadataProvider.getAdapter(MetadataTransactionContext mdTxnCtx,
String dataverseName,
String adapterName) |
long |
AqlMetadataProvider.getCardinalityPerPartitionHint(Dataset dataset)
Calculate an estimate size of the bloom filter.
|
AqlDataSource |
AqlMetadataProvider.lookupSourceInMetadata(AqlSourceId aqlId) |
| Modifier and Type | Method and Description |
|---|---|
static IAType |
AsterixBuiltinTypeMap.getTypeFromTypeName(MetadataNode metadataNode,
JobId jobId,
String dataverseName,
String typeName,
boolean isNullable) |
| Modifier and Type | Method and Description |
|---|---|
ExternalFile |
ExternalFileTupleTranslator.getMetadataEntityFromTuple(org.apache.hyracks.dataflow.common.data.accessors.ITupleReference tuple) |
Index |
IndexTupleTranslator.getMetadataEntityFromTuple(org.apache.hyracks.dataflow.common.data.accessors.ITupleReference frameTuple) |
Datatype |
DatatypeTupleTranslator.getMetadataEntityFromTuple(org.apache.hyracks.dataflow.common.data.accessors.ITupleReference frameTuple) |
DatasourceAdapter |
DatasourceAdapterTupleTranslator.getMetadataEntityFromTuple(org.apache.hyracks.dataflow.common.data.accessors.ITupleReference tuple) |
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference |
CompactionPolicyTupleTranslator.getTupleFromMetadataEntity(CompactionPolicy compactionPolicy) |
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference |
DatasetTupleTranslator.getTupleFromMetadataEntity(Dataset dataset) |
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference |
DatasourceAdapterTupleTranslator.getTupleFromMetadataEntity(DatasourceAdapter adapter) |
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference |
DatatypeTupleTranslator.getTupleFromMetadataEntity(Datatype dataType) |
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference |
DataverseTupleTranslator.getTupleFromMetadataEntity(Dataverse instance) |
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference |
ExternalFileTupleTranslator.getTupleFromMetadataEntity(ExternalFile externalFile) |
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference |
FeedTupleTranslator.getTupleFromMetadataEntity(Feed feed) |
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference |
FeedPolicyTupleTranslator.getTupleFromMetadataEntity(FeedPolicy feedPolicy) |
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference |
FunctionTupleTranslator.getTupleFromMetadataEntity(Function function) |
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference |
IndexTupleTranslator.getTupleFromMetadataEntity(Index instance) |
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference |
LibraryTupleTranslator.getTupleFromMetadataEntity(Library library) |
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference |
NodeTupleTranslator.getTupleFromMetadataEntity(Node instance) |
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference |
NodeGroupTupleTranslator.getTupleFromMetadataEntity(NodeGroup instance) |
| Modifier and Type | Method and Description |
|---|---|
static String |
FeedUtil.getSecondaryFeedOutput(SecondaryFeed feed,
FeedPolicyAccessor policyAccessor,
MetadataTransactionContext mdTxnCtx) |
static Feed |
FeedUtil.validateIfFeedExists(String dataverse,
String feedName,
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) |
| Modifier and Type | Method and Description |
|---|---|
String |
DatasetNameValueExtractor.getValue(JobId jobId,
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference tuple) |
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference |
TupleCopyValueExtractor.getValue(JobId jobId,
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference tuple) |
T |
MetadataEntityValueExtractor.getValue(JobId jobId,
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference tuple) |
String |
DatatypeNameValueExtractor.getValue(JobId jobId,
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference tuple) |
String |
NestedDatatypeNameValueExtractor.getValue(JobId jobId,
org.apache.hyracks.dataflow.common.data.accessors.ITupleReference tuple) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.