Package voldemort.serialization

Examples of voldemort.serialization.SerializationException

119
120
121
122
123
124
125
126
127
128
129
        try {
            datumWriter = new GenericDatumWriter<Object>(writer);
            datumWriter.write(object, encoder);
            encoder.flush();
        } catch(IOException e) {
            throw new SerializationException(e);
        } catch(SerializationException sE) {
            throw sE;
        } finally {
            SerializationUtils.close(output);
        }
View Full Code Here
138
139
140
141
142
143
144
            if(s.equals(version))
                return entry.getKey();

        }

        throw new SerializationException("Writer's schema invalid!");
    }
View Full Code Here
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
    public Object toObject(byte[] bytes) {

        Integer version = Integer.valueOf(bytes[0]);

        if(version > newestVersion)
            throw new SerializationException("Client needs to rebootstrap! \n Writer's schema version greater than Reader");

        Schema typeDefWriter = Schema.parse(typeDefVersions.get(version));

        byte[] dataBytes = new byte[bytes.length - 1];
        System.arraycopy(bytes, 1, dataBytes, 0, bytes.length - 1);
        Decoder decoder = DecoderFactory.defaultFactory().createBinaryDecoder(dataBytes, null);
        GenericDatumReader<Object> reader = null;
        try {
            reader = new GenericDatumReader<Object>(typeDefWriter, typeDef);
            // writer's schema
            reader.setSchema(typeDefWriter);
            // Reader's schema
            reader.setExpected(typeDef);
            return reader.read(null, decoder);
        } catch(IOException e) {
            throw new SerializationException(e);
        }

    }
View Full Code Here
80
81
82
83
84
85
86
87
        try {
            toBytes(object, output);
            output.flush();
            return bytes.toByteArray();
        } catch(IOException e) {
            throw new SerializationException(e);
        }
    }
View Full Code Here
97
98
99
100
101
102
103
104
    public Object toObject(byte[] bytes) {
        DataInputStream input = new DataInputStream(new ByteArrayInputStream(bytes));
        try {
            return toObject(input);
        } catch(IOException e) {
            throw new SerializationException(e);
        }
    }
View Full Code Here
107
108
109
110
111
112
113
114
        Integer version = 0;
        if(hasVersion)
            version = Integer.valueOf(input.readByte());
        JsonTypeDefinition typeDef = typeDefVersions.get(version);
        if(typeDef == null)
            throw new SerializationException("No schema found for schema version " + version + ".");
        return read(input, typeDef.getType());
    }
View Full Code Here
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
    @SuppressWarnings("unchecked")
    private void write(DataOutputStream output, Object object, Object type) throws IOException {
        try {
            if(type instanceof Map) {
                if(object != null && !(object instanceof Map))
                    throw new SerializationException("Expected Map, but got " + object.getClass()
                                                     + ": " + object);
                writeMap(output, (Map<String, Object>) object, (Map<String, Object>) type);
            } else if(type instanceof List) {
                if(object != null && !(object instanceof List))
                    throw new SerializationException("Expected List but got " + object.getClass()
                                                     + ": " + object);
                writeList(output, (List<Object>) object, (List<Object>) type);
            } else if(type instanceof JsonTypes) {
                JsonTypes jsonType = (JsonTypes) type;
                switch(jsonType) {
                    case STRING:
                        writeString(output, (String) object);
                        break;
                    case INT8:
                        writeInt8(output, (Byte) object);
                        break;
                    case INT16:
                        writeInt16(output, coerceToShort(object));
                        break;
                    case INT32:
                        writeInt32(output, coerceToInteger(object));
                        break;
                    case INT64:
                        writeInt64(output, coerceToLong(object));
                        break;
                    case FLOAT32:
                        writeFloat32(output, coerceToFloat(object));
                        break;
                    case FLOAT64:
                        writeFloat64(output, coerceToDouble(object));
                        break;
                    case DATE:
                        writeDate(output, coerceToDate(object));
                        break;
                    case BYTES:
                        writeBytes(output, (byte[]) object);
                        break;
                    case BOOLEAN:
                        writeBoolean(output, (Boolean) object);
                        break;
                    default:
                        throw new SerializationException("Unknown type: " + type);
                }
            }
        } catch(ClassCastException e) {
            // simpler than doing every test
            throw new SerializationException("Expected type " + type
                                             + " but got object of incompatible type "
                                             + object.getClass().getName() + ".", e);
        }
    }
View Full Code Here
199
200
201
202
203
204
205
206
207
208
209
                case BYTES:
                    return readBytes(stream);
                case STRING:
                    return readString(stream);
                default:
                    throw new SerializationException("Unknown type: " + type);
            }
        } else {
            throw new SerializationException("Unknown type of class " + type.getClass());
        }
    }
View Full Code Here
234
235
236
237
238
239
240
241
242
        if(c == Short.class)
            return (Short) o;
        else if(c == Byte.class)
            return ((Byte) o).shortValue();
        else
            throw new SerializationException("Object of type " + c.getName()
                                             + " cannot be coerced to type " + JsonTypes.INT16
                                             + " as the schema specifies.");
    }
View Full Code Here
250
251
252
253
254
255
256
257
258
        else if(c == Byte.class)
            return ((Byte) o).intValue();
        else if(c == Short.class)
            return ((Short) o).intValue();
        else
            throw new SerializationException("Object of type " + c.getName()
                                             + " cannot be coerced to type " + JsonTypes.INT32
                                             + " as the schema specifies.");
    }
View Full Code Here
TOP

Related Classes of voldemort.serialization.SerializationException

  • voldemort.client.AbstractStoreClientFactory
  • voldemort.serialization.avro.AvroGenericSerializer
  • voldemort.serialization.avro.AvroReflectiveSerializer
  • voldemort.serialization.avro.AvroSpecificSerializer
  • voldemort.serialization.avro.versioned.AvroVersionedGenericSerializer
  • voldemort.serialization.json.JsonReader
  • voldemort.serialization.json.JsonTypeDefinition
  • voldemort.serialization.json.JsonTypeSerializer
  • voldemort.serialization.thrift.ThriftSerializer
  • voldemort.store.readonly.mr.serialization.JsonDeserializerComparator
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.