@Override
    public void expireConnectorHistogramStatistics(Table table, List<String> columns) {
        if (table == null || columns == null) {
            return;
        }
        List<ConnectorTableColumnKey> allKeys = Lists.newArrayList();
        for (String column : columns) {
            ConnectorTableColumnKey key = new ConnectorTableColumnKey(table.getUUID(), column);
            allKeys.add(key);
        }
        connectorHistogramCache.synchronous().invalidateAll(allKeys);
    }
@Test
    public void testExpireConnectorHistogramStatistics() {
        Table table = connectContext.getGlobalStateMgr().getMetadataMgr().getTable("hive0", "partitioned_db", "t1");
        CachedStatisticStorage cachedStatisticStorage = new CachedStatisticStorage();
        try {
            cachedStatisticStorage.expireConnectorHistogramStatistics(table, ImmutableList.of("c1", "c2"));
        } catch (Exception e) {
            Assert.fail();
        }
    }