@Test
public void testEmbulkPartitioningMapperReducer()
        throws Exception
{

    new File("tmp/embulk_mapred_partitioning_output.000.00.csv").delete();
    new File("tmp/embulk_mapred_partitioning_output.001.00.csv").delete();
    ConfigSource config = loadConfigSource(configLoader, "config/embulk_mapred_partitioning_config.yml")
            .merge(configLoader.newConfigSource().set("exec", ImmutableMap.of("type", getPluginName())));
    embulk.run(config);
    assertFileContent(
            Lists.newArrayList(
                    RESOURCES_PATH + "fixtures/csv/sample1.csv",
                    RESOURCES_PATH + "fixtures/csv/sample1.csv"),
            Lists.newArrayList(
                    "tmp/embulk_mapred_partitioning_output.000.00.csv",
                    "tmp/embulk_mapred_partitioning_output.001.00.csv"));
}