@@ -0,0 +1,1384 @@
+package org.codelibs.elasticsearch.util.river;%0A%0Aimport org.codelibs.elasticsearch.util.exception.EsUtilSystemException;%0Aimport org.elasticsearch.ElasticsearchException;%0Aimport org.elasticsearch.action.admin.indices.mapping.delete.DeleteMappingResponse;%0Aimport org.elasticsearch.client.Client;%0Aimport org.elasticsearch.river.RiverName;%0A%0Apublic final class RiverUtils %7B%0A%0A    private RiverUtils() %7B%0A    %7D%0A%0A    public static void deleteQuietly(final Client client,%0A            final RiverName riverName) %7B%0A        try %7B%0A            delete(client, riverName);%0A        %7D catch (final EsUtilSystemException e) %7B%0A            // ignore%0A        %7D%0A    %7D%0A%0A    public static void delete(final Client client, final RiverName riverName) %7B%0A        DeleteMappingResponse deleteMappingResponse;%0A        try %7B%0A            deleteMappingResponse = client.admin().indices()%0A                    .prepareDeleteMapping(%22_river%22).setType(riverName.name())%0A                    .execute().actionGet();%0A        %7D catch (final ElasticsearchException e) %7B%0A            throw new EsUtilSystemException(%22Failed to delete %22%0A                    + riverName.name(), e);%0A        %7D%0A        if (!deleteMappingResponse.isAcknowledged()) %7B%0A            throw new EsUtilSystemException(%22Failed to delete %22%0A                    + riverName.name() + %22. %22%0A                    + deleteMappingResponse.toString());%0A        %7D%0A    %7D%0A%0A%7D%0A

add RiverUtils