org.apache.asterix.metadata.declared

Class AqlMetadataProvider

java.lang.Object

org.apache.asterix.metadata.declared.AqlMetadataProvider

All Implemented Interfaces:

org.apache.hyracks.algebricks.core.algebra.metadata.IMetadataProvider<AqlSourceId,String>

public class AqlMetadataProvider
extends Object
implements org.apache.hyracks.algebricks.core.algebra.metadata.IMetadataProvider<AqlSourceId,String>

Field Summary

Fields

Modifier and Type	Field and Description
static Map<String,String>	adapterFactoryMapping

Constructor Summary

Constructors

Constructor and Description
AqlMetadataProvider(Dataverse defaultDataverse, ICentralFeedManager centralFeedManager)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	buildBtreeRuntime(org.apache.hyracks.api.job.JobSpecification jobSpec, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> outputVars, org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema opSchema, org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv, org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context, boolean retainInput, boolean retainNull, Dataset dataset, String indexName, int[] lowKeyFields, int[] highKeyFields, boolean lowKeyInclusive, boolean highKeyInclusive, Object implConfig, int[] minFilterFieldIndexes, int[] maxFilterFieldIndexes)
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	buildExternalDatasetDataScannerRuntime(org.apache.hyracks.api.job.JobSpecification jobSpec, IAType itemType, IAdapterFactory adapterFactory, IDataFormat format)
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	buildFeedCollectRuntime(org.apache.hyracks.api.job.JobSpecification jobSpec, org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId> dataSource)
org.apache.hyracks.algebricks.common.utils.Triple<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint,IFeedAdapterFactory>	buildFeedIntakeRuntime(org.apache.hyracks.api.job.JobSpecification jobSpec, PrimaryFeed primaryFeed, FeedPolicyAccessor policyAccessor)
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	buildRtreeRuntime(org.apache.hyracks.api.job.JobSpecification jobSpec, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> outputVars, org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema opSchema, org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv, org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context, boolean retainInput, boolean retainNull, Dataset dataset, String indexName, int[] keyFields, int[] minFilterFieldIndexes, int[] maxFilterFieldIndexes)
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	buildScannerRuntime(org.apache.hyracks.api.job.JobSpecification jobSpec, IAType itemType, IParseFileSplitsDecl decl, IDataFormat format)
static org.apache.hyracks.storage.am.common.api.ITreeIndexFrameFactory	createBTreeNSMInteriorFrameFactory(org.apache.hyracks.api.dataflow.value.ITypeTraits[] typeTraits)
Dataset	findDataset(String dataverse, String dataset)
AqlDataSource	findDataSource(AqlSourceId id)
org.apache.hyracks.algebricks.core.algebra.metadata.IDataSourceIndex<String,AqlSourceId>	findDataSourceIndex(String indexId, AqlSourceId dataSourceId)
Feed	findFeed(String dataverse, String feedName)
FeedPolicy	findFeedPolicy(String dataverse, String policyName)
ARecordType	findOutputRecordType() Retrieve the Output RecordType, as defined by "set output-record-type".
IAType	findType(String dataverse, String typeName)
DatasourceAdapter	getAdapter(MetadataTransactionContext mdTxnCtx, String dataverseName, String adapterName)
Map<String,String[]>	getAllStores()
long	getCardinalityPerPartitionHint(Dataset dataset) Calculate an estimate size of the bloom filter.
org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint	getClusterLocations()
Map<String,String>	getConfig()
IDataFormat	getDataFormat(String dataverseName)
List<Index>	getDatasetIndexes(String dataverseName, String datasetName)
Dataverse	getDefaultDataverse()
String	getDefaultDataverseName()
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	getDeleteRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId> dataSource, org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema propagatedSchema, org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> keys, org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable payload, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> additionalNonKeyFields, org.apache.hyracks.api.dataflow.value.RecordDescriptor recordDesc, org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context, org.apache.hyracks.api.job.JobSpecification spec)
IDataFormat	getFormat()
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	getIndexDeleteRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSourceIndex<String,AqlSourceId> dataSourceIndex, org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema propagatedSchema, org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema[] inputSchemas, org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> primaryKeys, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> secondaryKeys, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> additionalNonKeyFields, org.apache.hyracks.algebricks.core.algebra.base.ILogicalExpression filterExpr, org.apache.hyracks.api.dataflow.value.RecordDescriptor recordDesc, org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context, org.apache.hyracks.api.job.JobSpecification spec)
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	getIndexInsertOrDeleteRuntime(org.apache.hyracks.storage.am.common.ophelpers.IndexOperation indexOp, org.apache.hyracks.algebricks.core.algebra.metadata.IDataSourceIndex<String,AqlSourceId> dataSourceIndex, org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema propagatedSchema, org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema[] inputSchemas, org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> primaryKeys, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> secondaryKeys, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> additionalNonKeyFields, org.apache.hyracks.algebricks.core.algebra.base.ILogicalExpression filterExpr, org.apache.hyracks.api.dataflow.value.RecordDescriptor recordDesc, org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context, org.apache.hyracks.api.job.JobSpecification spec, boolean bulkload)
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	getIndexInsertRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSourceIndex<String,AqlSourceId> dataSourceIndex, org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema propagatedSchema, org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema[] inputSchemas, org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> primaryKeys, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> secondaryKeys, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> additionalNonKeyFields, org.apache.hyracks.algebricks.core.algebra.base.ILogicalExpression filterExpr, org.apache.hyracks.api.dataflow.value.RecordDescriptor recordDesc, org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context, org.apache.hyracks.api.job.JobSpecification spec, boolean bulkload)
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	getInsertOrDeleteRuntime(org.apache.hyracks.storage.am.common.ophelpers.IndexOperation indexOp, org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId> dataSource, org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema propagatedSchema, org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> keys, org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable payload, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> additionalNonKeyFields, org.apache.hyracks.api.dataflow.value.RecordDescriptor recordDesc, org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context, org.apache.hyracks.api.job.JobSpecification spec, boolean bulkload)
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	getInsertRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId> dataSource, org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema propagatedSchema, org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> keys, org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable payload, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> additionalNonKeyFields, org.apache.hyracks.api.dataflow.value.RecordDescriptor recordDesc, org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context, org.apache.hyracks.api.job.JobSpecification spec, boolean bulkload)
JobId	getJobId()
Map<String,Integer>	getLocks()
MetadataTransactionContext	getMetadataTxnContext()
org.apache.hyracks.dataflow.std.file.FileSplit	getOutputFile()
String	getPropertyValue(String propertyName)
boolean	getResultAsyncMode()
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	getResultHandleRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSink sink, int[] printColumns, org.apache.hyracks.algebricks.data.IPrinterFactory[] printerFactories, org.apache.hyracks.api.dataflow.value.RecordDescriptor inputDesc, boolean ordered, org.apache.hyracks.api.job.JobSpecification spec)
org.apache.hyracks.algebricks.data.IResultSerializerFactoryProvider	getResultSerializerFactoryProvider()
org.apache.hyracks.api.dataset.ResultSetId	getResultSetId()
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	getScannerRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId> dataSource, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> scanVariables, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> projectVariables, boolean projectPushed, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> minFilterVars, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> maxFilterVars, org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema opSchema, org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv, org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context, org.apache.hyracks.api.job.JobSpecification jobSpec, Object implConfig)
AsterixStorageProperties	getStorageProperties()
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	getTokenizerRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSourceIndex<String,AqlSourceId> dataSourceIndex, org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema propagatedSchema, org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema[] inputSchemas, org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> primaryKeys, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> secondaryKeys, org.apache.hyracks.algebricks.core.algebra.base.ILogicalExpression filterExpr, org.apache.hyracks.api.dataflow.value.RecordDescriptor recordDesc, org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context, org.apache.hyracks.api.job.JobSpecification spec, boolean bulkload)
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.algebricks.runtime.base.IPushRuntimeFactory,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	getWriteFileRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSink sink, int[] printColumns, org.apache.hyracks.algebricks.data.IPrinterFactory[] printerFactories, org.apache.hyracks.api.dataflow.value.RecordDescriptor inputDesc)
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	getWriteResultRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId> dataSource, org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema propagatedSchema, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> keys, org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable payload, List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> additionalNonKeyFields, org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context, org.apache.hyracks.api.job.JobSpecification spec)
org.apache.hyracks.algebricks.data.IAWriterFactory	getWriterFactory()
boolean	isTemporaryDatasetWriteJob()
boolean	isWriteTransaction()
org.apache.hyracks.algebricks.core.algebra.functions.IFunctionInfo	lookupFunction(org.apache.hyracks.algebricks.core.algebra.functions.FunctionIdentifier fid)
AqlDataSource	lookupSourceInMetadata(AqlSourceId aqlId)
static org.apache.hyracks.api.dataflow.value.ILinearizeComparatorFactory	proposeLinearizer(ATypeTag keyType, int numKeyFields)
boolean	scannerOperatorIsLeaf(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId> dataSource)
void	setConfig(Map<String,String> config)
void	setJobId(JobId jobId)
void	setLocks(Map<String,Integer> locks)
void	setMetadataTxnContext(MetadataTransactionContext mdTxnCtx)
void	setOutputFile(org.apache.hyracks.dataflow.std.file.FileSplit outputFile)
void	setResultAsyncMode(boolean asyncResults)
void	setResultSerializerFactoryProvider(org.apache.hyracks.algebricks.data.IResultSerializerFactoryProvider rafp)
void	setResultSetId(org.apache.hyracks.api.dataset.ResultSetId resultSetId)
void	setWriterFactory(org.apache.hyracks.algebricks.data.IAWriterFactory writerFactory)
void	setWriteTransaction(boolean writeTransaction)
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.dataflow.std.file.IFileSplitProvider,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	splitProviderAndPartitionConstraintsForDataset(String dataverseName, String datasetName, String targetIdxName, boolean temp)
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.dataflow.std.file.IFileSplitProvider,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	splitProviderAndPartitionConstraintsForDataverse(String dataverse)
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.dataflow.std.file.IFileSplitProvider,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	splitProviderAndPartitionConstraintsForFilesIndex(String dataverseName, String datasetName, String targetIdxName, boolean create)
org.apache.hyracks.dataflow.std.file.FileSplit[]	splitsForDataset(MetadataTransactionContext mdTxnCtx, String dataverseName, String datasetName, String targetIdxName, boolean temp)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

