@Test public void testCompositeGlobalTableStore() throws VirtualDatabaseException { CompositeVDB vdb = TestCompositeVDB.createCompositeVDB(new MetadataStore(), "foo"); GlobalTableStore gts = CompositeGlobalTableStore.createInstance(vdb, BufferManagerFactory.getStandaloneBufferManager(), null); assertTrue(gts instanceof GlobalTableStoreImpl); vdb.children = new LinkedHashMap<VDBKey, CompositeVDB>(); MetadataStore ms = new MetadataStore(); Schema s = new Schema(); s.setName("x"); ms.addSchema(s); CompositeVDB imported = TestCompositeVDB.createCompositeVDB(ms, "foo"); GlobalTableStore gts1 = Mockito.mock(GlobalTableStore.class); imported.getVDB().addAttachment(GlobalTableStore.class, gts1); vdb.getChildren().put(new VDBKey("foo1", 1), imported); CompositeGlobalTableStore cgts = (CompositeGlobalTableStore)CompositeGlobalTableStore.createInstance(vdb, BufferManagerFactory.getStandaloneBufferManager(), null); assertEquals(gts1, cgts.getStoreForTable(RelationalPlanner.MAT_PREFIX + "X.Y")); assertEquals(cgts.getPrimary(), cgts.getStore("Z")); }
public CompositeGlobalTableStore(Map<String, GlobalTableStore> stores, GlobalTableStore primary, QueryMetadataInterface metadata) { this.stores = stores; this.primary = primary; this.metadata = metadata; }
CompositeGlobalTableStore implements GlobalTableStore { public CompositeGlobalTableStore(Map<String, GlobalTableStore> stores, GlobalTableStore primary, QueryMetadataInterface metadata) { this.stores = stores; this.primary = primary; this.metadata = metadata; } }
CompositeGlobalTableStore implements GlobalTableStore { public CompositeGlobalTableStore(Map<String, GlobalTableStore> stores, GlobalTableStore primary, QueryMetadataInterface metadata) { this.stores = stores; this.primary = primary; this.metadata = metadata; } CompositeGlobalTableStore(Map<String, GlobalTableStore> stores,
            GlobalTableStore primary, QueryMetadataInterface metadata); }
CompositeGlobalTableStore implements GlobalTableStore { public CompositeGlobalTableStore(Map<String, GlobalTableStore> stores, GlobalTableStore primary, QueryMetadataInterface metadata) { this.stores = stores; this.primary = primary; this.metadata = metadata; } CompositeGlobalTableStore(Map<String, GlobalTableStore> stores,
            GlobalTableStore primary, QueryMetadataInterface metadata); static GlobalTableStore createInstance(CompositeVDB vdb, BufferManager bufferManager, ObjectReplicator replicator); @Override TempMetadataID getGlobalTempTableMetadataId(Object groupID); @Override TempMetadataID getGlobalTempTableMetadataId(String matTableName); @Override TempMetadataID getCodeTableMetadataId(String codeTableName,
            String returnElementName, String keyElementName, String matTableName); @Override MatTableInfo getMatTableInfo(String matTableName); @Override TempTable getTempTable(String matTableName); @Override Serializable getAddress(); @Override List<?> updateMatViewRow(String matTableName, List<?> tuple,
            boolean delete); @Override TempTable createMatTable(String matTableName, GroupSymbol group); @Override void failedLoad(String matTableName); @Override boolean needsLoading(String matTableName, Serializable loadingAddress,
            boolean firstPass, boolean refresh, boolean invalidate); @Override void loaded(String matTableName, TempTable table); }
CompositeGlobalTableStore implements GlobalTableStore { public CompositeGlobalTableStore(Map<String, GlobalTableStore> stores, GlobalTableStore primary, QueryMetadataInterface metadata) { this.stores = stores; this.primary = primary; this.metadata = metadata; } CompositeGlobalTableStore(Map<String, GlobalTableStore> stores,
            GlobalTableStore primary, QueryMetadataInterface metadata); static GlobalTableStore createInstance(CompositeVDB vdb, BufferManager bufferManager, ObjectReplicator replicator); @Override TempMetadataID getGlobalTempTableMetadataId(Object groupID); @Override TempMetadataID getGlobalTempTableMetadataId(String matTableName); @Override TempMetadataID getCodeTableMetadataId(String codeTableName,
            String returnElementName, String keyElementName, String matTableName); @Override MatTableInfo getMatTableInfo(String matTableName); @Override TempTable getTempTable(String matTableName); @Override Serializable getAddress(); @Override List<?> updateMatViewRow(String matTableName, List<?> tuple,
            boolean delete); @Override TempTable createMatTable(String matTableName, GroupSymbol group); @Override void failedLoad(String matTableName); @Override boolean needsLoading(String matTableName, Serializable loadingAddress,
            boolean firstPass, boolean refresh, boolean invalidate); @Override void loaded(String matTableName, TempTable table);  }