public interface PartitionExpressionProxy
Modifier and Type | Method and Description |
---|---|
String |
convertExprToFilter(byte[] expr)
Converts serialized Hive expression into filter in the format suitable for Filter.g.
|
SearchArgument |
createSarg(byte[] expr)
Creates SARG from serialized representation.
|
boolean |
filterPartitionsByExpr(List<String> partColumnNames,
List<PrimitiveTypeInfo> partColumnTypeInfos,
byte[] expr,
String defaultPartitionName,
List<String> partitionNames)
Filters the partition names via serialized Hive expression.
|
FileFormatProxy |
getFileFormatProxy(FileMetadataExprType type)
Gets a separate proxy that can be used to call file-format-specific methods.
|
FileMetadataExprType |
getMetadataType(String inputFormat)
Determines the file metadata type from input format of the source table or partition.
|
String convertExprToFilter(byte[] expr) throws MetaException
expr
- Serialized expression.MetaException
boolean filterPartitionsByExpr(List<String> partColumnNames, List<PrimitiveTypeInfo> partColumnTypeInfos, byte[] expr, String defaultPartitionName, List<String> partitionNames) throws MetaException
partColumnNames
- Partition column names in the underlying table.partColumnTypeInfos
- Partition column types in the underlying tableexpr
- Serialized expression.defaultPartitionName
- Default partition name from job or server configuration.partitionNames
- Partition names; the list is modified in place.MetaException
FileMetadataExprType getMetadataType(String inputFormat)
inputFormat
- Input format name.FileFormatProxy getFileFormatProxy(FileMetadataExprType type)
type
- The file metadata type.SearchArgument createSarg(byte[] expr)
expr
- SARG, serialized as Kryo.Copyright © 2016 The Apache Software Foundation. All rights reserved.