org.gcube.contentmanagement.timeseriesservice.impl.timeseries.state

Class TimeSeriesResource

java.lang.Object

org.gcube.common.core.utils.handlers.GCUBEServiceClientImpl

org.gcube.common.core.state.GCUBEStatefulResource<org.gcube.common.core.state.GCUBEWSResourceKey>

org.gcube.common.core.state.GCUBEWSResource

org.gcube.contentmanagement.timeseriesservice.impl.timeseries.state.TimeSeriesResource

All Implemented Interfaces:

org.gcube.common.core.utils.handlers.GCUBEServiceClient, org.globus.wsrf.PersistenceCallback, org.globus.wsrf.Resource, org.globus.wsrf.ResourceLifetime, org.globus.wsrf.ResourceProperties, org.globus.wsrf.TopicListAccessor

public class TimeSeriesResource
extends org.gcube.common.core.state.GCUBEWSResource

Nested Class Summary

Nested classes/interfaces inherited from class org.gcube.common.core.state.GCUBEStatefulResource

org.gcube.common.core.state.GCUBEStatefulResource.LOCK, org.gcube.common.core.state.GCUBEStatefulResource.TaskContext

Field Summary

Fields

Modifier and Type	Field and Description
org.gcube.contentmanagement.timeseriesservice.stubs.types.ColumnDefinition[]	columnsDefinition
long	count
org.gcube.contentmanagement.timeseriesservice.stubs.types.Status	initializationState
String	relatedCurationId
protected static String	RP_ID
protected static String	RP_TITLE
protected static String[]	RPNames
String[]	tableDefinition

Fields inherited from class org.gcube.common.core.state.GCUBEStatefulResource

uuidGen

Constructor Summary

Constructors

Constructor and Description
TimeSeriesResource()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	_intialize(org.gcube.contentmanagement.timeseriesservice.stubs.CreateFromTsRequest request)
protected void	_intialize(org.gcube.contentmanagement.timeseriesservice.stubs.CreateTsRequest request)
void	addOperation(Operation operation, String user)
void	discardAllOperations(String user)
void	discardOperation(String user)
String	exportAsCsv(org.gcube.contentmanagement.timeseriesservice.stubs.types.ExportRequest req)
String	getAllDataAsJSon(org.gcube.contentmanagement.timeseriesservice.stubs.types.Limit limit, org.gcube.contentmanagement.timeseriesservice.stubs.types.Order order, String user)
String	getChartData(int maxDimension, String xDimension, String yDimension, String groupDimension, String speciesColumn, String[] filters, String[] areas)
org.gcube.contentmanagement.timeseriesservice.stubs.types.ColumnDefinition	getColumnDefinitionReference(String fieldId)
org.gcube.contentmanagement.timeseriesservice.stubs.types.ColumnDefinition[]	getColumnsDefinition()
protected long	getCount()
org.gcube.contentmanagement.timeseriesservice.stubs.types.ColumnDefinition[]	getCurrentColumnsDefinition(String user)
Operation	getCurrentOperation(String user)
Hashtable<String,LinkedList<Operation>>	getCurrentsOperations()
String[]	getDistinctValues(String fieldId, int start, int offset)
long	getElementCount(String user)
String	getFishingMontlyEffort(org.gcube.contentmanagement.timeseriesservice.stubs.GetFishingMontlyEffortRequest request)
TSHistory	getHistory()
String	getId() Returns the id.
org.gcube.contentmanagement.timeseriesservice.stubs.types.Status	getInitializationState()
org.gcube.contentmanagement.timeseriesservice.stubs.types.OperationType[]	getOperationList(String user)
String[]	getPropertyNames()
String	getRelatedCurationId()
org.gcube.common.dbinterface.tables.SimpleTable	getTable()
String	getTitle()
protected void	initialise(Object... arg)
protected void	onRemove()
void	performOperation(String user, Class<? extends Operation> operationClass, Object... parameters)
void	publishAtVOLevel(org.gcube.common.core.scope.GCUBEScope scope)
void	remove()
void	setColumnsDefinition(org.gcube.contentmanagement.timeseriesservice.stubs.types.ColumnDefinition[] columnsDefinition)
protected void	setCount(long count)
void	setCurrentsOperations(Hashtable<String,LinkedList<Operation>> currentsOperations)
void	setHistory(TSHistory history)
void	setId(String id)
void	setInitializationState(org.gcube.contentmanagement.timeseriesservice.stubs.types.Status initializationState)
void	setInitializationState(String value)
void	setRelatedCurationId(String relatedCurationId)
void	setTable(org.gcube.common.dbinterface.tables.SimpleTable table)
void	setTitle(String title)
void	setTSPublished()
String	transform(org.gcube.contentmanagement.timeseries.geotools.filters.AFilter filter, String user)
org.gcube.contentmanagement.timeseriesservice.stubs.GetTransformationStatusResponse	transformationStatus(String groupName)

