public class PartitionExpressionForMetastore extends Object implements PartitionExpressionProxy
Constructor and Description |
---|
PartitionExpressionForMetastore() |
Modifier and Type | Method and Description |
---|---|
String |
convertExprToFilter(byte[] exprBytes)
Converts serialized Hive expression into filter in the format suitable for Filter.g.
|
boolean |
filterPartitionsByExpr(List<String> partColumnNames,
List<PrimitiveTypeInfo> partColumnTypeInfos,
byte[] exprBytes,
String defaultPartitionName,
List<String> partitionNames)
Filters the partition names via serialized Hive expression.
|
public String convertExprToFilter(byte[] exprBytes) throws MetaException
PartitionExpressionProxy
convertExprToFilter
in interface PartitionExpressionProxy
exprBytes
- Serialized expression.MetaException
public boolean filterPartitionsByExpr(List<String> partColumnNames, List<PrimitiveTypeInfo> partColumnTypeInfos, byte[] exprBytes, String defaultPartitionName, List<String> partitionNames) throws MetaException
PartitionExpressionProxy
filterPartitionsByExpr
in interface PartitionExpressionProxy
partColumnNames
- Partition column names in the underlying table.partColumnTypeInfos
- Partition column types in the underlying tableexprBytes
- Serialized expression.defaultPartitionName
- Default partition name from job or server configuration.partitionNames
- Partition names; the list is modified in place.MetaException
Copyright © 2017 The Apache Software Foundation. All rights reserved.