Examples of voldemort.serialization.DefaultSerializerFactory

voldemort.serialization.DefaultSerializerFactory
Factory that maps serialization strings to serializers. Used to get a Serializer from config serializer description.

                                                                partitionIdList,
                                                                null,
                                                                false);


            final SerializerDefinition serializerDef = storeDef.getKeySerializer();
            final SerializerFactory serializerFactory = new DefaultSerializerFactory();
            @SuppressWarnings("unchecked")
            final Serializer<Object> serializer = (Serializer<Object>) serializerFactory.getSerializer(serializerDef);


            final CompressionStrategy keysCompressionStrategy;
            if(serializerDef != null && serializerDef.hasCompression()) {
                keysCompressionStrategy = new CompressionStrategyFactory().get(serializerDef.getCompression());
            } else {

View Full Code Here

        fetcher.fetch(nodeFile.getAbsolutePath(), versionDir.getAbsolutePath());
        Assert.assertTrue(versionDir.exists());


        // open store
        @SuppressWarnings("unchecked")
        Serializer<Object> serializer = (Serializer<Object>) new DefaultSerializerFactory().getSerializer(serDef);
        ReadOnlyStorageEngine engine = new ReadOnlyStorageEngine(storeName,
                                                                 searchStrategy,
                                                                 new RoutingStrategyFactory().updateRoutingStrategy(def,
                                                                                                                    cluster),
                                                                 0,

View Full Code Here


            if(useAscii) {
                // k-v serializer
                SerializerDefinition keySerializerDef = storeDefinition.getKeySerializer();
                SerializerDefinition valueSerializerDef = storeDefinition.getValueSerializer();
                SerializerFactory serializerFactory = new DefaultSerializerFactory();
                @SuppressWarnings("unchecked")
                final Serializer<Object> keySerializer = (Serializer<Object>) serializerFactory.getSerializer(keySerializerDef);
                @SuppressWarnings("unchecked")
                final Serializer<Object> valueSerializer = (Serializer<Object>) serializerFactory.getSerializer(valueSerializerDef);


                // compression strategy
                final CompressionStrategy keyCompressionStrategy;
                final CompressionStrategy valueCompressionStrategy;
                if(keySerializerDef != null && keySerializerDef.hasCompression()) {

View Full Code Here

                outputFile = new File(directory, store + ".keys");
            }
            final Iterator<ByteArray> keyIterator = keyIteratorRef;
            if(useAscii) {
                final SerializerDefinition serializerDef = storeDefinition.getKeySerializer();
                final SerializerFactory serializerFactory = new DefaultSerializerFactory();
                @SuppressWarnings("unchecked")
                final Serializer<Object> serializer = (Serializer<Object>) serializerFactory.getSerializer(serializerDef);


                final CompressionStrategy keysCompressionStrategy;
                if(serializerDef != null && serializerDef.hasCompression()) {
                    keysCompressionStrategy = new CompressionStrategyFactory().get(serializerDef.getCompression());
                } else {

View Full Code Here

            out.write("STORE_NAME: " + storeDefinition.getName() + "\n");


            // k-v serializer
            final SerializerDefinition keySerializerDef = storeDefinition.getKeySerializer();
            final SerializerDefinition valueSerializerDef = storeDefinition.getValueSerializer();
            SerializerFactory serializerFactory = new DefaultSerializerFactory();
            @SuppressWarnings("unchecked")
            final Serializer<Object> keySerializer = (Serializer<Object>) serializerFactory.getSerializer(keySerializerDef);
            @SuppressWarnings("unchecked")
            final Serializer<Object> valueSerializer = (Serializer<Object>) serializerFactory.getSerializer(valueSerializerDef);


            // compression strategy
            final CompressionStrategy keyCompressionStrategy;
            final CompressionStrategy valueCompressionStrategy;
            if(keySerializerDef != null && keySerializerDef.hasCompression()) {

View Full Code Here

        }


        String storeName = "test";
        SerializerDefinition serDef = new SerializerDefinition("string");
        Cluster cluster = ServerTestUtils.getLocalCluster(1);
        Serializer<Object> serializer = (Serializer<Object>) new DefaultSerializerFactory().getSerializer(serDef);


        // write test data to text file
        File inputFile = File.createTempFile("input", ".txt", testDir);
        inputFile.deleteOnExit();
        StringBuilder contents = new StringBuilder();

View Full Code Here

        for(Map.Entry<String, String> entry: testData.getData().entrySet()) {
            for(Node node: testData.routeRequest(entry.getKey())) {
                nodeToEntries.put(node.getId(), Pair.create(entry.getKey(), entry.getValue()));
            }
        }
        SerializerFactory factory = new DefaultSerializerFactory();
        Serializer<String> serializer = (Serializer<String>) factory.getSerializer(serDef);
        for(Map.Entry<Integer, ReadOnlyStorageEngine> storeEntry: testData.getReadOnlyStores()
                                                                          .entrySet()) {
            List<Pair<String, String>> entries = Lists.newArrayList(nodeToEntries.get(storeEntry.getKey()));
            ClosableIterator<ByteArray> keyIterator = null;
            ClosableIterator<Pair<ByteArray, Versioned<byte[]>>> entryIterator = null;

View Full Code Here

    }


    public void testGetSerializer() {
        SerializerDefinition def = new SerializerDefinition("protobuf",
                                                            "java=" + MessageStub.class.getName());
        Serializer<?> serializer = new DefaultSerializerFactory().getSerializer(def);
        assertEquals(ProtoBufSerializer.class, serializer.getClass());
    }

View Full Code Here

                                                             false);
        storeBuilder.build(type);


        File nodeDir = TestUtils.createTempDir(baseDir);
        @SuppressWarnings("unchecked")
        Serializer<String> keySerializer = (Serializer<String>) new DefaultSerializerFactory().getSerializer(keySerDef);
        @SuppressWarnings("unchecked")
        Serializer<String> valueSerializer = (Serializer<String>) new DefaultSerializerFactory().getSerializer(valueSerDef);
        Serializer<String> transSerializer = new StringSerializer();
        Map<Integer, Store<String, String, String>> nodeStores = Maps.newHashMap();
        Map<Integer, ReadOnlyStorageEngine> readOnlyStores = Maps.newHashMap();


        for(int i = 0; i < numNodes; i++) {

View Full Code Here


    public void testGetSerializer() {
        SerializerDefinition def = new SerializerDefinition("thrift", "java="
                                                                      + MockMessage.class.getName()
                                                                      + ", protocol=binary   ");
        Serializer<?> serializer = new DefaultSerializerFactory().getSerializer(def);
        assertEquals(ThriftSerializer.class, serializer.getClass());
    }

View Full Code Here

0 1 2

TOP

Related Classes of voldemort.serialization.DefaultSerializerFactory

voldemort.client.MockStoreClientFactory

voldemort.client.protocol.admin.StreamingClientTest

voldemort.performance.RequestFileFilter

voldemort.serialization.avro.AvroGenericSerializer

voldemort.serialization.avro.versioned.AvroVersionedGenericSerializer

voldemort.serialization.json.JsonTypeSerializer

voldemort.serialization.protobuf.ProtoBufSerializerTest

voldemort.serialization.thrift.ThriftSerializerTest

voldemort.store.readonly.JsonStoreBuilder

voldemort.store.readonly.JsonStoreBuilder$JsonObjectIterator

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.