|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface PrimaryProducer
A client uses a PrimaryProducer to publish information into R-GMA.
Method Summary | |
---|---|
void |
declareTable(java.lang.String tableName,
java.lang.String predicate,
TimeInterval historyRetentionPeriod,
TimeInterval latestRetentionPeriod)
Declares a table, specifying the retention period for history and latest tuples. |
TimeInterval |
getHistoryRetentionPeriod(java.lang.String tableName)
Gets the retention period that is applied to history tuples for the specified table. |
TimeInterval |
getLatestRetentionPeriod(java.lang.String tableName)
Gets the retention period that is applied to latest tuples for the specified table. |
void |
insert(java.lang.String insertStatement)
Publishes data by inserting a tuple into a table, both specified by the SQL INSERT statement. |
void |
insert(java.lang.String insertStatement,
TimeInterval latestRetentionPeriod)
Publishes data by inserting a tuple into a table, both specified by the SQL INSERT statement. |
void |
insertList(StringList insertStatements)
Publishes using a list of SQL INSERT statements. |
void |
insertList(StringList insertStatements,
TimeInterval latestRetentionPeriod)
Publishes using a list of SQL INSERT statements. |
Methods inherited from interface org.glite.rgma.Resource |
---|
close, destroy, getResourceEndpoint, getTerminationInterval, setTerminationInterval, showSignOfLife |
Method Detail |
---|
TimeInterval getHistoryRetentionPeriod(java.lang.String tableName) throws RemoteException, UnknownResourceException, RGMAException
tableName
- Name of the table
RemoteException
- If the service could not be contacted.
UnknownResourceException
- If the resource could not be found.
RGMAException
- If the table has not been declared.declareTable(java.lang.String, java.lang.String, org.glite.rgma.TimeInterval, org.glite.rgma.TimeInterval)
TimeInterval getLatestRetentionPeriod(java.lang.String tableName) throws RemoteException, UnknownResourceException, RGMAException
tableName
- Name of the table
RemoteException
- If the service could not be contacted.
UnknownResourceException
- If the resource could not be found.
RGMAException
- If the table has not been declared.declareTable(java.lang.String, java.lang.String, org.glite.rgma.TimeInterval, org.glite.rgma.TimeInterval)
void declareTable(java.lang.String tableName, java.lang.String predicate, TimeInterval historyRetentionPeriod, TimeInterval latestRetentionPeriod) throws RemoteException, UnknownResourceException, RGMAException
tableName
- The name of the table to declare.predicate
- An SQL WHERE clause defining the subset of a table that
this Producer will publish. To publish to the whole table, an
empty predicate can be used.historyRetentionPeriod
- The retention period for history tupleslatestRetentionPeriod
- The retention period for latest tuples
RemoteException
- If the service could not be contacted.
UnknownResourceException
- If the producer resource could not be
found
RGMAException
- If the tableName is unknown. If the predicate is
invalid. If either xxxRetentionPeriod is invalid.getLatestRetentionPeriod(java.lang.String)
,
getHistoryRetentionPeriod(java.lang.String)
void insert(java.lang.String insertStatement) throws RemoteException, UnknownResourceException, RGMAException
insertStatement
- An SQL INSERT statement providing the data to
publish and the table into which to put it.
RemoteException
- If the service could not be contacted.
UnknownResourceException
- If the producer resource could not be
found
RGMAException
- If the table in the insert has not been declared.
If the inserted tuple does not match its table's declared
predicateinsertList(org.glite.rgma.StringList)
,
insert(String,TimeInterval)
void insert(java.lang.String insertStatement, TimeInterval latestRetentionPeriod) throws RemoteException, UnknownResourceException, RGMAException
insertStatement
- An SQL INSERT statement providing the data to
publish and the table into which to put it.latestRetentionPeriod
- Latest retention period for this tuple (overrides
LRP defined for table).
RemoteException
- If the service could not be contacted.
UnknownResourceException
- If the producer resource could not be
found
RGMAException
- If the table in the insert has not been declared.
If the inserted tuple does not match its table's declared
predicateinsertList(org.glite.rgma.StringList)
,
insert(String)
void insertList(StringList insertStatements) throws RemoteException, UnknownResourceException, RGMAException
insertStatements
- A list of SQL INSERT statements.
RemoteException
- If the service could not be contacted.
UnknownResourceException
- If the producer resource could not be
found
RGMAException
- If the table in any insert has not been declared.
If any inserted tuple does not match its table's declared
predicateinsert(java.lang.String)
void insertList(StringList insertStatements, TimeInterval latestRetentionPeriod) throws RemoteException, UnknownResourceException, RGMAException
insertStatements
- A list of SQL INSERT statements.latestRetentionPeriod
- Latest retention period for this tuple (overrides
LRP defined for table).
RemoteException
- If the service could not be contacted.
UnknownResourceException
- If the producer resource could not be
found
RGMAException
- If the table in any insert has not been declared.
If any inserted tuple does not match its table's declared
predicateinsert(java.lang.String)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |