Examples of com.netflix.zeno.fastblob.record.ByteData

Package com.netflix.zeno.fastblob.record

Examples of com.netflix.zeno.fastblob.record.ByteData

com.netflix.zeno.fastblob.record.ByteData
Interface implemented by data structures which may be used to access FastBlob record data: {@link SegmentedByteArray}{@link StreamingByteData} @author dkoszewnik

    /**
     * Read a String as UTF-8 encoded characters.  The length is encoded as a variable-byte integer.
     */
    @Override
    public String deserializeString(FlatBlobDeserializationRecord rec, String fieldName) {
        ByteData byteData = rec.getByteData();
        long fieldPosition = rec.getPosition(fieldName);


        if (fieldPosition == -1 || VarInt.readVNull(byteData, fieldPosition))
            return null;

View Full Code Here

    /**
     * Read a sequence of bytes directly from the stream.  The length is encoded as a variable-byte integer.
     */
    @Override
    public byte[] deserializeBytes(FlatBlobDeserializationRecord rec, String fieldName) {
        ByteData byteData = rec.getByteData();
        long fieldPosition = rec.getPosition(fieldName);


        if (fieldPosition == -1 || VarInt.readVNull(byteData, fieldPosition))
            return null;


        int length = VarInt.readVInt(byteData, fieldPosition);
        fieldPosition += VarInt.sizeOfVInt(length);


        byte data[] = new byte[length];


        for(int i=0;i<length;i++) {
            data[i] = byteData.get(fieldPosition++);
        }


        return data;
    }

View Full Code Here

        return deserializeObject(rec, position, typeName);
    }


    @SuppressWarnings("unchecked")
    private <T> T deserializeObject(FlatBlobDeserializationRecord rec, long position, String typeName) {
        ByteData underlyingData = rec.getByteData();


        if (position == -1 || VarInt.readVNull(underlyingData, position))
            return null;


        int ordinal = VarInt.readVInt(underlyingData, position);

View Full Code Here

        return deserialized;
    }


    @Override
    public <T> List<T> deserializeList(FlatBlobDeserializationRecord rec, String fieldName, NFTypeSerializer<T> itemSerializer) {
        ByteData byteData = rec.getByteData();
        long fieldPosition = rec.getPosition(fieldName);


        if (fieldPosition == -1 || VarInt.readVNull(byteData, fieldPosition))
            return null;

View Full Code Here

        return listBuilder.builderFinish();
    }


    @Override
    public <T> Set<T> deserializeSet(FlatBlobDeserializationRecord rec, String fieldName, NFTypeSerializer<T> itemSerializer) {
        ByteData byteData = rec.getByteData();
        long fieldPosition = rec.getPosition(fieldName);


        if (fieldPosition == -1 || VarInt.readVNull(byteData, fieldPosition))
            return null;

View Full Code Here

        return setBuilder.builderFinish();
    }


    @Override
    public <K, V> Map<K, V> deserializeMap(FlatBlobDeserializationRecord rec, String fieldName, NFTypeSerializer<K> keySerializer, NFTypeSerializer<V> valueSerializer) {
        ByteData byteData = rec.getByteData();
        long fieldPosition = rec.getPosition(fieldName);


        if (fieldPosition == -1 || VarInt.readVNull(byteData, fieldPosition))
            return null;

View Full Code Here

        return minimizedCollections.minimizeMap(map.builderFinish());
    }


    @Override
    public <K, V> SortedMap<K, V> deserializeSortedMap(FlatBlobDeserializationRecord rec, String fieldName, NFTypeSerializer<K> keySerializer, NFTypeSerializer<V> valueSerializer) {
        ByteData byteData = rec.getByteData();
        long fieldPosition = rec.getPosition(fieldName);


        if(fieldPosition == -1 || VarInt.readVNull(byteData, fieldPosition))
            return null;

View Full Code Here

        this.scratch = new ByteDataBuffer();
    }


    public void remapOrdinals(FastBlobDeserializationRecord rec, ByteDataBuffer toBuffer) {
        FastBlobSchema schema = rec.getSchema();
        ByteData fromSpace = rec.getByteData();


        long currentPointerPosition = rec.position();


        for(int i=0;i<schema.numFields();i++) {
            FieldDefinition fieldDef = schema.getFieldDefinition(i);

View Full Code Here

            return null;
        return deserializeObject(rec, fieldPosition, typeName);
    }


    private <T> T deserializeObject(FastBlobDeserializationRecord rec, long fieldPosition, String typeName) {
        ByteData byteData = rec.getByteData();


        if (fieldPosition == -1 || VarInt.readVNull(byteData, fieldPosition))
            return null;


        int ordinal = VarInt.readVInt(byteData, fieldPosition);

View Full Code Here

    /**
     * Read a List as a sequence of ordinals encoded as variable-byte integers.  Use the framework to look up each Object by it's ordinals.
     */
    @Override
    public <T> List<T> deserializeList(FastBlobDeserializationRecord rec, String fieldName, NFTypeSerializer<T> itemSerializer) {
        ByteData byteData = rec.getByteData();
        long fieldPosition = rec.getPosition(fieldName);


        if (fieldPosition == -1 || VarInt.readVNull(byteData, fieldPosition))
            return null;

View Full Code Here

0 1 2 3

TOP

Related Classes of com.netflix.zeno.fastblob.record.ByteData

com.netflix.zeno.fastblob.FastBlobFrameworkDeserializer

com.netflix.zeno.fastblob.state.OrdinalRemapper

com.netflix.zeno.flatblob.FlatBlobFrameworkDeserializer

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.