public class DatasetUtils extends Object
| Constructor and Description |
|---|
DatasetUtils() |
| 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) |
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
org.apache.hyracks.algebricks.common.exceptions.AlgebricksExceptionpublic static int[] createBloomFilterKeyFields(Dataset dataset) throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException
org.apache.hyracks.algebricks.common.exceptions.AlgebricksExceptionpublic 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
org.apache.hyracks.algebricks.common.exceptions.AlgebricksExceptionpublic static org.apache.hyracks.api.dataflow.value.ITypeTraits[] computeTupleTypeTraits(Dataset dataset, ARecordType itemType) throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException
org.apache.hyracks.algebricks.common.exceptions.AlgebricksExceptionpublic 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
org.apache.hyracks.algebricks.common.exceptions.AlgebricksExceptionpublic static org.apache.hyracks.api.dataflow.value.ITypeTraits[] computeFilterTypeTraits(Dataset dataset, ARecordType itemType) throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException
org.apache.hyracks.algebricks.common.exceptions.AlgebricksExceptionpublic static int[] createFilterFields(Dataset dataset) throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException
org.apache.hyracks.algebricks.common.exceptions.AlgebricksExceptionpublic static int[] createBTreeFieldsWhenThereisAFilter(Dataset dataset) throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException
org.apache.hyracks.algebricks.common.exceptions.AlgebricksExceptionpublic static int getPositionOfPartitioningKeyField(Dataset dataset, String fieldExpr)
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
org.apache.hyracks.algebricks.common.exceptions.AlgebricksExceptionMetadataExceptionpublic static void writePropertyTypeRecord(String name, String value, DataOutput out, ARecordType recordType) throws org.apache.hyracks.api.exceptions.HyracksDataException
org.apache.hyracks.api.exceptions.HyracksDataExceptionCopyright © 2016 The Apache Software Foundation. All rights reserved.