Package | Description |
---|---|
org.apache.hadoop.hive.accumulo |
Serde and InputFormat support for connecting Hive to Accumulo tables.
|
org.apache.hadoop.hive.accumulo.mr |
map reduce and supporting classes
|
org.apache.hadoop.hive.accumulo.serde |
accumulo serde classes
|
Modifier and Type | Field and Description |
---|---|
protected AccumuloConnectionParameters |
AccumuloStorageHandler.connectionParams |
Modifier and Type | Method and Description |
---|---|
AccumuloConnectionParameters |
AccumuloDefaultIndexScanner.getConnectParams() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier> |
HiveAccumuloHelper.setConnectorInfoForInputAndOutput(AccumuloConnectionParameters params,
org.apache.accumulo.core.client.Connector conn,
org.apache.hadoop.conf.Configuration conf)
Obtains an Accumulo DelegationToken and sets it in the configuration for input and output jobs.
|
void |
AccumuloDefaultIndexScanner.setConnectParams(AccumuloConnectionParameters connectParams) |
void |
HiveAccumuloHelper.updateInputFormatConfWithAccumuloToken(org.apache.hadoop.mapred.JobConf jobConf,
org.apache.hadoop.security.UserGroupInformation currentUser,
AccumuloConnectionParameters cnxnParams) |
void |
HiveAccumuloHelper.updateOutputFormatConfWithAccumuloToken(org.apache.hadoop.mapred.JobConf jobConf,
org.apache.hadoop.security.UserGroupInformation currentUser,
AccumuloConnectionParameters cnxnParams) |
Modifier and Type | Method and Description |
---|---|
protected void |
HiveAccumuloTableInputFormat.configure(org.apache.hadoop.mapred.JobConf conf,
org.apache.accumulo.core.client.Instance instance,
org.apache.accumulo.core.client.Connector connector,
AccumuloConnectionParameters accumuloParams,
ColumnMapper columnMapper,
List<org.apache.accumulo.core.client.IteratorSetting> iterators,
Collection<org.apache.accumulo.core.data.Range> ranges)
Configure the underlying AccumuloInputFormat
|
Modifier and Type | Class and Description |
---|---|
class |
AccumuloSerDeParameters |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.