Package voldemort.store.compress

Examples of voldemort.store.compress.CompressionStrategyFactory

271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
                // compression strategy
                final CompressionStrategy keyCompressionStrategy;
                final CompressionStrategy valueCompressionStrategy;
                if(keySerializerDef != null && keySerializerDef.hasCompression()) {
                    keyCompressionStrategy = new CompressionStrategyFactory().get(keySerializerDef.getCompression());
                } else {
                    keyCompressionStrategy = null;
                }
                if(valueSerializerDef != null && valueSerializerDef.hasCompression()) {
                    valueCompressionStrategy = new CompressionStrategyFactory().get(valueSerializerDef.getCompression());
                } else {
                    valueCompressionStrategy = null;
                }

                if(keyCompressionStrategy == null) {
View Full Code Here
717
718
719
720
721
722
723
724
            this.digest = ByteUtils.getDigest("MD5");
            this.keySerializerDefinition = storeDefinition.getKeySerializer();
            this.valueSerializerDefinition = storeDefinition.getValueSerializer();
            this.keySerializer = (Serializer<Object>) factory.getSerializer(storeDefinition.getKeySerializer());
            this.valueSerializer = (Serializer<Object>) factory.getSerializer(storeDefinition.getValueSerializer());
            this.keyCompressor = new CompressionStrategyFactory().get(keySerializerDefinition.getCompression());
            this.valueCompressor = new CompressionStrategyFactory().get(valueSerializerDefinition.getCompression());
        }
View Full Code Here
513
514
515
516
517
518
519
            logger.error("Error shutting down system store factory", e);
        }
    }

    private CompressionStrategy getCompressionStrategy(SerializerDefinition serializerDef) {
        return new CompressionStrategyFactory().get(serializerDef.getCompression());
    }
View Full Code Here
269
270
271
272
273
274
275
276
277
278
279
280
        } catch(Exception e) {
            throw new RuntimeException(e);
        }

        keyCompressor = new CompressionStrategyFactory().get(keySerializerDefinition.getCompression());
        valueCompressor = new CompressionStrategyFactory().get(valueSerializerDefinition.getCompression());

        routingStrategy = new ConsistentRoutingStrategy(getCluster(),
                                                        getStoreDef().getReplicationFactor());

        Props props = HadoopUtils.getPropsFromJob(conf);
View Full Code Here
TOP

Related Classes of voldemort.store.compress.CompressionStrategyFactory

  • voldemort.client.AbstractStoreClientFactory
  • voldemort.client.protocol.admin.StreamingClientTest
  • voldemort.restclient.RESTClientFactory
  • voldemort.store.readonly.JsonStoreBuilder$JsonObjectIterator
  • voldemort.store.readonly.mr.AbstractHadoopStoreBuilderMapper
  • voldemort.store.readonly.mr.AvroStoreBuilderMapper
  • voldemort.store.readonly.ReadOnlyStorageEngineTestInstance
  • voldemort.store.views.ViewStorageConfiguration
  • voldemort.tools.admin.command.AdminCommandDebug$SubCommandDebugQueryKeys
  • voldemort.tools.admin.command.AdminCommandStream$SubCommandStreamFetchEntries
    • 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.