adapterFactoryMapping

public static final Map<String,String> adapterFactoryMapping

Constructor Detail

AqlMetadataProvider

public AqlMetadataProvider(Dataverse defaultDataverse,
                   ICentralFeedManager centralFeedManager)

Method Detail

getPropertyValue

public String getPropertyValue(String propertyName)

setConfig

public void setConfig(Map<String,String> config)

getAllStores

public Map<String,String[]> getAllStores()

getConfig

public Map<String,String> getConfig()

setJobId

public void setJobId(JobId jobId)

getDefaultDataverse

public Dataverse getDefaultDataverse()

getDefaultDataverseName

public String getDefaultDataverseName()

setWriteTransaction

public void setWriteTransaction(boolean writeTransaction)

setWriterFactory

public void setWriterFactory(org.apache.hyracks.algebricks.data.IAWriterFactory writerFactory)

setMetadataTxnContext

public void setMetadataTxnContext(MetadataTransactionContext mdTxnCtx)

getMetadataTxnContext

public MetadataTransactionContext getMetadataTxnContext()

getWriterFactory

public org.apache.hyracks.algebricks.data.IAWriterFactory getWriterFactory()

getOutputFile

public org.apache.hyracks.dataflow.std.file.FileSplit getOutputFile()

setOutputFile

