Uses of Class
uk.gov.gchq.gaffer.accumulostore.AccumuloStore
-
-
Uses of AccumuloStore in uk.gov.gchq.gaffer.accumulostore
Subclasses of AccumuloStore in uk.gov.gchq.gaffer.accumulostore Modifier and Type Class Description class
SingleUseAccumuloStore
AnAccumuloStore
that deletes the underlying table each time it is initialised. -
Uses of AccumuloStore in uk.gov.gchq.gaffer.accumulostore.key
Methods in uk.gov.gchq.gaffer.accumulostore.key with parameters of type AccumuloStore Modifier and Type Method Description org.apache.accumulo.core.client.IteratorSetting
IteratorSettingFactory. getAggregatorIteratorSetting(AccumuloStore store)
Returns an Iterator that will aggregate values in the accumulo table, this iterator will be applied to the table on creationorg.apache.accumulo.core.client.IteratorSetting
IteratorSettingFactory. getElementPostAggregationFilterIteratorSetting(View view, AccumuloStore store)
Returns anIteratorSetting
that can be used to apply an iterator that will filter elements based on predicates specified in the postAggregation block in the view to aScanner
.org.apache.accumulo.core.client.IteratorSetting
IteratorSettingFactory. getElementPreAggregationFilterIteratorSetting(View view, AccumuloStore store)
Returns anIteratorSetting
that can be used to apply an iterator that will filter elements based on predicates specified in the preAggregation block in the view to aScanner
.org.apache.accumulo.core.client.IteratorSetting
IteratorSettingFactory. getIteratorSetting(AccumuloStore store, String iteratorName)
Returns the iterator settings for a given iterator name.org.apache.accumulo.core.client.IteratorSetting
IteratorSettingFactory. getQueryTimeAggregatorIteratorSetting(View view, AccumuloStore store)
Returns an Iterator that will aggregate values at query time.org.apache.accumulo.core.client.IteratorSetting
IteratorSettingFactory. getRowIDAggregatorIteratorSetting(AccumuloStore store, String columnFamily)
Returns an Iterator that will aggregate properties across a range of RowID's for a given columnFamilyorg.apache.accumulo.core.client.IteratorSetting
IteratorSettingFactory. getValidatorIteratorSetting(AccumuloStore store)
Returns an Iterator that will validate elements in the accumulo table based on the validator provided in theSchema
this iterator will be applied to the table on creation -
Uses of AccumuloStore in uk.gov.gchq.gaffer.accumulostore.key.core
Methods in uk.gov.gchq.gaffer.accumulostore.key.core with parameters of type AccumuloStore Modifier and Type Method Description org.apache.accumulo.core.client.IteratorSetting
AbstractCoreKeyIteratorSettingsFactory. getAggregatorIteratorSetting(AccumuloStore store)
org.apache.accumulo.core.client.IteratorSetting
AbstractCoreKeyIteratorSettingsFactory. getElementPostAggregationFilterIteratorSetting(View view, AccumuloStore store)
org.apache.accumulo.core.client.IteratorSetting
AbstractCoreKeyIteratorSettingsFactory. getElementPreAggregationFilterIteratorSetting(View view, AccumuloStore store)
org.apache.accumulo.core.client.IteratorSetting
AbstractCoreKeyIteratorSettingsFactory. getIteratorSetting(AccumuloStore store, String iteratorName)
org.apache.accumulo.core.client.IteratorSetting
AbstractCoreKeyIteratorSettingsFactory. getQueryTimeAggregatorIteratorSetting(View view, AccumuloStore store)
org.apache.accumulo.core.client.IteratorSetting
AbstractCoreKeyIteratorSettingsFactory. getRowIDAggregatorIteratorSetting(AccumuloStore store, String columnFamily)
org.apache.accumulo.core.client.IteratorSetting
AbstractCoreKeyIteratorSettingsFactory. getValidatorIteratorSetting(AccumuloStore store)
boolean
AbstractCoreKeyIteratorSettingsFactory. queryTimeAggregatorRequired(View view, AccumuloStore store)
-
Uses of AccumuloStore in uk.gov.gchq.gaffer.accumulostore.operation.handler
Methods in uk.gov.gchq.gaffer.accumulostore.operation.handler with parameters of type AccumuloStore Modifier and Type Method Description Iterable<? extends EntityId>
GetAdjacentIdsHandler. doOperation(GetAdjacentIds op, User user, AccumuloStore store)
Iterable<? extends Element>
GetAllElementsHandler. doOperation(GetAllElements operation, User user, AccumuloStore store)
Iterable<? extends Element>
GetElementsBetweenSetsHandler. doOperation(GetElementsBetweenSets operation, User user, AccumuloStore store)
Deprecated.Iterable<? extends Element>
GetElementsBetweenSetsPairsHandler. doOperation(GetElementsBetweenSetsPairs operation, User user, AccumuloStore store)
Iterable<? extends Element>
GetElementsHandler. doOperation(GetElements operation, User user, AccumuloStore store)
Iterable<? extends Element>
GetElementsInRangesHandler. doOperation(GetElementsInRanges operation, User user, AccumuloStore store)
Iterable<? extends Element>
GetElementsWithinSetHandler. doOperation(GetElementsWithinSet operation, User user, AccumuloStore store)
Iterable<? extends Element>
SummariseGroupOverRangesHandler. doOperation(SummariseGroupOverRanges operation, User user, AccumuloStore store)
-
Uses of AccumuloStore in uk.gov.gchq.gaffer.accumulostore.operation.hdfs.handler
Methods in uk.gov.gchq.gaffer.accumulostore.operation.hdfs.handler with parameters of type AccumuloStore Modifier and Type Method Description void
AddElementsFromHdfsHandler. doOperation(AddElementsFromHdfs operation, Context context, AccumuloStore store)
void
ImportAccumuloKeyValueFilesHandler. doOperation(ImportAccumuloKeyValueFiles operation, AccumuloStore store)
-
Uses of AccumuloStore in uk.gov.gchq.gaffer.accumulostore.operation.hdfs.handler.job.tool
Constructors in uk.gov.gchq.gaffer.accumulostore.operation.hdfs.handler.job.tool with parameters of type AccumuloStore Constructor Description ImportElementsToAccumuloTool(String inputPath, String failurePath, AccumuloStore store)
ImportElementsToAccumuloTool(String inputPath, String failurePath, AccumuloStore store, Map<String,String> options)
-
Uses of AccumuloStore in uk.gov.gchq.gaffer.accumulostore.retriever
Constructors in uk.gov.gchq.gaffer.accumulostore.retriever with parameters of type AccumuloStore Constructor Description AccumuloSetRetriever(AccumuloStore store, OP operation, User user)
AccumuloSetRetriever(AccumuloStore store, OP operation, User user, boolean readEntriesIntoMemory)
AccumuloSetRetriever(AccumuloStore store, OP operation, User user, boolean readEntriesIntoMemory, org.apache.accumulo.core.client.IteratorSetting... iteratorSettings)
AccumuloSetRetriever(AccumuloStore store, OP operation, User user, org.apache.accumulo.core.client.IteratorSetting... iteratorSettings)
-
Uses of AccumuloStore in uk.gov.gchq.gaffer.accumulostore.retriever.impl
Constructors in uk.gov.gchq.gaffer.accumulostore.retriever.impl with parameters of type AccumuloStore Constructor Description AccumuloAdjacentIdRetriever(AccumuloStore store, GetAdjacentIds operation, User user)
AccumuloAllElementsRetriever(AccumuloStore store, GetAllElements operation, User user)
AccumuloElementsRetriever(AccumuloStore store, GetElements operation, User user)
AccumuloIDBetweenSetsRetriever(AccumuloStore store, GetElementsBetweenSets operation, User user, boolean readEntriesIntoMemory, org.apache.accumulo.core.client.IteratorSetting... iteratorSettings)
AccumuloIDBetweenSetsRetriever(AccumuloStore store, GetElementsBetweenSets operation, User user, org.apache.accumulo.core.client.IteratorSetting... iteratorSettings)
AccumuloIDWithinSetRetriever(AccumuloStore store, GetElementsWithinSet operation, User user, boolean readEntriesIntoMemory, org.apache.accumulo.core.client.IteratorSetting... iteratorSettings)
AccumuloIDWithinSetRetriever(AccumuloStore store, GetElementsWithinSet operation, User user, org.apache.accumulo.core.client.IteratorSetting... iteratorSettings)
AccumuloRangeIDRetriever(AccumuloStore store, OP operation, User user)
AccumuloRangeIDRetriever(AccumuloStore store, OP operation, User user, org.apache.accumulo.core.client.IteratorSetting... iteratorSettings)
Use of the varargs parameter here will mean the usual default iterators wont be applied, (Edge Direction,Edge/Entity TypeDefinition and View Filtering) To apply them pass them directly to the varargs via calling your keyPackage.getIteratorFactory() and either getElementFilterIteratorSetting and/Or getEdgeEntityDirectionFilterIteratorSettingAccumuloSingleIDRetriever(AccumuloStore store, OP operation, User user)
AccumuloSingleIDRetriever(AccumuloStore store, OP operation, User user, boolean includeMatchedVertex, org.apache.accumulo.core.client.IteratorSetting... iteratorSettings)
Use of the varargs parameter here will mean the usual default iterators wont be applied, (Edge Direction,Edge/Entity TypeDefinition and View Filtering) To apply them pass them directly to the varargs via calling your keyPackage.getIteratorFactory() and either getElementFilterIteratorSetting and/Or getEdgeEntityDirectionFilterIteratorSettingAccumuloSingleIDRetriever(AccumuloStore store, OP operation, User user, org.apache.accumulo.core.client.IteratorSetting... iteratorSettings)
-
Uses of AccumuloStore in uk.gov.gchq.gaffer.accumulostore.utils
Methods in uk.gov.gchq.gaffer.accumulostore.utils with parameters of type AccumuloStore Modifier and Type Method Description static void
AddUpdateTableIterator. addIterator(AccumuloStore store, String iteratorName)
This should be used if a gaffer version upgrade causes the aggregator iterator to be removed from a tablestatic void
AddUpdateTableIterator. addIterator(AccumuloStore store, org.apache.accumulo.core.client.IteratorSetting iteratorSetting)
This method can be used to attach an iterator to the table in use by the store instance.static org.apache.accumulo.core.client.BatchWriter
TableUtils. createBatchWriter(AccumuloStore store)
Creates aBatchWriter
static void
TableUtils. createTable(AccumuloStore store)
Creates a table for Gaffer data and enables the correct Bloom filter; removes the versioning iterator and adds an aggregator Iterator theAgeOffFilter
for the specified time period.static void
TableUtils. ensureTableExists(AccumuloStore store)
Ensures that the table exists, otherwise it creates it and sets it up to receive Gaffer datastatic void
AddUpdateTableIterator. removeIterator(AccumuloStore store, String iteratorName)
This method takes a store and the name of an iterator to be removed.static void
TableUtils. setLocalityGroups(AccumuloStore store)
static void
AddUpdateTableIterator. updateIterator(AccumuloStore store, String iteratorName)
This method takes a store and the name of an iterator to be updated.static void
AddUpdateTableIterator. updateIterator(AccumuloStore store, String iteratorName, org.apache.accumulo.core.client.IteratorSetting iteratorSetting)
This method takes a store and the name of an iterator to be removed. -
Uses of AccumuloStore in uk.gov.gchq.gaffer.sparkaccumulo.operation.handler
Methods in uk.gov.gchq.gaffer.sparkaccumulo.operation.handler with parameters of type AccumuloStore Modifier and Type Method Description void
AbstractGetRDDHandler. addIterators(AccumuloStore accumuloStore, org.apache.hadoop.conf.Configuration conf, User user, OP operation)
<INPUT_OP extends Operation & GraphFilters & Input<Iterable<? extends ElementId>>>
voidAbstractGetRDDHandler. addRanges(AccumuloStore accumuloStore, org.apache.hadoop.conf.Configuration conf, INPUT_OP operation)
<INPUT_OP extends Operation & GraphFilters & Input<Iterable<? extends Pair<? extends ElementId,? extends ElementId>>>>
voidAbstractGetRDDHandler. addRangesFromPairs(AccumuloStore accumuloStore, org.apache.hadoop.conf.Configuration conf, INPUT_OP operation)
void
AbstractImportKeyValuePairRDDToAccumuloHandler. doOperation(OP operation, Context context, AccumuloStore store)
-
Uses of AccumuloStore in uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.dataframe
Methods in uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.dataframe with parameters of type AccumuloStore Modifier and Type Method Description org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>
GetDataFrameOfElementsHandler. doOperation(GetDataFrameOfElements operation, Context context, AccumuloStore store)
Constructors in uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.dataframe with parameters of type AccumuloStore Constructor Description AccumuloStoreRelation(Context context, List<Converter> converters, View view, AccumuloStore store, Map<String,String> options)
-
Uses of AccumuloStore in uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.javardd
Methods in uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.javardd with parameters of type AccumuloStore Modifier and Type Method Description void
ImportJavaRDDOfElementsHandler. doOperation(ImportJavaRDDOfElements operation, Context context, AccumuloStore store)
-
Uses of AccumuloStore in uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.scalardd
Methods in uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.scalardd with parameters of type AccumuloStore Modifier and Type Method Description void
ImportRDDOfElementsHandler. doOperation(ImportRDDOfElements operation, Context context, AccumuloStore store)
-
Uses of AccumuloStore in uk.gov.gchq.gaffer.sparkaccumulo.operation.utils
Methods in uk.gov.gchq.gaffer.sparkaccumulo.operation.utils with parameters of type AccumuloStore Modifier and Type Method Description static String[]
AccumuloKeyRangePartitioner. getSplits(AccumuloStore store)
Constructors in uk.gov.gchq.gaffer.sparkaccumulo.operation.utils with parameters of type AccumuloStore Constructor Description AccumuloKeyRangePartitioner(AccumuloStore store)
-