Examples of MetadataCache

Examples of com.nearinfinity.honeycomb.hbase.MetadataCache

95
96
97
98
99
100
101
102
103
104
105
        LOG.info("Input separator: '" + separator + "'");

        final HTablePool pool = new HTablePool(conf, 1);
        HBaseMetadata metadata = new HBaseMetadata(new PoolHTableProvider(hbaseTable, pool));
        metadata.setColumnFamily(columnFamily);
        HBaseStore store = new HBaseStore(metadata, null, new MetadataCache(metadata));

        tableId = store.getTableId(sqlTable);
        schema = store.getSchema(sqlTable);
        mutationFactory = new MutationFactory(store);
        mutationFactory.setColumnFamily(columnFamily);
View Full Code Here

Examples of com.rackspacecloud.blueflood.cache.MetadataCache

106
107
108
109
110
111
112
113
114
115
116
        // state management for active shards, slots, etc.
        ShardStateIO shardstateIO = new AstyanaxShardStateIO(); // todo: use configuration setting.
        StateManager stateManager = new StateManager(rollupContext, shardstateIO);
        environment.lifecycle().manage(stateManager);
       
        MetadataCache cache = MetadataCache.getInstance();
       
        // create resources.
        final NotDOAHealthCheck notDOA = new NotDOAHealthCheck();
        final BasicIngestResource basicIngestResource = new BasicIngestResource(
                ingestConfiguration,
View Full Code Here

Examples of com.rackspacecloud.blueflood.cache.MetadataCache

32
33
34
35
36
37
38
39
40
41
42
    @Test
    public void testBatchedMetaWritesAndReads() throws Exception {
        final AstyanaxMetadataIO metadataIO = new AstyanaxMetadataIO();
        Table<Locator, String, String> metaTable = HashBasedTable.create();
        final Set<Locator> locators = new HashSet<Locator>();
        MetadataCache cache = MetadataCache.getInstance();

        for (int i = 0; i < 10; i++) {
            Locator loc = Locator.createLocatorFromDbKey(
                    "12345.rackspace.monitoring.enities.enFoo.check_type.agent.cpu.check.chBar.metric.met" + i);
            locators.add(loc);
View Full Code Here

Examples of com.rackspacecloud.blueflood.cache.MetadataCache

159
160
161
162
163
164
165
166
167
168
169
            .withUnboundedQueue()
            .build());


        // RollupRunnable keeps a static one of these. It would be nice if we could register it and share.
        MetadataCache rollupTypeCache = MetadataCache.createLoadingCacheInstance(
                new TimeValue(48, TimeUnit.HOURS),
                Configuration.getInstance().getIntegerProperty(CoreConfig.MAX_ROLLUP_READ_THREADS));
        rollupTypeCacher = new RollupTypeCacher(
                new ThreadPoolBuilder().withName("Rollup type persistence").build(),
                rollupTypeCache,
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.