Methods inherited from class org.gcube.common.core.state.GCUBEWSResource

getCurrentTime, getEPR, getPorttypeContext, getProperty, getPublisher, getResourcePropertySet, getServiceContext, getTerminationTime, getTopicList, getTopicNames, initialise, initialiseContainers, inScope, load, publish, setPortTypeContext, setTerminationTime, unpublish

Methods inherited from class org.gcube.common.core.state.GCUBEStatefulResource

getID, getLock, getScheduledTasks, getScope, launchTask, setID, setPersistenceDelegate, stopTask, store

Methods inherited from class org.gcube.common.core.utils.handlers.GCUBEServiceClientImpl

getPortTypeMap, setPortTypeMap

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.globus.wsrf.PersistenceCallback

store

Field Detail

RP_ID

protected static final String RP_ID

See Also:

Constant Field Values

RP_TITLE

protected static final String RP_TITLE

See Also:

Constant Field Values

RPNames

protected static String[] RPNames

count

public long count

initializationState

public org.gcube.contentmanagement.timeseriesservice.stubs.types.Status initializationState

relatedCurationId

public String relatedCurationId

columnsDefinition

public org.gcube.contentmanagement.timeseriesservice.stubs.types.ColumnDefinition[] columnsDefinition

tableDefinition

public String[] tableDefinition

Constructor Detail

TimeSeriesResource

public TimeSeriesResource()

Method Detail

getPropertyNames

public String[] getPropertyNames()

Overrides:

getPropertyNames in class org.gcube.common.core.state.GCUBEWSResource

initialise

protected void initialise(Object... arg)
                   throws Exception

Specified by:

initialise in class org.gcube.common.core.state.GCUBEWSResource

Throws:

Exception

getCount

protected long getCount()

Returns:

setCount

protected void setCount(long count)

Parameters:

count -

_intialize

protected void _intialize(org.gcube.contentmanagement.timeseriesservice.stubs.CreateTsRequest request)
                   throws Exception

Parameters:

request -

Throws:

Exception

_intialize

protected void _intialize(org.gcube.contentmanagement.timeseriesservice.stubs.CreateFromTsRequest request)
                   throws Exception

Parameters:

request -

Throws:

Exception

remove

public void remove()

onRemove

protected void onRemove()
                 throws org.globus.wsrf.ResourceException

Overrides:

onRemove in class org.gcube.common.core.state.GCUBEStatefulResource<org.gcube.common.core.state.GCUBEWSResourceKey>

Throws:

org.globus.wsrf.ResourceException

getId

public String getId()
             throws org.globus.wsrf.ResourceException

Returns the id.

Returns:

the id.

Throws:

org.globus.wsrf.ResourceException

setId

public void setId(String id)
           throws org.globus.wsrf.ResourceException

Parameters:

id -

Throws:

org.globus.wsrf.ResourceException

getTitle

public String getTitle()
                throws org.globus.wsrf.ResourceException

Returns:

Throws:

org.globus.wsrf.ResourceException

setTitle

public void setTitle(String title)
              throws org.globus.wsrf.ResourceException

Parameters:

title -

Throws:

org.globus.wsrf.ResourceException

getTable

public org.gcube.common.dbinterface.tables.SimpleTable getTable()
                                                         throws Exception

Returns:

Throws:

Exception

getInitializationState

public org.gcube.contentmanagement.timeseriesservice.stubs.types.Status getInitializationState()

Returns:

setInitializationState

public void setInitializationState(org.gcube.contentmanagement.timeseriesservice.stubs.types.Status initializationState)

Parameters:

initializationState -

