Page History

/** writesUse andDSFIDSerializerFactory readsto DataSerializableFixedIDcreate instances.a  Supports reading/writing of nulls serializer */
interfaceclass DSFIDSerializerDSFIDSerializerFactory {
  void writeDSFID(DataSerializableFixedID, DataOutput output) throws IOException;
  DataSerializableFixedID readDSFID(DataInput input) throws IOException, ClassNotFoundException;
}

/** provides context for toData and fromData serialization methods */
interface SerializationContext {
  DSFIDSerializer getDSFIDSerializer();
  SerializerPlugin getDataSerializer();  // provides InternalDataSerializer readObject/writeObject
  Version getSerializationVersion/** set an ObjectSerializer that should be used when invoking
   *  toData/fromData methods on objects.  This will typically
   *  defer serialization of DataSerializableFixedID objects to
   *  the DSFIDSerializer
   */
  setObjectSerializer(ObjectSerializer serializer);
  create();
}

/** writes injectsand higherreads level (e.g., DataSerializer) serialization services into DSFID serializers for
    use in serializing objects that the basic DSFIDSerializer can't handle */
interface SerializerPlugin {
  public void writeObject(Object obj, DataOutput output) throws IOException;
  public Object readObject(DataInput input) throws IOException, ClassNotFoundException;DataSerializableFixedID instances.  Supports reading/writing of nulls */
interface DSFIDSerializer {
  /** retrieve the ObjectSerializer.  If none was given to the factory this will be
   *  a default serializer that can only handle DataSerializableFixedID objects */
  ObjectSerializer getObjectSerializer();

  /**
 register a *class returnwith the versionserializer. associated withIt themust givenhave ordinala orno-arg theconstructor current*/
 version ifvoid the given
   * ordinal is > than the current version's ordinal
   */
  public Version getVersionForOrdinalOrCurrent(int ordinal);
}

/** a new superclass of HeapDataOutputStream that separates the methods used with Buffers from
    a bunch of other methods concerning other functionality such as Streamables, PDX, etc. */
class BufferDataOutputStream {
  // methods moved from HeapDataOutputStream unchangedregisterDSFID(int dsfid, Class dsfidClass);

  SerializationContext createSerializationContext(DataOutput dataOutput);
  SerializationContext createSerializationContext(DataInput dataInput);

  void writeDSFID(DataSerializableFixedID o, int dsfid, DataOutput out) throws IOException;
  void writeDSFID(DataSerializableFixedID dsfid, DataOutput out) throws IOException;

  Object create(int dsfid, DataInput in) throws IOException, ClassNotFoundException;

  void invokeToData(Object ds, DataOutput out) throws IOException;
  void invokeFromData(Object ds, DataInput in) throws IOException, ClassNotFoundException;

  int readDSFIDHeader(DataInput dis) throws IOException;
  void writeDSFIDHeader(int dsfid, DataOutput out) throws IOException;
}

/** DataSerializableFixedIDprovides iscontext modifiedfor totoData haveand morefromData parameters in toData/fromData serialization methods */
classinterface DataSerializableFixedIDSerializationContext {
  public Version[] getSerializationVersions()ObjectSerializer getSerializer();
  publicVersion int getDSFIDgetSerializationVersion();
}

interface ObjectSerializer {
  public void toDatawriteObject(DataOutputObject outputobj, SerializationContextDataOutput contextoutput) throws IOException;
  public voidObject fromDatareadObject(DataInput input, SerializationContext context) throws ClassNotFoundExceptionIOException, IOExceptionClassNotFoundException;
}


  void invokeToData(Object ds, DataOutput out) throws IOException;
  void invokeFromData(Object ds, DataInput in) throws IOException, ClassNotFoundException;

  public Version getVersionForOrdinalOrCurrent(int ordinal);
}

/** a new superclass of HeapDataOutputStream that separates the methods used with Buffers from
    a bunch of other methods concerning other functionality such as Streamables, PDX, etc. */
class BufferDataOutputStream {
  // methods moved from HeapDataOutputStream unchanged
}

/** DataSerializableFixedID is modified to have more parameters in toData/fromData methods */
class DataSerializableFixedID {
  public Version[] getSerializationVersions();
  public int getDSFID();
  public void toData(DataOutput output, SerializationContext context) throws IOException;
  public void fromData(DataInput input, SerializationContext context) throws ClassNotFoundException, IOException;
}