org.apache.hadoop.hive.accumulo.mr

Class IndexOutputConfigurator

java.lang.Object

org.apache.accumulo.core.client.mapreduce.lib.impl.ConfiguratorBase

org.apache.accumulo.core.client.mapreduce.lib.impl.OutputConfigurator

org.apache.hadoop.hive.accumulo.mr.IndexOutputConfigurator

public class IndexOutputConfigurator
extends org.apache.accumulo.core.client.mapreduce.lib.impl.OutputConfigurator

Extension of OutputConfigurtion to support indexing.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IndexOutputConfigurator.WriteOpts Accumulo Write options.

Nested classes/interfaces inherited from class org.apache.accumulo.core.client.mapreduce.lib.impl.OutputConfigurator

org.apache.accumulo.core.client.mapreduce.lib.impl.OutputConfigurator.Features

Nested classes/interfaces inherited from class org.apache.accumulo.core.client.mapreduce.lib.impl.ConfiguratorBase

org.apache.accumulo.core.client.mapreduce.lib.impl.ConfiguratorBase.ConnectorInfo, org.apache.accumulo.core.client.mapreduce.lib.impl.ConfiguratorBase.GeneralOpts, org.apache.accumulo.core.client.mapreduce.lib.impl.ConfiguratorBase.InstanceOpts, org.apache.accumulo.core.client.mapreduce.lib.impl.ConfiguratorBase.TokenSource

Constructor Summary

Constructors

Constructor and Description
IndexOutputConfigurator()

Method Summary

Modifier and Type	Method and Description
static String	getIndexColumns(Class<?> implementingClass, org.apache.hadoop.conf.Configuration conf)
static String	getIndexTableName(Class<?> implementingClass, org.apache.hadoop.conf.Configuration conf)
static Boolean	getRecordEncoding(Class<?> implementingClass, org.apache.hadoop.conf.Configuration conf)
static void	setIndexColumns(Class<?> implementingClass, org.apache.hadoop.conf.Configuration conf, String tableName)
static void	setIndexTableName(Class<?> implementingClass, org.apache.hadoop.conf.Configuration conf, String tableName)
static void	setRecordEncoding(Class<?> implementingClass, org.apache.hadoop.conf.Configuration conf, Boolean isBinary)

Methods inherited from class org.apache.accumulo.core.client.mapreduce.lib.impl.OutputConfigurator

canCreateTables, getBatchWriterOptions, getDefaultTableName, getSimulationMode, setBatchWriterOptions, setCreateTables, setDefaultTableName, setSimulationMode

Methods inherited from class org.apache.accumulo.core.client.mapreduce.lib.impl.ConfiguratorBase

enumToConfKey, enumToConfKey, getAuthenticationToken, getClientConfiguration, getInstance, getLogLevel, getPrincipal, getTokenFromFile, getVisibilityCacheSize, isConnectorInfoSet, setConnectorInfo, setConnectorInfo, setLogLevel, setMockInstance, setVisibilityCacheSize, setZooKeeperInstance, unwrapAuthenticationToken, unwrapAuthenticationToken

Methods inherited from class java.lang.Object

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

Constructor Detail

IndexOutputConfigurator

public IndexOutputConfigurator()

Method Detail

setIndexTableName

public static void setIndexTableName(Class<?> implementingClass,
                                     org.apache.hadoop.conf.Configuration conf,
                                     String tableName)

getIndexTableName

public static String getIndexTableName(Class<?> implementingClass,
                                       org.apache.hadoop.conf.Configuration conf)

setIndexColumns

public static void setIndexColumns(Class<?> implementingClass,
                                   org.apache.hadoop.conf.Configuration conf,
                                   String tableName)

getIndexColumns

public static String getIndexColumns(Class<?> implementingClass,
                                     org.apache.hadoop.conf.Configuration conf)

setRecordEncoding

public static void setRecordEncoding(Class<?> implementingClass,
                                     org.apache.hadoop.conf.Configuration conf,
                                     Boolean isBinary)

getRecordEncoding

public static Boolean getRecordEncoding(Class<?> implementingClass,
                                        org.apache.hadoop.conf.Configuration conf)