org.apache.hadoop.hive.metastore

Class DefaultPartitionExpressionProxy

java.lang.Object

org.apache.hadoop.hive.metastore.DefaultPartitionExpressionProxy

All Implemented Interfaces:

PartitionExpressionProxy

public class DefaultPartitionExpressionProxy
extends Object
implements PartitionExpressionProxy

Default implementation of PartitionExpressionProxy. Eventually this should use the SARGs in Hive's storage-api. For now it just throws UnsupportedOperationException.

Constructor Summary

Constructors

Constructor and Description
DefaultPartitionExpressionProxy()

Method Summary

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<org.apache.hadoop.hive.metastore.api.FieldSchema> partColumns, byte[] expr, String defaultPartitionName, List<String> partitionNames) Filters the partition names via serialized Hive expression.
FileFormatProxy	getFileFormatProxy(org.apache.hadoop.hive.metastore.api.FileMetadataExprType type) Gets a separate proxy that can be used to call file-format-specific methods.
org.apache.hadoop.hive.metastore.api.FileMetadataExprType	getMetadataType(String inputFormat) Determines the file metadata type from input format of the source table or partition.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultPartitionExpressionProxy

public DefaultPartitionExpressionProxy()

Method Detail

convertExprToFilter

public String convertExprToFilter(byte[] expr)
                           throws org.apache.hadoop.hive.metastore.api.MetaException

Description copied from interface: PartitionExpressionProxy

Converts serialized Hive expression into filter in the format suitable for Filter.g.

Specified by:

convertExprToFilter in interface PartitionExpressionProxy

Parameters:

expr - Serialized expression.

Returns:

The filter string.

Throws:

org.apache.hadoop.hive.metastore.api.MetaException

filterPartitionsByExpr

public boolean filterPartitionsByExpr(List<org.apache.hadoop.hive.metastore.api.FieldSchema> partColumns,
                                      byte[] expr,
                                      String defaultPartitionName,
                                      List<String> partitionNames)
                               throws org.apache.hadoop.hive.metastore.api.MetaException

Description copied from interface: PartitionExpressionProxy

Filters the partition names via serialized Hive expression.

Specified by:

filterPartitionsByExpr in interface PartitionExpressionProxy

Parameters:

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.

Returns:

Whether there were any unknown partitions preserved in the name list.

Throws:

org.apache.hadoop.hive.metastore.api.MetaException

getMetadataType

public org.apache.hadoop.hive.metastore.api.FileMetadataExprType getMetadataType(String inputFormat)

Description copied from interface: PartitionExpressionProxy

Determines the file metadata type from input format of the source table or partition.

Specified by:

getMetadataType in interface PartitionExpressionProxy

Parameters:

inputFormat - Input format name.

Returns:

The file metadata type.

getFileFormatProxy

public FileFormatProxy getFileFormatProxy(org.apache.hadoop.hive.metastore.api.FileMetadataExprType type)

Description copied from interface: PartitionExpressionProxy

Gets a separate proxy that can be used to call file-format-specific methods.

Specified by:

getFileFormatProxy in interface PartitionExpressionProxy

Parameters:

type - The file metadata type.

Returns:

The proxy.

createSarg

public org.apache.hadoop.hive.ql.io.sarg.SearchArgument createSarg(byte[] expr)

Description copied from interface: PartitionExpressionProxy

Creates SARG from serialized representation.

Specified by:

createSarg in interface PartitionExpressionProxy

Parameters:

expr - SARG, serialized as Kryo.

Returns:

SARG.