Uses of Class
uk.gov.gchq.gaffer.store.StoreException
-
Packages that use StoreException Package Description uk.gov.gchq.gaffer.accumulostore uk.gov.gchq.gaffer.accumulostore.operation.hdfs.handler.job.factory uk.gov.gchq.gaffer.accumulostore.retriever uk.gov.gchq.gaffer.accumulostore.retriever.impl uk.gov.gchq.gaffer.accumulostore.utils uk.gov.gchq.gaffer.federated.simple uk.gov.gchq.gaffer.federatedstore uk.gov.gchq.gaffer.hdfs.operation.handler.job.factory Factory classes for preparing Hadoop MapReduce jobs.uk.gov.gchq.gaffer.mapstore The Gaffer MapStore implementation.uk.gov.gchq.gaffer.proxystore The Gaffer ProxyStore implementation.uk.gov.gchq.gaffer.store Core classes for the Gaffer store interface. -
-
Uses of StoreException in uk.gov.gchq.gaffer.accumulostore
Methods in uk.gov.gchq.gaffer.accumulostore that throw StoreException Modifier and Type Method Description void
AccumuloStore. addElements(Iterable<? extends Element> elements)
Method to addElement
s into Accumulo.void
AccumuloStore. deleteElements(Iterable<? extends Element> elements)
Method to deleteElement
s from Accumulo.org.apache.accumulo.core.client.Connector
AccumuloStore. getConnection()
Creates an AccumuloConnector
using the properties found in properties file associated with the AccumuloStore.List<String>
AccumuloStore. getTabletServers()
Gets the TabletServers.void
AccumuloStore. initialise(String graphId, Schema schema, StoreProperties properties)
void
AccumuloStore. preInitialise(String graphId, Schema schema, StoreProperties properties)
Performs general initialisation without creating the table.void
SingleUseAccumuloStore. preInitialise(String graphId, Schema schema, StoreProperties properties)
void
AccumuloStore. updateConfiguration(org.apache.hadoop.conf.Configuration conf, GraphFilters graphFilters, User user)
Updates a HadoopConfiguration
with information needed to connect to the Accumulo store. -
Uses of StoreException in uk.gov.gchq.gaffer.accumulostore.operation.hdfs.handler.job.factory
Methods in uk.gov.gchq.gaffer.accumulostore.operation.hdfs.handler.job.factory that throw StoreException Modifier and Type Method Description void
AccumuloAddElementsFromHdfsJobFactory. prepareStore(Store store)
-
Uses of StoreException in uk.gov.gchq.gaffer.accumulostore.retriever
Constructors in uk.gov.gchq.gaffer.accumulostore.retriever that throw StoreException 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 StoreException in uk.gov.gchq.gaffer.accumulostore.retriever.impl
Constructors in uk.gov.gchq.gaffer.accumulostore.retriever.impl that throw StoreException 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 StoreException in uk.gov.gchq.gaffer.accumulostore.utils
Methods in uk.gov.gchq.gaffer.accumulostore.utils that throw StoreException 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 org.apache.accumulo.core.client.Connector
TableUtils. getConnector(String instanceName, String zookeepers, String userName, String password)
Creates a connection (using password-based authentication) to an accumulo instance using the provided parametersstatic org.apache.accumulo.core.client.Connector
TableUtils. getConnector(AccumuloProperties accumuloProperties)
Creates a connection to an accumulo instance using parameters from the providedAccumuloProperties
.static org.apache.accumulo.core.client.Connector
TableUtils. getConnectorKerberos(String instanceName, String zookeepers, String principal, String keytabPath)
Creates a connection (using Kerberos authentication) to an accumulo instance using the provided parametersstatic org.apache.accumulo.core.security.Authorizations
TableUtils. getCurrentAuthorizations(org.apache.accumulo.core.client.Connector connection)
Returns theAuthorizations
of the current userstatic void
AddUpdateTableIterator. removeIterator(AccumuloStore store, String iteratorName)
This method takes a store and the name of an iterator to be removed.static void
TableUtils. renameTable(AccumuloProperties accumuloProperties, String currentGraphId, String newGraphId)
Renames the Accumulo table (if it exists) that is associated with the provided parameters.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 StoreException in uk.gov.gchq.gaffer.federated.simple
Methods in uk.gov.gchq.gaffer.federated.simple that throw StoreException Modifier and Type Method Description void
FederatedStore. changeGraphId(String graphToUpdateId, String newGraphId)
Change the graph's ID for the specified graph.void
FederatedStore. initialise(String graphId, Schema unused, StoreProperties properties)
-
Uses of StoreException in uk.gov.gchq.gaffer.federatedstore
Methods in uk.gov.gchq.gaffer.federatedstore that throw StoreException Modifier and Type Method Description void
FederatedStore. initialise(String graphId, Schema unused, StoreProperties properties)
Initialise this FederatedStore with any sub-graphs defined within the properties. -
Uses of StoreException in uk.gov.gchq.gaffer.hdfs.operation.handler.job.factory
Methods in uk.gov.gchq.gaffer.hdfs.operation.handler.job.factory that throw StoreException Modifier and Type Method Description void
AddElementsFromHdfsJobFactory. prepareStore(Store store)
Prepares the store for the add from hdfs. -
Uses of StoreException in uk.gov.gchq.gaffer.mapstore
Methods in uk.gov.gchq.gaffer.mapstore that throw StoreException Modifier and Type Method Description void
MapStore. initialise(String graphId, Schema schema, StoreProperties properties)
void
SingleUseMapStore. initialise(String graphId, Schema schema, StoreProperties properties)
-
Uses of StoreException in uk.gov.gchq.gaffer.proxystore
Methods in uk.gov.gchq.gaffer.proxystore that throw StoreException Modifier and Type Method Description void
ProxyStore. initialise(String graphId, Schema unusedSchema, StoreProperties properties)
-
Uses of StoreException in uk.gov.gchq.gaffer.store
Methods in uk.gov.gchq.gaffer.store that throw StoreException Modifier and Type Method Description void
Store. initialise(String graphId, Schema schema, StoreProperties properties)
-