Package voldemort.serialization.avro

Examples of voldemort.serialization.avro.AvroGenericSerializer

241
242
243
244
245
246
247
248
249
250
251
252
            keySchema = conf.get("avro.key.schema");
            valSchema = conf.get("avro.val.schema");

            if(keySerializerDefinition.getName().equals("avro-generic")) {
                keySerializer = new AvroGenericSerializer(keySchema);
                valueSerializer = new AvroGenericSerializer(valSchema);
            } else {

                if(keySerializerDefinition.hasVersion()) {
                    Map<Integer, String> versions = new HashMap<Integer, String>();
                    for(Map.Entry<Integer, String> entry: keySerializerDefinition.getAllSchemaInfoVersions()
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
        } else if(name.equals(PROTO_BUF_TYPE_NAME)) {
            return new ProtoBufSerializer<Message>(serializerDef.getCurrentSchemaInfo());
        } else if(name.equals(THRIFT_TYPE_NAME)) {
            return new ThriftSerializer<TBase<?, ?>>(serializerDef.getCurrentSchemaInfo());
        } else if(name.equals(AVRO_GENERIC_TYPE_NAME)) {
            return new AvroGenericSerializer(serializerDef.getCurrentSchemaInfo());
        } else if(name.equals(AVRO_SPECIFIC_TYPE_NAME)) {
            return new AvroSpecificSerializer<SpecificRecord>(serializerDef.getCurrentSchemaInfo());
        } else if(name.equals(AVRO_REFLECTIVE_TYPE_NAME)) {
            return new AvroReflectiveSerializer<Object>(serializerDef.getCurrentSchemaInfo());
        } else if(name.equals(AVRO_GENERIC_VERSIONED_TYPE_NAME)) {
View Full Code Here
TOP

Related Classes of voldemort.serialization.avro.AvroGenericSerializer

  • org.apache.avro.io.BinaryEncoder
  • org.apache.avro.io.Decoder
  • org.apache.avro.io.Encoder
  • voldemort.serialization.DefaultSerializerFactory
  • voldemort.store.readonly.mr.AvroStoreBuilderMapper
  • java.io.ByteArrayOutputStream
  • voldemort.serialization.SerializationException
    • 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.