Package org.apache.vxquery.metadata

Class VXQueryMetadataProvider

java.lang.Object

org.apache.vxquery.metadata.VXQueryMetadataProvider

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor	Description
VXQueryMetadataProvider(String[] nodeList, Map<String,File> sourceFileMap, StaticContext staticCtx, String hdfsConf, Map<String,org.apache.hyracks.api.client.NodeControllerInfo> nodeControllerInfos)

Method Summary

Modifier and Type	Method	Description
org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<String>	findDataSource(String id)
org.apache.hyracks.algebricks.core.algebra.metadata.IDataSourceIndex<String,String>	findDataSourceIndex(String indexId, String dataSourceId)
static org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint	getClusterLocations(String[] nodeList)
static org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint	getClusterLocations(String[] nodeList, int partitions)
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<String> 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 payLoadVar, 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 jobSpec)
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,String> dataSource, 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>	getIndexInsertRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSourceIndex<String,String> dataSource, 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>	getInsertRuntime(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<String> 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 payLoadVar, 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 jobSpec, boolean bulkload)
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.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<String> 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)
Map<String,File>	getSourceFileMap()
StaticContext	getStaticContext()
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,String> dataSource, 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<String> 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 payLoadVar, 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 jobSpec)
org.apache.hyracks.algebricks.core.algebra.functions.IFunctionInfo	lookupFunction(org.apache.hyracks.algebricks.core.algebra.functions.FunctionIdentifier fid)
boolean	scannerOperatorIsLeaf(org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<String> dataSource)

Methods inherited from class java.lang.Object

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

Constructor Detail

VXQueryMetadataProvider

public VXQueryMetadataProvider(String[] nodeList,
                               Map<String,File> sourceFileMap,
                               StaticContext staticCtx,
                               String hdfsConf,
                               Map<String,org.apache.hyracks.api.client.NodeControllerInfo> nodeControllerInfos)

Method Detail

findDataSource

public org.apache.hyracks.algebricks.core.algebra.metadata.IDataSource<String> findDataSource(String id)
                                                                                       throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Specified by:

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

Throws:

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

getSourceFileMap

public Map<String,File> getSourceFileMap()

getStaticContext

public StaticContext getStaticContext()

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<String> 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<String,String>

Throws:

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

getClusterLocations

public static org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint getClusterLocations(String[] nodeList)

getClusterLocations

public static org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint getClusterLocations(String[] nodeList,
                                                                                                                 int partitions)

scannerOperatorIsLeaf

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

Specified by:

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

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)
                                                                                                                                                                                                                   throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Specified by:

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

Throws:

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

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<String> 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 payLoadVar,
                                                                                                                                                                                                                 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 jobSpec)
                                                                                                                                                                                                          throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Specified by:

getWriteResultRuntime in interface org.apache.hyracks.algebricks.core.algebra.metadata.IMetadataProvider<String,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<String> 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 payLoadVar,
                                                                                                                                                                                                            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 jobSpec)
                                                                                                                                                                                                     throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Specified by:

getDeleteRuntime in interface org.apache.hyracks.algebricks.core.algebra.metadata.IMetadataProvider<String,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,String> dataSource,
                                                                                                                                                                                                                 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<String,String>

Throws:

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

findDataSourceIndex

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

Specified by:

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

Throws:

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<String,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<String,String>

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<String> 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 payLoadVar,
                                                                                                                                                                                                            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 jobSpec,
                                                                                                                                                                                                            boolean bulkload)
                                                                                                                                                                                                     throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Specified by:

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

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,String> dataSource,
                                                                                                                                                                                                                 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<String,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,String> dataSource,
                                                                                                                                                                                                               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<String,String>

Throws:

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