This Confluence has been LDAP enabled, if you are an ASF Committer, please use your LDAP Credentials to login. Any problems file an INFRA jira ticket please.

Child pages
  • Pluggable IgniteObjects
Skip to end of metadata
Go to start of metadata

Cache configuration changes

Adding ability to set a marshaller to cache configuration:

public class CacheConfiguration {
    // ...
 
    public void setMarshaller(Marshaller marshaller) {...}
    public Marshaller getMarshaller() {...}
 
    // ...
}

 

Public API: New Interface

/**
 * 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
 

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);}
public interface SeekableDataInput extends DataInput {
    public long position();
 
    public void seek(long pos) throws IOException;
 
    public void ensureOnHeap();
}

 

 
  • No labels

4 Comments

  1. I have a question on IgniteObject.source() method. How will you be able to provide the source if you cannot really cache a reference to it?

  2. In cases when an input stream is passed to the object factory, the input stream will be store in the object. Otherwise, source stream can be created from byte array.

    1. Can you please provide more details? I don't see an object factory in the design.

    2. I still don't like this source() method name. Why do we care if it is the original source or a new one just created? I think a specific implementation of IgniteObject should always know how to create the SeekableDataInput based on its internal state, regardless if it was created from a byte array or an off-heap pointer. Perhaps we should rename the method to dataInput()?