@Override
    public Operation createPartitionOperation(int partitionId) {
        for (int i = 0; i < partitions.length; i++) {
            if (partitions[i] == partitionId) {
                return new PutAllOperation(name, mapEntries[i], triggerMapLoader);
            }
        }
        throw new IllegalArgumentException("Unknown partitionId " + partitionId + " (" + Arrays.toString(partitions) + ")");
    }
@Test(expected = IllegalArgumentException.class)
    public void testCreatePartitionOperation() {
        factory.createPartitionOperation(0);
    }