ome.services.blitz.impl

Class TableCloserI

java.lang.Object

ome.services.blitz.impl.AbstractAmdServant

ome.services.blitz.impl.AbstractCloseableAmdServant

ome.services.blitz.impl.TableCloserI

All Implemented Interfaces:

_ServiceInterfaceOperations, _StatefulServiceInterfaceOperations, _TableOperations, CloseableServant, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

public class TableCloserI
extends AbstractCloseableAmdServant
implements _StatefulServiceInterfaceOperations, _TableOperations

Blitz-specific wrapper for table proxies to facilitate the cleanup of files on session exit.

Field Summary

Fields inherited from class ome.services.blitz.impl.AbstractAmdServant

be, ctx, holder, invoker, log, service

Constructor Summary

Constructors

Constructor and Description
TableCloserI(ServiceFactoryI sf, TablePrx tablePrx, Ice.Identity id)

Method Summary

Modifier and Type	Method and Description
int	addColumn(Column col, Ice.Current __current) Adds a column and returns the position index of the new column.
void	addData(Column[] cols, Ice.Current __current)
void	delete(Ice.Current __current)
java.util.Map<java.lang.String,RType>	getAllMetadata(Ice.Current __current)
Column[]	getHeaders(Ice.Current __current) Returns empty columns.
RType	getMetadata(java.lang.String key, Ice.Current __current)
long	getNumberOfRows(Ice.Current __current)
OriginalFile	getOriginalFile(Ice.Current __current)
TablePrx	getProxy()
long[]	getWhereList(java.lang.String condition, java.util.Map<java.lang.String,RType> variables, long start, long stop, long step, Ice.Current __current) http://www.pytables.org/docs/manual/apb.html Leave all three of start, stop, step to 0 to disable.
void	initialize(Column[] cols, Ice.Current __current) Initializes the structure based on
protected void	postClose(Ice.Current current) Should not throw any exceptions which should be detected by clients since it is called in a finally block after the client thread has been released.
protected void	preClose(Ice.Current current)
Data	read(long[] colNumbers, long start, long stop, Ice.Current __current) http://www.pytables.org/docs/manual/ch04.html#Table.read
Data	readCoordinates(long[] rowNumbers, Ice.Current __current) Read the given rows of data.
void	setAllMetadata(java.util.Map<java.lang.String,RType> dict, Ice.Current __current)
void	setMetadata(java.lang.String key, RType value, Ice.Current __current)
Data	slice(long[] colNumbers, long[] rowNumbers, Ice.Current __current) Simple slice method which will return only the given columns and rows in the order supplied.
void	update(Data modifiedData, Ice.Current __current) Allows the user to modify a Data instance passed back from a query method and have the values modified.

Methods inherited from class ome.services.blitz.impl.AbstractCloseableAmdServant

close_async, close

Methods inherited from class ome.services.blitz.impl.AbstractAmdServant

activate_async, applyHardWiredInterceptors, callInvokerOnMappedArgs, callInvokerOnRawArgs, executorWorkCall, getCurrentEventContext_async, onSetOmeroContext, passivate_async, runnableCall, safeRunnableCall, setApplicationContext, setHolder

Methods inherited from class java.lang.Object

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

Methods inherited from interface omero.api._StatefulServiceInterfaceOperations

activate_async, close_async, getCurrentEventContext_async, passivate_async

Methods inherited from interface omero.grid._TableOperations

close

Constructor Detail

TableCloserI

public TableCloserI(ServiceFactoryI sf,
                    TablePrx tablePrx,
                    Ice.Identity id)
             throws ServerError

Throws:

ServerError

Method Detail

getProxy

public TablePrx getProxy()

preClose

protected void preClose(Ice.Current current)
                 throws java.lang.Throwable

Specified by:

preClose in class AbstractCloseableAmdServant

Throws:

java.lang.Throwable

postClose

protected void postClose(Ice.Current current)

Description copied from class: AbstractCloseableAmdServant

Should not throw any exceptions which should be detected by clients since it is called in a finally block after the client thread has been released.

Specified by:

postClose in class AbstractCloseableAmdServant

getOriginalFile

public OriginalFile getOriginalFile(Ice.Current __current)
                             throws ServerError

Specified by:

getOriginalFile in interface _TableOperations

Throws:

ServerError

getHeaders

public Column[] getHeaders(Ice.Current __current)
                    throws ServerError

