DatasetAffinityFunctionWrapper implements AffinityFunction { @Override public int partitions() { return delegate.partitions(); } 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);  }
@Test public void testPartitions() { doReturn(42).when(affinityFunction).partitions(); int partitions = wrapper.partitions(); assertEquals(42, partitions); verify(affinityFunction, times(1)).partitions(); }