public void setOutputFile(org.apache.hyracks.dataflow.std.file.FileSplit outputFile)

getResultAsyncMode

public boolean getResultAsyncMode()

setResultAsyncMode

public void setResultAsyncMode(boolean asyncResults)

getResultSetId

public org.apache.hyracks.api.dataset.ResultSetId getResultSetId()

setResultSetId

public void setResultSetId(org.apache.hyracks.api.dataset.ResultSetId resultSetId)

setResultSerializerFactoryProvider

public void setResultSerializerFactoryProvider(org.apache.hyracks.algebricks.data.IResultSerializerFactoryProvider rafp)

getResultSerializerFactoryProvider

public org.apache.hyracks.algebricks.data.IResultSerializerFactoryProvider getResultSerializerFactoryProvider()

findOutputRecordType

public ARecordType findOutputRecordType()
                                 throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Retrieve the Output RecordType, as defined by "set output-record-type".

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

findDataSource

public AqlDataSource findDataSource(AqlSourceId id)
                             throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Specified by:

findDataSource in interface org.apache.hyracks.algebricks.core.algebra.metadata.IMetadataProvider<AqlSourceId,String>

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

isWriteTransaction

public boolean isWriteTransaction()

isTemporaryDatasetWriteJob

public boolean isTemporaryDatasetWriteJob()