Description copied from interface: _TableOperations

Returns empty columns.

Specified by:

getHeaders in interface _TableOperations

Parameters:

__current - The Current object for the invocation.

Throws:

ServerError

getNumberOfRows

public long getNumberOfRows(Ice.Current __current)
                     throws ServerError

Specified by:

getNumberOfRows in interface _TableOperations

Throws:

ServerError

getWhereList

public long[] getWhereList(java.lang.String condition,
                           java.util.Map<java.lang.String,RType> variables,
                           long start,
                           long stop,
                           long step,
                           Ice.Current __current)
                    throws ServerError

Description copied from interface: _TableOperations

http://www.pytables.org/docs/manual/apb.html Leave all three of start, stop, step to 0 to disable. TODO:Test effect of returning a billion rows matching getWhereList()

Specified by:

getWhereList in interface _TableOperations

__current - The Current object for the invocation.

Throws:

ServerError

readCoordinates

public Data readCoordinates(long[] rowNumbers,
                            Ice.Current __current)
                     throws ServerError

Description copied from interface: _TableOperations

Read the given rows of data.

Specified by:

readCoordinates in interface _TableOperations

Parameters:

rowNumbers - must contain at least one element or an ApiUsageException will be thrown.

__current - The Current object for the invocation.

Throws:

ServerError

read

public Data read(long[] colNumbers,
                 long start,
                 long stop,
                 Ice.Current __current)
          throws ServerError

Description copied from interface: _TableOperations

http://www.pytables.org/docs/manual/ch04.html#Table.read

Specified by:

read in interface _TableOperations

__current - The Current object for the invocation.

Throws:

ServerError

slice

public Data slice(long[] colNumbers,
                  long[] rowNumbers,
                  Ice.Current __current)
           throws ServerError

Description copied from interface: _TableOperations

Simple slice method which will return only the given columns and rows in the order supplied. If colNumbers or rowNumbers is empty (or None), then all values will be returned.

Python examples:

 data = table.slice(None, None)
 assert len(data.rowNumbers) == table.getNumberOfRows()

 data = table.slice(None, \[3,2,1])
 assert data.rowNumbers == \[3,2,1]
 

Specified by:

slice in interface _TableOperations

__current - The Current object for the invocation.

Throws:

ServerError

addData

public void addData(Column[] cols,
                    Ice.Current __current)
             throws ServerError

Specified by:

addData in interface _TableOperations

Throws:

ServerError

update

public void update(Data modifiedData,
                   Ice.Current __current)
            throws ServerError

Description copied from interface: _TableOperations

Allows the user to modify a Data instance passed back from a query method and have the values modified. It is critical that the Data.lastModification and the Data.rowNumbers fields are properly set. An exception will be thrown if the data has since been modified.

Specified by:

update in interface _TableOperations

__current - The Current object for the invocation.

Throws:

ServerError

getAllMetadata

public java.util.Map<java.lang.String,RType> getAllMetadata(Ice.Current __current)
                                                     throws ServerError

Specified by:

getAllMetadata in interface _TableOperations

Throws:

ServerError

getMetadata

public RType getMetadata(java.lang.String key,
                         Ice.Current __current)
                  throws ServerError

Specified by:

getMetadata in interface _TableOperations

Throws:

ServerError

setAllMetadata

public void setAllMetadata(java.util.Map<java.lang.String,RType> dict,
                           Ice.Current __current)
                    throws ServerError

Specified by:

setAllMetadata in interface _TableOperations

Throws:

ServerError

setMetadata

public void setMetadata(java.lang.String key,
                        RType value,
                        Ice.Current __current)
                 throws ServerError

Specified by:

setMetadata in interface _TableOperations

Throws:

ServerError

initialize

public void initialize(Column[] cols,
                       Ice.Current __current)
                throws ServerError

Description copied from interface: _TableOperations

Initializes the structure based on

Specified by:

initialize in interface _TableOperations

__current - The Current object for the invocation.

Throws:

ServerError

addColumn

public int addColumn(Column col,
                     Ice.Current __current)
              throws ServerError

Description copied from interface: _TableOperations

Adds a column and returns the position index of the new column.

Specified by:

addColumn in interface _TableOperations

__current - The Current object for the invocation.

Throws:

ServerError

delete

public void delete(Ice.Current __current)
            throws ServerError

Specified by:

delete in interface _TableOperations

Throws:

ServerError