Versions Compared

Old Version 7

changes.mady.by.user Alexey Goncharuk

Saved on

compared with

New Version Current

changes.mady.by.user Dmitriy Setrakyan

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

Drawbacks:

  • An instance of SeekableInputStream is passed to object factory which leads to a ~40-byte overhead per cache entry on object header (20 bytes per each key and value)
  • There is no way to create a temporary IgniteObject without serialization

 

Cache configuration changes

Adding ability to set a marshaller to cache configuration:

...

Code Block
languagejava
/**
 * Abstracted binary representation of objects.
 */
public interface IgniteObject {
    /**
     * Gets portable object type ID.
     *
     * @return Type ID.
     */
    public int typeId();

    /**
     * Gets fully deserialized instance of portable object.
     *
     * @return Fully deserialized instance of portable object.
     */
    @Nullable public <T> T deserialize() throws IgniteException;

    /**
     * Gets field value.
     *
     * @param fieldName Field name.
     * @return Field value.
     */
    @Nullable public <T> T field(String fieldName);

    /**
     * Checks whether field is set.
     *
     * @param fieldName Field name.
     * @return {@code true} if field is set.
     */
    public boolean hasField(String fieldName);
 
    /**
     * Gets the source input stream that was used to create this IgniteObject.
     */
    public SeekableDataInput source();
}

 

...

IgniteObjectMarshaller
 

Code Block
languagejava
titleCacheObjectManager
/**
 *
 */
public interface CacheObjectFactory {public interface IgniteObjectMarshaller extends Marshaller {    
    /**
     * @param input Seekable input.
     * @return Cache object.
     */
    @Nullable public IgniteObject toIgniteObject(SeekableDataInput input);

    /**
     * @param input Seekable input.
     * @return Cache object.
     */
    @Nullable public IgniteObject toIgniteObject(byte[] data);

    /**
     * @param typeName Type name.
     * @return Type ID.
     */
    public abstract int typeId(String typeName);

    /**
     * @param obj Object to get type ID for.
     * @return Type ID.
     */
    public abstract int typeId(Object obj);
}
Code Block
languagejava
public interface MarshallerEx extends Marshaller {
    public CacheObjectFactory getCacheObjectFactory();
}
Code Block
languagejava
public interface SeekableDataInput extends DataInput {
    public long position();
 
    public void seek(long pos) throws IOException;
 
    public void ensureOnHeap();
}

...