getScannerRuntime

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> getScannerRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId> dataSource,
                                                                                                                                                                                                    List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> scanVariables,
                                                                                                                                                                                                    List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> projectVariables,
                                                                                                                                                                                                    boolean projectPushed,
                                                                                                                                                                                                    List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> minFilterVars,
                                                                                                                                                                                                    List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> maxFilterVars,
                                                                                                                                                                                                    org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema opSchema,
                                                                                                                                                                                                    org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv,
                                                                                                                                                                                                    org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context,
                                                                                                                                                                                                    org.apache.hyracks.api.job.JobSpecification jobSpec,
                                                                                                                                                                                                    Object implConfig)
                                                                                                                                                                                                      throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Specified by:

getScannerRuntime in interface org.apache.hyracks.algebricks.core.algebra.metadata.IMetadataProvider<AqlSourceId,String>

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

buildFeedCollectRuntime

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> buildFeedCollectRuntime(org.apache.hyracks.api.job.JobSpecification jobSpec,
                                                                                                                                                                                                          org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId> dataSource)
                                                                                                                                                                                                            throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

getDataFormat

public IDataFormat getDataFormat(String dataverseName)
                          throws AsterixException

Throws:

AsterixException

buildExternalDatasetDataScannerRuntime

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> buildExternalDatasetDataScannerRuntime(org.apache.hyracks.api.job.JobSpecification jobSpec,
                                                                                                                                                                                                                         IAType itemType,
                                                                                                                                                                                                                         IAdapterFactory adapterFactory,
                                                                                                                                                                                                                         IDataFormat format)
                                                                                                                                                                                                                           throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

buildScannerRuntime

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> buildScannerRuntime(org.apache.hyracks.api.job.JobSpecification jobSpec,
                                                                                                                                                                                                      IAType itemType,
                                                                                                                                                                                                      IParseFileSplitsDecl decl,
                                                                                                                                                                                                      IDataFormat format)
                                                                                                                                                                                                        throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

buildFeedIntakeRuntime

public org.apache.hyracks.algebricks.common.utils.Triple<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint,IFeedAdapterFactory> buildFeedIntakeRuntime(org.apache.hyracks.api.job.JobSpecification jobSpec,
                                                                                                                                                                                                                               PrimaryFeed primaryFeed,
                                                                                                                                                                                                                               FeedPolicyAccessor policyAccessor)
                                                                                                                                                                                                                                 throws Exception

