@Test public void testGetFieldMappingsNonExistingTable() throws FoxtrotException { try { queryStore.getFieldMappings(TestUtils.TEST_TABLE + "-test"); fail(); } catch (FoxtrotException qse) { assertEquals(ErrorCode.INVALID_REQUEST, qse.getCode()); } }
@Override public TableFieldMapping getFieldMappings(String table) { return tableMetadataManager.getFieldMappings(table, false, false); }
ElasticsearchQueryStore implements QueryStore { @Override public TableFieldMapping getFieldMappings(String table) { return tableMetadataManager.getFieldMappings(table, false, false); } }
ElasticsearchQueryStore implements QueryStore { @Override public TableFieldMapping getFieldMappings(String table) { return tableMetadataManager.getFieldMappings(table, false, false); } @Inject  ElasticsearchQueryStore(TableMetadataManager tableMetadataManager,
                                   ElasticsearchConnection connection,
                                   DataStore dataStore,
                                   List<IndexerEventMutator> mutators,
                                   ObjectMapper mapper,
                                   CardinalityConfig cardinalityConfig); }
ElasticsearchQueryStore implements QueryStore { @Override public TableFieldMapping getFieldMappings(String table) { return tableMetadataManager.getFieldMappings(table, false, false); } @Inject  ElasticsearchQueryStore(TableMetadataManager tableMetadataManager,
                                   ElasticsearchConnection connection,
                                   DataStore dataStore,
                                   List<IndexerEventMutator> mutators,
                                   ObjectMapper mapper,
                                   CardinalityConfig cardinalityConfig); @Override @Timed void initializeTable(String table); @Override @Timed void save(String table, Document document); @Override @Timed void save(String table, List<Document> documents); @Override @Timed Document get(String table, String id); @Override List<Document> getAll(String table, List<String> ids); @Override @Timed List<Document> getAll(String table, List<String> ids, boolean bypassMetalookup); @Override void cleanupAll(); @Override @Timed void cleanup(final String table); @Override @Timed void cleanup(Set<String> tables); @Override ClusterHealthResponse getClusterHealth(); @Override NodesStatsResponse getNodeStats(); @Override IndicesStatsResponse getIndicesStats(); @Override TableFieldMapping getFieldMappings(String table); }
ElasticsearchQueryStore implements QueryStore { @Override public TableFieldMapping getFieldMappings(String table) { return tableMetadataManager.getFieldMappings(table, false, false); } @Inject  ElasticsearchQueryStore(TableMetadataManager tableMetadataManager,
                                   ElasticsearchConnection connection,
                                   DataStore dataStore,
                                   List<IndexerEventMutator> mutators,
                                   ObjectMapper mapper,
                                   CardinalityConfig cardinalityConfig); @Override @Timed void initializeTable(String table); @Override @Timed void save(String table, Document document); @Override @Timed void save(String table, List<Document> documents); @Override @Timed Document get(String table, String id); @Override List<Document> getAll(String table, List<String> ids); @Override @Timed List<Document> getAll(String table, List<String> ids, boolean bypassMetalookup); @Override void cleanupAll(); @Override @Timed void cleanup(final String table); @Override @Timed void cleanup(Set<String> tables); @Override ClusterHealthResponse getClusterHealth(); @Override NodesStatsResponse getNodeStats(); @Override IndicesStatsResponse getIndicesStats(); @Override TableFieldMapping getFieldMappings(String table);  }