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.
|
org.apache.hadoop.hive.ql.io.sarg.SearchArgument |
createSarg(byte[] expr)
Creates SARG from serialized representation.
|
boolean |
filterPartitionsByExpr(List<FieldSchema> partColumns,
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<FieldSchema> partColumns, byte[] expr, String defaultPartitionName, List<String> partitionNames) throws MetaException
partColumns
- Partition columns in the underlying table.expr
- 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.org.apache.hadoop.hive.ql.io.sarg.SearchArgument createSarg(byte[] expr)
expr
- SARG, serialized as Kryo.Copyright © 2019 The Apache Software Foundation. All rights reserved.