Package uk.gov.gchq.gaffer.accumulostore.utils

Class LegacySupport.InputConfigurator

java.lang.Object

uk.gov.gchq.gaffer.accumulostore.utils.LegacySupport.InputConfigurator

Enclosing class:

LegacySupport

public static class LegacySupport.InputConfigurator
extends Object

Constructor Summary

Constructors

Constructor	Description
InputConfigurator()

Method Summary

Modifier and Type	Method	Description
static void	addIterator(Class<org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat> accumuloInputFormatClass, org.apache.hadoop.conf.Configuration conf, org.apache.accumulo.core.client.IteratorSetting elementPreFilter)
static void	fetchColumns(Class<org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat> accumuloInputFormatClass, org.apache.hadoop.conf.Configuration conf, Collection<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> columnFamilyColumnQualifierPairs)
static Set<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>>	getFetchedColumns(Class<org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat> accumuloInputFormatClass, org.apache.hadoop.conf.Configuration conf)
static List<org.apache.accumulo.core.client.IteratorSetting>	getIterators(Class<org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat> accumuloInputFormatClass, org.apache.hadoop.conf.Configuration conf)
static void	setBatchScan(Class<org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat> accumuloInputFormatClass, org.apache.hadoop.conf.Configuration conf, boolean enableFeature)
static void	setConnectorInfo(Class<org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat> accumuloInputFormatClass, org.apache.hadoop.conf.Configuration conf, String user, org.apache.accumulo.core.client.security.tokens.AuthenticationToken token)
static void	setInputTableName(Class<org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat> accumuloInputFormatClass, org.apache.hadoop.conf.Configuration conf, String tableName)
static void	setRanges(Class<org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat> accumuloInputFormatClass, org.apache.hadoop.conf.Configuration conf, Collection<org.apache.accumulo.core.data.Range> ranges)
static void	setScanAuthorizations(Class<?> implementingClass, org.apache.hadoop.conf.Configuration conf, org.apache.accumulo.core.security.Authorizations auths)
static void	setZooKeeperInstance(Class<org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat> accumuloInputFormatClass, org.apache.hadoop.conf.Configuration conf, org.apache.accumulo.core.client.ClientConfiguration withZkHosts)

Methods inherited from class java.lang.Object

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

Constructor Detail

InputConfigurator

public InputConfigurator()

Method Detail

setScanAuthorizations

public static void setScanAuthorizations(Class<?> implementingClass,
                                         org.apache.hadoop.conf.Configuration conf,
                                         org.apache.accumulo.core.security.Authorizations auths)

setInputTableName

public static void setInputTableName(Class<org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat> accumuloInputFormatClass,
                                     org.apache.hadoop.conf.Configuration conf,
                                     String tableName)

fetchColumns

public static void fetchColumns(Class<org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat> accumuloInputFormatClass,
                                org.apache.hadoop.conf.Configuration conf,
                                Collection<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> columnFamilyColumnQualifierPairs)

addIterator

public static void addIterator(Class<org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat> accumuloInputFormatClass,
                               org.apache.hadoop.conf.Configuration conf,
                               org.apache.accumulo.core.client.IteratorSetting elementPreFilter)

setConnectorInfo

public static void setConnectorInfo(Class<org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat> accumuloInputFormatClass,
                                    org.apache.hadoop.conf.Configuration conf,
                                    String user,
                                    org.apache.accumulo.core.client.security.tokens.AuthenticationToken token)

setZooKeeperInstance

public static void setZooKeeperInstance(Class<org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat> accumuloInputFormatClass,
                                        org.apache.hadoop.conf.Configuration conf,
                                        org.apache.accumulo.core.client.ClientConfiguration withZkHosts)

setBatchScan

public static void setBatchScan(Class<org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat> accumuloInputFormatClass,
                                org.apache.hadoop.conf.Configuration conf,
                                boolean enableFeature)

setRanges

public static void setRanges(Class<org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat> accumuloInputFormatClass,
                             org.apache.hadoop.conf.Configuration conf,
                             Collection<org.apache.accumulo.core.data.Range> ranges)

getIterators

public static List<org.apache.accumulo.core.client.IteratorSetting> getIterators(Class<org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat> accumuloInputFormatClass,
                                                                                 org.apache.hadoop.conf.Configuration conf)

getFetchedColumns

public static Set<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> getFetchedColumns(Class<org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat> accumuloInputFormatClass,
                                                                                                                                   org.apache.hadoop.conf.Configuration conf)