zeta.processor
Interface TaskResultProcessor

All Superinterfaces:

TaskProcessor

All Known Implementing Classes:

DefaultWorkUnitProcessor

public interface TaskResultProcessor

extends TaskProcessor

Processes work units received through the result handler.

Method Summary

void	checkResult(WorkUnit workUnit, byte[] result) Checks work units received through the result handler
boolean	processResult(java.sql.Statement stmt, WorkUnit workUnit, byte[] result, boolean recomputation) Processes work units received through the result handler

Methods inherited from interface zeta.processor.TaskProcessor

getWorkUnit, init

Method Detail

checkResult

public void checkResult(WorkUnit workUnit,
                        byte[] result)
                 throws java.lang.Exception

Checks work units received through the result handler

Parameters:

workUnit - work unit which should be checked

result - buffer with the zipped result

java.lang.Exception

processResult

public boolean processResult(java.sql.Statement stmt,
                             WorkUnit workUnit,
                             byte[] result,
                             boolean recomputation)
                      throws javax.servlet.ServletException,
                             java.sql.SQLException,
                             java.io.IOException

Processes work units received through the result handler

Parameters:

stmt - statement object's database

workUnit - work unit which should be processed

result - buffer with the zipped result

recomputation - if the result was recomputed

Returns:

true if the ResultHandler shall save the result into the database.

Throws:

java.io.IOException - if an I/O error occurs.

javax.servlet.ServletException

java.sql.SQLException