Uses of Class
org.apache.asterix.metadata.declared.AqlSourceId

Packages that use AqlSourceId

Package	Description
org.apache.asterix.metadata.declared

Uses of AqlSourceId in org.apache.asterix.metadata.declared

Methods in org.apache.asterix.metadata.declared that return AqlSourceId

Modifier and Type	Method and Description
AqlSourceId	AqlDataSource.getId()

Methods in org.apache.asterix.metadata.declared that return types with arguments of type AqlSourceId

Modifier and Type	Method and Description
org.apache.hyracks.algebricks.core.algebra.metadata.IDataSourceIndex<String,AqlSourceId>	AqlMetadataProvider.findDataSourceIndex(String indexId, AqlSourceId dataSourceId)
org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId>	AqlIndex.getDataSource()

Methods in org.apache.asterix.metadata.declared with parameters of type AqlSourceId

Modifier and Type	Method and Description
AqlDataSource	AqlMetadataProvider.findDataSource(AqlSourceId id)
org.apache.hyracks.algebricks.core.algebra.metadata.IDataSourceIndex<String,AqlSourceId>	AqlMetadataProvider.findDataSourceIndex(String indexId, AqlSourceId dataSourceId)
AqlDataSource	AqlMetadataProvider.lookupSourceInMetadata(AqlSourceId aqlId)

Method parameters in org.apache.asterix.metadata.declared with type arguments of type AqlSourceId

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>	AqlMetadataProvider.buildFeedCollectRuntime(org.apache.hyracks.api.job.JobSpecification jobSpec, org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId> dataSource)
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	AqlMetadataProvider.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)
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	AqlMetadataProvider.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>	AqlMetadataProvider.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>	AqlMetadataProvider.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>	AqlMetadataProvider.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>	AqlMetadataProvider.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)
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	AqlMetadataProvider.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)
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	AqlMetadataProvider.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.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	AqlMetadataProvider.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)
boolean	AqlMetadataProvider.scannerOperatorIsLeaf(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<AqlSourceId> dataSource)

Constructors in org.apache.asterix.metadata.declared with parameters of type AqlSourceId

Constructor and Description
AqlDataSource(AqlSourceId id, String datasourceDataverse, String datasourceName, IAType itemType, AqlDataSource.AqlDataSourceType datasourceType)
DatasetDataSource(AqlSourceId id, String datasourceDataverse, String datasourceName, IAType itemType, AqlDataSource.AqlDataSourceType datasourceType)
FeedDataSource(AqlSourceId id, String targetDataset, IAType itemType, AqlDataSource.AqlDataSourceType dataSourceType, FeedId sourceFeedId, Feed.FeedType sourceFeedType, IFeedLifecycleListener.ConnectionLocation location, String[] locations)