Package uk.gov.gchq.gaffer.proxystore
Class ProxyStore
- java.lang.Object
-
- uk.gov.gchq.gaffer.store.Store
-
- uk.gov.gchq.gaffer.proxystore.ProxyStore
-
public class ProxyStore extends Store
GafferProxyStore
implementation.The ProxyStore is simply a Gaffer store which delegates all operations to a Gaffer REST API.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ProxyStore.Builder
-
Field Summary
Fields Modifier and Type Field Description static String
ERROR_FETCHING_SCHEMA_FROM_REMOTE_STORE
-
Constructor Summary
Constructors Constructor Description ProxyStore()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description JobDetail
executeJob(OperationChain<?> operationChain, Context context)
<O> O
executeOpChainViaUrl(OperationChain<O> opChain, Context context)
Schema
getOriginalSchema()
Get originalSchema
from the remote Store.ProxyProperties
getProperties()
Get this Store'sStoreProperties
.Schema
getSchema()
GetSchema
from the remote Store.Set<Class<? extends Operation>>
getSupportedOperations()
void
initialise(String graphId, Schema unusedSchema, StoreProperties properties)
boolean
isSupported(Class<? extends Operation> operationClass)
void
validateSchemas()
-
Methods inherited from class uk.gov.gchq.gaffer.store.Store
addOperationChainOptimisers, addOperationHandler, addOperationHandler, createContext, createStore, createStore, execute, execute, executeJob, executeJob, getCaches, getCreatedTime, getGraphId, getGraphLibrary, getJobTracker, getNextOperations, getOperationChainOptimisers, getOperationChainValidator, getOperationHandler, handleOperation, optimiseSchema, populateElement, runAsync, setGraphLibrary, setOriginalSchema, updateJsonSerialiser, updateJsonSerialiser
-
-
-
-
Field Detail
-
ERROR_FETCHING_SCHEMA_FROM_REMOTE_STORE
public static final String ERROR_FETCHING_SCHEMA_FROM_REMOTE_STORE
- See Also:
- Constant Field Values
-
-
Method Detail
-
initialise
public void initialise(String graphId, Schema unusedSchema, StoreProperties properties) throws StoreException
- Overrides:
initialise
in classStore
- Throws:
StoreException
-
getSupportedOperations
public Set<Class<? extends Operation>> getSupportedOperations()
- Overrides:
getSupportedOperations
in classStore
- Returns:
- a collection of all the supported
Operation
s.
-
isSupported
public boolean isSupported(Class<? extends Operation> operationClass)
- Overrides:
isSupported
in classStore
- Parameters:
operationClass
- the operation class to check- Returns:
- true if the provided operation is supported.
-
getOriginalSchema
public Schema getOriginalSchema()
Get originalSchema
from the remote Store.- Overrides:
getOriginalSchema
in classStore
- Returns:
- original
Schema
-
validateSchemas
public void validateSchemas()
- Overrides:
validateSchemas
in classStore
-
executeJob
public JobDetail executeJob(OperationChain<?> operationChain, Context context) throws OperationException
- Throws:
OperationException
-
executeOpChainViaUrl
public <O> O executeOpChainViaUrl(OperationChain<O> opChain, Context context) throws OperationException
- Throws:
OperationException
-
getProperties
public ProxyProperties getProperties()
Description copied from class:Store
Get this Store'sStoreProperties
.- Overrides:
getProperties
in classStore
- Returns:
- the instance of
StoreProperties
, this may contain details such as database connection details.
-
-