getRelatedCurationId

public String getRelatedCurationId()

Returns:

setRelatedCurationId

public void setRelatedCurationId(String relatedCurationId)

Parameters:

relatedCurationId -

getColumnsDefinition

public org.gcube.contentmanagement.timeseriesservice.stubs.types.ColumnDefinition[] getColumnsDefinition()

Returns:

getCurrentColumnsDefinition

public org.gcube.contentmanagement.timeseriesservice.stubs.types.ColumnDefinition[] getCurrentColumnsDefinition(String user)

Parameters:

user -

Returns:

setColumnsDefinition

public void setColumnsDefinition(org.gcube.contentmanagement.timeseriesservice.stubs.types.ColumnDefinition[] columnsDefinition)

Parameters:

columnsDefinition -

setInitializationState

public void setInitializationState(String value)

Parameters:

value -

getAllDataAsJSon

public String getAllDataAsJSon(org.gcube.contentmanagement.timeseriesservice.stubs.types.Limit limit,
                      org.gcube.contentmanagement.timeseriesservice.stubs.types.Order order,
                      String user)
                        throws Exception

Parameters:

limit -

order -

user -

Returns:

Throws:

Exception

getElementCount

public long getElementCount(String user)
                     throws Exception

Parameters:

user -

Returns:

Throws:

Exception

getColumnDefinitionReference

public org.gcube.contentmanagement.timeseriesservice.stubs.types.ColumnDefinition getColumnDefinitionReference(String fieldId)
                                                                                                        throws Exception

Parameters:

fieldId -

Returns:

Throws:

Exception

getCurrentOperation

public Operation getCurrentOperation(String user)

Parameters:

user -

Returns:

getOperationList

public org.gcube.contentmanagement.timeseriesservice.stubs.types.OperationType[] getOperationList(String user)

Parameters:

user -

Returns:

addOperation

public void addOperation(Operation operation,
                String user)

Parameters:

currentOperation -

user -

performOperation

public void performOperation(String user,
                    Class<? extends Operation> operationClass,
                    Object... parameters)
                      throws Exception

Parameters:

user -

operationClass -

parameters -

Throws:

Exception

discardOperation

public void discardOperation(String user)
                      throws Exception

Parameters:

user -

Throws:

Exception

discardAllOperations

public void discardAllOperations(String user)
                          throws Exception

Parameters:

user -

Throws:

Exception

getCurrentsOperations

public Hashtable<String,LinkedList<Operation>> getCurrentsOperations()

Returns:

setCurrentsOperations

public void setCurrentsOperations(Hashtable<String,LinkedList<Operation>> currentsOperations)

Parameters:

currentsOperations -

exportAsCsv

public String exportAsCsv(org.gcube.contentmanagement.timeseriesservice.stubs.types.ExportRequest req)
                   throws Exception

Parameters:

req -

Returns:

Throws:

Exception

getHistory

public TSHistory getHistory()

setHistory

public void setHistory(TSHistory history)

setTable

public void setTable(org.gcube.common.dbinterface.tables.SimpleTable table)

setTSPublished

public void setTSPublished()
                    throws Exception

Throws:

Exception

publishAtVOLevel

public void publishAtVOLevel(org.gcube.common.core.scope.GCUBEScope scope)
                      throws Exception

Throws:

Exception

getDistinctValues

public String[] getDistinctValues(String fieldId,
                         int start,
                         int offset)
                           throws Exception

Throws:

Exception

getChartData

public String getChartData(int maxDimension,
                  String xDimension,
                  String yDimension,
                  String groupDimension,
                  String speciesColumn,
                  String[] filters,
                  String[] areas)
                    throws Exception

Throws:

Exception

transform

public String transform(org.gcube.contentmanagement.timeseries.geotools.filters.AFilter filter,
               String user)
                 throws Exception

Throws:

Exception

transformationStatus

public org.gcube.contentmanagement.timeseriesservice.stubs.GetTransformationStatusResponse transformationStatus(String groupName)
                                                                                                         throws Exception

Throws:

Exception

getFishingMontlyEffort

public String getFishingMontlyEffort(org.gcube.contentmanagement.timeseriesservice.stubs.GetFishingMontlyEffortRequest request)
                              throws Exception

Throws:

Exception