Throws:

Exception

buildBtreeRuntime

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> buildBtreeRuntime(org.apache.hyracks.api.job.JobSpecification jobSpec,
                                                                                                                                                                                                    List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> outputVars,
                                                                                                                                                                                                    org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema opSchema,
                                                                                                                                                                                                    org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv,
                                                                                                                                                                                                    org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context,
                                                                                                                                                                                                    boolean retainInput,
                                                                                                                                                                                                    boolean retainNull,
                                                                                                                                                                                                    Dataset dataset,
                                                                                                                                                                                                    String indexName,
                                                                                                                                                                                                    int[] lowKeyFields,
                                                                                                                                                                                                    int[] highKeyFields,
                                                                                                                                                                                                    boolean lowKeyInclusive,
                                                                                                                                                                                                    boolean highKeyInclusive,
                                                                                                                                                                                                    Object implConfig,
                                                                                                                                                                                                    int[] minFilterFieldIndexes,
                                                                                                                                                                                                    int[] maxFilterFieldIndexes)
                                                                                                                                                                                                      throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

buildRtreeRuntime

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> buildRtreeRuntime(org.apache.hyracks.api.job.JobSpecification jobSpec,
                                                                                                                                                                                                    List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> outputVars,
                                                                                                                                                                                                    org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema opSchema,
                                                                                                                                                                                                    org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv,
                                                                                                                                                                                                    org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context,
                                                                                                                                                                                                    boolean retainInput,
                                                                                                                                                                                                    boolean retainNull,
                                                                                                                                                                                                    Dataset dataset,
                                                                                                                                                                                                    String indexName,
                                                                                                                                                                                                    int[] keyFields,
                                                                                                                                                                                                    int[] minFilterFieldIndexes,
                                                                                                                                                                                                    int[] maxFilterFieldIndexes)
                                                                                                                                                                                                      throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

getWriteFileRuntime

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.algebricks.runtime.base.IPushRuntimeFactory,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> getWriteFileRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSink sink,
                                                                                                                                                                                                                 int[] printColumns,
                                                                                                                                                                                                                 org.apache.hyracks.algebricks.data.IPrinterFactory[] printerFactories,
                                                                                                                                                                                                                 org.apache.hyracks.api.dataflow.value.RecordDescriptor inputDesc)

Specified by:

getWriteFileRuntime in interface org.apache.hyracks.algebricks.core.algebra.metadata.IMetadataProvider<AqlSourceId,String>

getResultHandleRuntime

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> getResultHandleRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSink sink,
                                                                                                                                                                                                         int[] printColumns,
                                                                                                                                                                                                         org.apache.hyracks.algebricks.data.IPrinterFactory[] printerFactories,
                                                                                                                                                                                                         org.apache.hyracks.api.dataflow.value.RecordDescriptor inputDesc,
                                                                                                                                                                                                         boolean ordered,
                                                                                                                                                                                                         org.apache.hyracks.api.job.JobSpecification spec)
                                                                                                                                                                                                           throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Specified by:

getResultHandleRuntime in interface org.apache.hyracks.algebricks.core.algebra.metadata.IMetadataProvider<AqlSourceId,String>

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

findDataSourceIndex

public org.apache.hyracks.algebricks.core.algebra.metadata.IDataSourceIndex<String,AqlSourceId> findDataSourceIndex(String indexId,
                                                                                                           AqlSourceId dataSourceId)
                                                                                                             throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Specified by:

findDataSourceIndex in interface org.apache.hyracks.algebricks.core.algebra.metadata.IMetadataProvider<AqlSourceId,String>

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

lookupSourceInMetadata

public AqlDataSource lookupSourceInMetadata(AqlSourceId aqlId)
                                     throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException,
                                            MetadataException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

MetadataException

scannerOperatorIsLeaf

