Package org.aktin.broker.db

Class AggregatorImpl

java.lang.Object

org.aktin.broker.db.AggregatorImpl

All Implemented Interfaces:

AggregatorBackend, Aggregator

@Singleton
public class AggregatorImpl
extends Object
implements AggregatorBackend

Constructor Summary

Constructors

Constructor	Description
AggregatorImpl()
AggregatorImpl(DataSource ds, Path dataDir)

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.
String[]	getDistinctResultTypes(int requestId)
PathDataSource	getResult(int requestId, int nodeId)
boolean	isRequestWritable(int requestId, int nodeId)
List<ResultInfo>	listResults(int requestId)
void	setBrokerDB(DataSource ds)
void	setDataDirectory(Path dataDir)

Methods inherited from class java.lang.Object

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

Constructor Details

AggregatorImpl

public AggregatorImpl()
               throws IOException

Throws:

IOException

AggregatorImpl

public AggregatorImpl(DataSource ds,
 Path dataDir)
               throws IOException

Throws:

IOException

Method Details

setDataDirectory

public void setDataDirectory(Path dataDir)
                      throws IOException

Throws:

IOException

setBrokerDB

public void setBrokerDB(DataSource ds)

Specified by:

setBrokerDB in interface AggregatorBackend

clearDataDirectory

public void clearDataDirectory()
                        throws IOException

Description copied from interface: AggregatorBackend

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

Specified by:

clearDataDirectory in interface AggregatorBackend

Throws:

IOException - IO error

listResults

public List<ResultInfo> listResults(int requestId)
                             throws SQLException

Specified by:

listResults in interface Aggregator

Throws:

SQLException

getResult

public PathDataSource getResult(int requestId,
 int nodeId)
                         throws SQLException

Specified by:

getResult in interface Aggregator

Throws:

SQLException

addOrReplaceResult

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

Specified by:

addOrReplaceResult in interface AggregatorBackend

Throws:

SQLException

getDistinctResultTypes

public String[] getDistinctResultTypes(int requestId)
                                throws SQLException

Specified by:

getDistinctResultTypes in interface Aggregator

Throws:

SQLException

isRequestWritable

public boolean isRequestWritable(int requestId,
 int nodeId)

Specified by:

isRequestWritable in interface AggregatorBackend