org.apache.hadoop.hive.kudu

Class KuduHiveUtils

java.lang.Object

org.apache.hadoop.hive.kudu.KuduHiveUtils

public final class KuduHiveUtils
extends Object

A collection of static utility methods for the Kudu Hive integration. This is useful for code sharing.

Method Summary

Modifier and Type	Method and Description
static org.apache.hadoop.conf.Configuration	createOverlayedConf(org.apache.hadoop.conf.Configuration conf, Properties tblProps) Returns the union of the configuration and table properties with the table properties taking precedence.
static org.apache.kudu.client.KuduClient	getKuduClient(org.apache.hadoop.conf.Configuration conf)
static String	getMasterAddresses(org.apache.hadoop.conf.Configuration conf)
static void	importCredentialsFromCurrentSubject(org.apache.kudu.client.KuduClient client)
static PrimitiveTypeInfo	toHiveType(org.apache.kudu.Type kuduType, org.apache.kudu.ColumnTypeAttributes attributes)

Methods inherited from class java.lang.Object

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

Method Detail

createOverlayedConf

public static org.apache.hadoop.conf.Configuration createOverlayedConf(org.apache.hadoop.conf.Configuration conf,
                                                                       Properties tblProps)

Returns the union of the configuration and table properties with the table properties taking precedence.

getMasterAddresses

public static String getMasterAddresses(org.apache.hadoop.conf.Configuration conf)
                                 throws IOException

Throws:

IOException

getKuduClient

public static org.apache.kudu.client.KuduClient getKuduClient(org.apache.hadoop.conf.Configuration conf)
                                                       throws IOException

Throws:

IOException

importCredentialsFromCurrentSubject

public static void importCredentialsFromCurrentSubject(org.apache.kudu.client.KuduClient client)

toHiveType

public static PrimitiveTypeInfo toHiveType(org.apache.kudu.Type kuduType,
                                           org.apache.kudu.ColumnTypeAttributes attributes)
                                    throws SerDeException

Throws:

SerDeException