@Test public void put() { get(); }
@Override public void put(ConsumePartition key, Position value) { consumePositionCache.put(key, value); }
LocalFileStore implements PositionStore<ConsumePartition, Position> { @Override public void put(ConsumePartition key, Position value) { consumePositionCache.put(key, value); } }
LocalFileStore implements PositionStore<ConsumePartition, Position> { @Override public void put(ConsumePartition key, Position value) { consumePositionCache.put(key, value); }  }
LocalFileStore implements PositionStore<ConsumePartition, Position> { @Override public void put(ConsumePartition key, Position value) { consumePositionCache.put(key, value); }  void setBasePath(String basePath); @Override void start(); @Override void stop(); @Override boolean isStarted(); @Override Position get(ConsumePartition key); @Override void put(ConsumePartition key, Position value); @Override Position remove(ConsumePartition key); @Override Position putIfAbsent(ConsumePartition key, Position value); @Override void forceFlush(); @Override Iterator<ConsumePartition> iterator(); ConcurrentMap<ConsumePartition, Position> recover(); }
LocalFileStore implements PositionStore<ConsumePartition, Position> { @Override public void put(ConsumePartition key, Position value) { consumePositionCache.put(key, value); }  void setBasePath(String basePath); @Override void start(); @Override void stop(); @Override boolean isStarted(); @Override Position get(ConsumePartition key); @Override void put(ConsumePartition key, Position value); @Override Position remove(ConsumePartition key); @Override Position putIfAbsent(ConsumePartition key, Position value); @Override void forceFlush(); @Override Iterator<ConsumePartition> iterator(); ConcurrentMap<ConsumePartition, Position> recover();  }