public boolean scannerOperatorIsLeaf(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId> dataSource)

Specified by:

scannerOperatorIsLeaf in interface org.apache.hyracks.algebricks.core.algebra.metadata.IMetadataProvider<AqlSourceId,String>

getWriteResultRuntime

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> getWriteResultRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId> dataSource,
                                                                                                                                                                                                        org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema propagatedSchema,
                                                                                                                                                                                                        List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> keys,
                                                                                                                                                                                                        org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable payload,
                                                                                                                                                                                                        List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> additionalNonKeyFields,
                                                                                                                                                                                                        org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context,
                                                                                                                                                                                                        org.apache.hyracks.api.job.JobSpecification spec)
                                                                                                                                                                                                          throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Specified by:

getWriteResultRuntime in interface org.apache.hyracks.algebricks.core.algebra.metadata.IMetadataProvider<AqlSourceId,String>

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

getInsertOrDeleteRuntime

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> getInsertOrDeleteRuntime(org.apache.hyracks.storage.am.common.ophelpers.IndexOperation indexOp,
                                                                                                                                                                                                           org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId> dataSource,
                                                                                                                                                                                                           org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema propagatedSchema,
                                                                                                                                                                                                           org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv,
                                                                                                                                                                                                           List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> keys,
                                                                                                                                                                                                           org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable payload,
                                                                                                                                                                                                           List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> additionalNonKeyFields,
                                                                                                                                                                                                           org.apache.hyracks.api.dataflow.value.RecordDescriptor recordDesc,
                                                                                                                                                                                                           org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context,
                                                                                                                                                                                                           org.apache.hyracks.api.job.JobSpecification spec,
                                                                                                                                                                                                           boolean bulkload)
                                                                                                                                                                                                             throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

getInsertRuntime

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> getInsertRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId> dataSource,
                                                                                                                                                                                                   org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema propagatedSchema,
                                                                                                                                                                                                   org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv,
                                                                                                                                                                                                   List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> keys,
                                                                                                                                                                                                   org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable payload,
                                                                                                                                                                                                   List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> additionalNonKeyFields,
                                                                                                                                                                                                   org.apache.hyracks.api.dataflow.value.RecordDescriptor recordDesc,
                                                                                                                                                                                                   org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context,
                                                                                                                                                                                                   org.apache.hyracks.api.job.JobSpecification spec,
                                                                                                                                                                                                   boolean bulkload)
                                                                                                                                                                                                     throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Specified by:

getInsertRuntime in interface org.apache.hyracks.algebricks.core.algebra.metadata.IMetadataProvider<AqlSourceId,String>

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

getDeleteRuntime

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> getDeleteRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId> dataSource,
                                                                                                                                                                                                   org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema propagatedSchema,
                                                                                                                                                                                                   org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv,
                                                                                                                                                                                                   List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> keys,
                                                                                                                                                                                                   org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable payload,
                                                                                                                                                                                                   List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> additionalNonKeyFields,
                                                                                                                                                                                                   org.apache.hyracks.api.dataflow.value.RecordDescriptor recordDesc,
                                                                                                                                                                                                   org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context,
                                                                                                                                                                                                   org.apache.hyracks.api.job.JobSpecification spec)
                                                                                                                                                                                                     throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Specified by:

getDeleteRuntime in interface org.apache.hyracks.algebricks.core.algebra.metadata.IMetadataProvider<AqlSourceId,String>

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

