Package org.aktin.broker.db

Interface AggregatorBackend

All Superinterfaces:

Aggregator

All Known Implementing Classes:

AggregatorImpl

public interface AggregatorBackend
extends Aggregator

Method Summary

Modifier and Type	Method	Description
void	addOrReplaceResult(int requestId, int nodeId, javax.ws.rs.core.MediaType mediaType, InputStream content)
void	clearDataDirectory()	Delete all files in the data directory.
boolean	isRequestWritable(int requestId, int nodeId)
void	setBrokerDB(DataSource ds)

Methods inherited from interface org.aktin.broker.server.Aggregator

getDistinctResultTypes, getResult, listResults

Method Details

setBrokerDB

void setBrokerDB(DataSource ds)

clearDataDirectory

void clearDataDirectory()
                 throws IOException

Delete all files in the data directory. This should be used only for testing.

Throws:

IOException - IO error

addOrReplaceResult

void addOrReplaceResult(int requestId,
 int nodeId,
 javax.ws.rs.core.MediaType mediaType,
 InputStream content)
                 throws SQLException

Throws:

SQLException

isRequestWritable

boolean isRequestWritable(int requestId,
 int nodeId)