001package org.xbib.elasticsearch.action.plugin.jdbc.run;
002
003import org.elasticsearch.action.ActionListener;
004import org.elasticsearch.action.support.nodes.NodesOperationRequestBuilder;
005import org.elasticsearch.client.ClusterAdminClient;
006
007public class RunRiverRequestBuilder extends NodesOperationRequestBuilder<RunRiverRequest, RunRiverResponse, RunRiverRequestBuilder> {
008
009    public RunRiverRequestBuilder(ClusterAdminClient client) {
010        super(client, new RunRiverRequest());
011    }
012
013    public RunRiverRequestBuilder setRiverType(String riverType) {
014        request.setRiverType(riverType);
015        return this;
016    }
017
018    public RunRiverRequestBuilder setRiverName(String riverName) {
019        request.setRiverName(riverName);
020        return this;
021    }
022
023    @Override
024    protected void doExecute(ActionListener<RunRiverResponse> listener) {
025        client.execute(RunRiverAction.INSTANCE, request, listener);
026    }
027}