org.apache.s4.core.ft
Class SerializeTask

java.lang.Object
  extended by org.apache.s4.core.ft.SerializeTask
All Implemented Interfaces:
java.util.concurrent.Callable<byte[]>

public class SerializeTask
extends java.lang.Object
implements java.util.concurrent.Callable<byte[]>

Encaspulate a PE serialization operation. This operation locks the PE instance in order to avoid any inconsistent serialized state. If serialization is successful, the PE is marked as "not dirty".


Constructor Summary
SerializeTask(ProcessingElement pe)
           
 
Method Summary
 byte[] call()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SerializeTask

public SerializeTask(ProcessingElement pe)
Method Detail

call

public byte[] call()
            throws java.lang.Exception
Specified by:
call in interface java.util.concurrent.Callable<byte[]>
Throws:
java.lang.Exception