1.1.1

}
// if lesserRow is null, then there are no more rows in
any incoming results
return lesserRow;
}
public boolean getMoreResults(int nextResultSetNumber) {
return false; // only one result set
}
public void close() {
this.context = null;
}
}
ProcedureProcessorContext
ProcedureProcessorContext is a Context object passed to the ProcedureResultProcessor in its init method.
The interface has these methods:
DescriptionMethod
Get the array of incoming result sets for a given result set number,
where each array element is a result set provided by a procedure
getIncomingResultSets(int resultSetNumber)
executing on some server. The size of the array is equal to the number
of servers executing this procedure.
Get the array of incoming result sets for the out parameters provided
by the executing procedures. The size of the array is equal to the
getIncomingOutParameters()
number of servers executing this procedure. Each of these result sets
will only have one "row" in it, one Object[] corresponding to the out
parameters.
Returns the whereClause for this execution, or null if there wasn't
one.
getFilter()
Returns the table name in the format "schemaName.tableName" if
this procedure was executed with an ON TABLE clause, or null
otherwise.
getTableName()
Returns an array of colocated tables in this server in the format
"schemaName.tableName". If this procedure was not called with an
ON TABLE clause, then this method returns null.
getColocatedTableNames()
Return the name of this procedure.getProcedureName()
Return true if this is a re-attempt occurring after a member of the
distributed system has failed. For some procedure implementations
isPossibleDuplicate()
that are doing write operations, special handling may be necessary
if this is a possible duplicate invocation on this data.
Returns true if the specified table is a partitioned table, false if it is
a replicated table.
isPartitioned(String tableName)
IncomingResultSet
IncomingResultSet is an interface for retrieving rows as List<Object> from an incoming result set.
This interface uses semantics similar to a BlockingQueue. It has these methods:
DescriptionMethod
Retrieve and removes the head row in this result set as a
List<Object>, waiting if necessary until an element becomes
takeRow()
available, or returning END_OF_RESULTS if there are no more
rows in this result set.
vFabric SQLFire User's Guide468
vFabric SQLFire Reference