DatasetAffinityFunctionWrapper implements AffinityFunction { @Override public void removeNode(UUID nodeId) { delegate.removeNode(nodeId); } 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 testRemoveNode() { UUID nodeId = UUID.randomUUID(); wrapper.removeNode(nodeId); verify(affinityFunction, times(1)).removeNode(eq(nodeId)); }