getIndexInsertOrDeleteRuntime

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> getIndexInsertOrDeleteRuntime(org.apache.hyracks.storage.am.common.ophelpers.IndexOperation indexOp,
                                                                                                                                                                                                                org.apache.hyracks.algebricks.core.algebra.metadata.IDataSourceIndex<String,AqlSourceId> dataSourceIndex,
                                                                                                                                                                                                                org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema propagatedSchema,
                                                                                                                                                                                                                org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema[] inputSchemas,
                                                                                                                                                                                                                org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv,
                                                                                                                                                                                                                List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> primaryKeys,
                                                                                                                                                                                                                List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> secondaryKeys,
                                                                                                                                                                                                                List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> additionalNonKeyFields,
                                                                                                                                                                                                                org.apache.hyracks.algebricks.core.algebra.base.ILogicalExpression filterExpr,
                                                                                                                                                                                                                org.apache.hyracks.api.dataflow.value.RecordDescriptor recordDesc,
                                                                                                                                                                                                                org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context,
                                                                                                                                                                                                                org.apache.hyracks.api.job.JobSpecification spec,
                                                                                                                                                                                                                boolean bulkload)
                                                                                                                                                                                                                  throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

getIndexInsertRuntime

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> getIndexInsertRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSourceIndex<String,AqlSourceId> dataSourceIndex,
                                                                                                                                                                                                        org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema propagatedSchema,
                                                                                                                                                                                                        org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema[] inputSchemas,
                                                                                                                                                                                                        org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv,
                                                                                                                                                                                                        List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> primaryKeys,
                                                                                                                                                                                                        List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> secondaryKeys,
                                                                                                                                                                                                        List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> additionalNonKeyFields,
                                                                                                                                                                                                        org.apache.hyracks.algebricks.core.algebra.base.ILogicalExpression filterExpr,
                                                                                                                                                                                                        org.apache.hyracks.api.dataflow.value.RecordDescriptor recordDesc,
                                                                                                                                                                                                        org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context,
                                                                                                                                                                                                        org.apache.hyracks.api.job.JobSpecification spec,
                                                                                                                                                                                                        boolean bulkload)
                                                                                                                                                                                                          throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Specified by:

getIndexInsertRuntime in interface org.apache.hyracks.algebricks.core.algebra.metadata.IMetadataProvider<AqlSourceId,String>

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

getTokenizerRuntime

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> getTokenizerRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSourceIndex<String,AqlSourceId> dataSourceIndex,
                                                                                                                                                                                                      org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema propagatedSchema,
                                                                                                                                                                                                      org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema[] inputSchemas,
                                                                                                                                                                                                      org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv,
                                                                                                                                                                                                      List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> primaryKeys,
                                                                                                                                                                                                      List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> secondaryKeys,
                                                                                                                                                                                                      org.apache.hyracks.algebricks.core.algebra.base.ILogicalExpression filterExpr,
                                                                                                                                                                                                      org.apache.hyracks.api.dataflow.value.RecordDescriptor recordDesc,
                                                                                                                                                                                                      org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context,
                                                                                                                                                                                                      org.apache.hyracks.api.job.JobSpecification spec,
                                                                                                                                                                                                      boolean bulkload)
                                                                                                                                                                                                        throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Specified by:

getTokenizerRuntime in interface org.apache.hyracks.algebricks.core.algebra.metadata.IMetadataProvider<AqlSourceId,String>

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

getIndexDeleteRuntime

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> getIndexDeleteRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSourceIndex<String,AqlSourceId> dataSourceIndex,
                                                                                                                                                                                                        org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema propagatedSchema,
                                                                                                                                                                                                        org.apache.hyracks.algebricks.core.algebra.operators.logical.IOperatorSchema[] inputSchemas,
                                                                                                                                                                                                        org.apache.hyracks.algebricks.core.algebra.expressions.IVariableTypeEnvironment typeEnv,
                                                                                                                                                                                                        List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> primaryKeys,
                                                                                                                                                                                                        List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> secondaryKeys,
                                                                                                                                                                                                        List<org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable> additionalNonKeyFields,
                                                                                                                                                                                                        org.apache.hyracks.algebricks.core.algebra.base.ILogicalExpression filterExpr,
                                                                                                                                                                                                        org.apache.hyracks.api.dataflow.value.RecordDescriptor recordDesc,
                                                                                                                                                                                                        org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext context,
                                                                                                                                                                                                        org.apache.hyracks.api.job.JobSpecification spec)
                                                                                                                                                                                                          throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Specified by:

