@Test public void remove() { localFileStore.put(consumePartition, position); Position remove = localFileStore.remove(consumePartition); Assert.assertEquals(remove, position); Position position = localFileStore.get(consumePartition); Assert.assertEquals(null, position); }
@Override public Position remove(ConsumePartition key) { return consumePositionCache.remove(key); }
LocalFileStore implements PositionStore<ConsumePartition, Position> { @Override public Position remove(ConsumePartition key) { return consumePositionCache.remove(key); } }
LocalFileStore implements PositionStore<ConsumePartition, Position> { @Override public Position remove(ConsumePartition key) { return consumePositionCache.remove(key); }  }
LocalFileStore implements PositionStore<ConsumePartition, Position> { @Override public Position remove(ConsumePartition key) { return consumePositionCache.remove(key); }  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 Position remove(ConsumePartition key) { return consumePositionCache.remove(key); }  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();  }