org.apache.asterix.metadata.utils

Class DatasetUtils

java.lang.Object

org.apache.asterix.metadata.utils.DatasetUtils

public class DatasetUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
DatasetUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static org.apache.hyracks.api.dataflow.value.IBinaryComparatorFactory[]	computeFilterBinaryComparatorFactories(Dataset dataset, ARecordType itemType, org.apache.hyracks.algebricks.data.IBinaryComparatorFactoryProvider comparatorFactoryProvider)
static org.apache.hyracks.api.dataflow.value.ITypeTraits[]	computeFilterTypeTraits(Dataset dataset, ARecordType itemType)
static org.apache.hyracks.api.dataflow.value.IBinaryComparatorFactory[]	computeKeysBinaryComparatorFactories(Dataset dataset, ARecordType itemType, org.apache.hyracks.algebricks.data.IBinaryComparatorFactoryProvider comparatorFactoryProvider)
static org.apache.hyracks.api.dataflow.value.IBinaryHashFunctionFactory[]	computeKeysBinaryHashFunFactories(Dataset dataset, ARecordType itemType, org.apache.hyracks.algebricks.data.IBinaryHashFunctionFactoryProvider hashFunProvider)
static org.apache.hyracks.api.dataflow.value.ITypeTraits[]	computeTupleTypeTraits(Dataset dataset, ARecordType itemType)
static int[]	createBloomFilterKeyFields(Dataset dataset)
static int[]	createBTreeFieldsWhenThereisAFilter(Dataset dataset)
static int[]	createFilterFields(Dataset dataset)
static List<String>	getFilterField(Dataset dataset)
static org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.storage.am.lsm.common.api.ILSMMergePolicyFactory,Map<String,String>>	getMergePolicyFactory(Dataset dataset, MetadataTransactionContext mdTxnCtx)
static List<List<String>>	getPartitioningKeys(Dataset dataset)
static int	getPositionOfPartitioningKeyField(Dataset dataset, String fieldExpr)
static void	writePropertyTypeRecord(String name, String value, DataOutput out, ARecordType recordType)

Methods inherited from class java.lang.Object

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

Constructor Detail

DatasetUtils

public DatasetUtils()

Method Detail

computeKeysBinaryComparatorFactories

public static org.apache.hyracks.api.dataflow.value.IBinaryComparatorFactory[] computeKeysBinaryComparatorFactories(Dataset dataset,
                                                                                                    ARecordType itemType,
                                                                                                    org.apache.hyracks.algebricks.data.IBinaryComparatorFactoryProvider comparatorFactoryProvider)
                                                                                                             throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

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

createBloomFilterKeyFields

public static int[] createBloomFilterKeyFields(Dataset dataset)
                                        throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

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

computeKeysBinaryHashFunFactories

public static org.apache.hyracks.api.dataflow.value.IBinaryHashFunctionFactory[] computeKeysBinaryHashFunFactories(Dataset dataset,
                                                                                                   ARecordType itemType,
                                                                                                   org.apache.hyracks.algebricks.data.IBinaryHashFunctionFactoryProvider hashFunProvider)
                                                                                                            throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

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

computeTupleTypeTraits

public static org.apache.hyracks.api.dataflow.value.ITypeTraits[] computeTupleTypeTraits(Dataset dataset,
                                                                         ARecordType itemType)
                                                                                  throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

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

getPartitioningKeys

public static List<List<String>> getPartitioningKeys(Dataset dataset)

getFilterField

public static List<String> getFilterField(Dataset dataset)

computeFilterBinaryComparatorFactories

public static org.apache.hyracks.api.dataflow.value.IBinaryComparatorFactory[] computeFilterBinaryComparatorFactories(Dataset dataset,
                                                                                                      ARecordType itemType,
                                                                                                      org.apache.hyracks.algebricks.data.IBinaryComparatorFactoryProvider comparatorFactoryProvider)
                                                                                                               throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

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

computeFilterTypeTraits

public static org.apache.hyracks.api.dataflow.value.ITypeTraits[] computeFilterTypeTraits(Dataset dataset,
                                                                          ARecordType itemType)
                                                                                   throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

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

createFilterFields

public static int[] createFilterFields(Dataset dataset)
                                throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

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

createBTreeFieldsWhenThereisAFilter

public static int[] createBTreeFieldsWhenThereisAFilter(Dataset dataset)
                                                 throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

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

getPositionOfPartitioningKeyField

public static int getPositionOfPartitioningKeyField(Dataset dataset,
                                    String fieldExpr)

getMergePolicyFactory

public static org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.storage.am.lsm.common.api.ILSMMergePolicyFactory,Map<String,String>> getMergePolicyFactory(Dataset dataset,
                                                                                                                                                            MetadataTransactionContext mdTxnCtx)
                                                                                                                                                                     throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException,
                                                                                                                                                                            MetadataException

Throws:

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

MetadataException

writePropertyTypeRecord

public static void writePropertyTypeRecord(String name,
                           String value,
                           DataOutput out,
                           ARecordType recordType)
                                    throws org.apache.hyracks.api.exceptions.HyracksDataException

Throws:

org.apache.hyracks.api.exceptions.HyracksDataException