getIndexDeleteRuntime in interface org.apache.hyracks.algebricks.core.algebra.metadata.IMetadataProvider<AqlSourceId,String>

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

getJobId

public JobId getJobId()

createBTreeNSMInteriorFrameFactory

public static org.apache.hyracks.storage.am.common.api.ITreeIndexFrameFactory createBTreeNSMInteriorFrameFactory(org.apache.hyracks.api.dataflow.value.ITypeTraits[] typeTraits)

proposeLinearizer

public static org.apache.hyracks.api.dataflow.value.ILinearizeComparatorFactory proposeLinearizer(ATypeTag keyType,
                                                                                  int numKeyFields)
                                                                                           throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

getCardinalityPerPartitionHint

public long getCardinalityPerPartitionHint(Dataset dataset)
                                    throws MetadataException,
                                           org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Calculate an estimate size of the bloom filter. Note that this is an estimation which assumes that the data is going to be uniformly distributed across all partitions.

Parameters:

dataset -

Returns:

Number of elements that will be used to create a bloom filter per dataset per partition

Throws:

MetadataException

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

lookupFunction

public org.apache.hyracks.algebricks.core.algebra.functions.IFunctionInfo lookupFunction(org.apache.hyracks.algebricks.core.algebra.functions.FunctionIdentifier fid)

Specified by:

lookupFunction in interface org.apache.hyracks.algebricks.core.algebra.metadata.IMetadataProvider<AqlSourceId,String>

splitProviderAndPartitionConstraintsForDataset

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.dataflow.std.file.IFileSplitProvider,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> splitProviderAndPartitionConstraintsForDataset(String dataverseName,
                                                                                                                                                                                                                                     String datasetName,
                                                                                                                                                                                                                                     String targetIdxName,
                                                                                                                                                                                                                                     boolean temp)
                                                                                                                                                                                                                                       throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

splitProviderAndPartitionConstraintsForDataverse

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.dataflow.std.file.IFileSplitProvider,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> splitProviderAndPartitionConstraintsForDataverse(String dataverse)

splitsForDataset

public org.apache.hyracks.dataflow.std.file.FileSplit[] splitsForDataset(MetadataTransactionContext mdTxnCtx,
                                                                String dataverseName,
                                                                String datasetName,
                                                                String targetIdxName,
                                                                boolean temp)
                                                                  throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

getAdapter

public DatasourceAdapter getAdapter(MetadataTransactionContext mdTxnCtx,
                           String dataverseName,
                           String adapterName)
                             throws MetadataException

Throws:

MetadataException

findDataset

public Dataset findDataset(String dataverse,
                  String dataset)
                    throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

findType

public IAType findType(String dataverse,
              String typeName)
                throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

findFeed

public Feed findFeed(String dataverse,
            String feedName)
              throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

findFeedPolicy

public FeedPolicy findFeedPolicy(String dataverse,
                        String policyName)
                          throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

getDatasetIndexes

public List<Index> getDatasetIndexes(String dataverseName,
                            String datasetName)
                              throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

getClusterLocations

public org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint getClusterLocations()

getFormat

public IDataFormat getFormat()

splitProviderAndPartitionConstraintsForFilesIndex

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.dataflow.std.file.IFileSplitProvider,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> splitProviderAndPartitionConstraintsForFilesIndex(String dataverseName,
                                                                                                                                                                                                                                        String datasetName,
                                                                                                                                                                                                                                        String targetIdxName,
                                                                                                                                                                                                                                        boolean create)
                                                                                                                                                                                                                                          throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

getStorageProperties

public AsterixStorageProperties getStorageProperties()

getLocks

public Map<String,Integer> getLocks()

setLocks

public void setLocks(Map<String,Integer> locks)