@Test public void testReset() { wrapper.reset(); verify(affinityFunction, times(1)).reset(); }
@Override public void reset() { delegate.reset(); }
DatasetAffinityFunctionWrapper implements AffinityFunction { @Override public void reset() { delegate.reset(); } }
DatasetAffinityFunctionWrapper implements AffinityFunction { @Override public void reset() { delegate.reset(); } DatasetAffinityFunctionWrapper(AffinityFunction delegate); }
DatasetAffinityFunctionWrapper implements AffinityFunction { @Override public void reset() { delegate.reset(); } DatasetAffinityFunctionWrapper(AffinityFunction delegate); @Override void reset(); @Override int partitions(); @Override int partition(Object key); @Override List<List<ClusterNode>> assignPartitions(AffinityFunctionContext affCtx); @Override void removeNode(UUID nodeId); }
DatasetAffinityFunctionWrapper implements AffinityFunction { @Override public void reset() { delegate.reset(); } DatasetAffinityFunctionWrapper(AffinityFunction delegate); @Override void reset(); @Override int partitions(); @Override int partition(Object key); @Override List<List<ClusterNode>> assignPartitions(AffinityFunctionContext affCtx); @Override void removeNode(UUID nodeId);  }