org.xbib.elasticsearch.action.plugin.jdbc.run

Class TransportRunRiverAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.action.support.TransportAction<Request,Response>

org.elasticsearch.action.support.nodes.TransportNodesOperationAction<RunRiverRequest,RunRiverResponse,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteRequest,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteResponse>

org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction

public class TransportRunRiverAction
extends org.elasticsearch.action.support.nodes.TransportNodesOperationAction<RunRiverRequest,RunRiverResponse,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteRequest,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteResponse>

Field Summary

Fields inherited from class org.elasticsearch.action.support.nodes.TransportNodesOperationAction

clusterName, clusterService, transportService

Fields inherited from class org.elasticsearch.action.support.TransportAction

actionName, threadPool

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
TransportRunRiverAction(org.elasticsearch.common.settings.Settings settings, org.elasticsearch.cluster.ClusterName clusterName, org.elasticsearch.threadpool.ThreadPool threadPool, org.elasticsearch.cluster.ClusterService clusterService, org.elasticsearch.transport.TransportService transportService, org.elasticsearch.common.inject.Injector injector)

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	accumulateExceptions()
protected String	executor()
protected org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteRequest	newNodeRequest()
protected org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteRequest	newNodeRequest(String nodeId, RunRiverRequest request)
protected org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteResponse	newNodeResponse()
protected RunRiverRequest	newRequest()
protected RunRiverResponse	newResponse(RunRiverRequest request, AtomicReferenceArray nodesResponses)
protected org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteResponse	nodeOperation(org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteRequest request)
static org.elasticsearch.common.collect.ImmutableMap<org.elasticsearch.river.RiverName,org.elasticsearch.river.River>	rivers(org.elasticsearch.river.RiversService riversService)

Methods inherited from class org.elasticsearch.action.support.nodes.TransportNodesOperationAction

doExecute, filterNodeIds, transportCompress

Methods inherited from class org.elasticsearch.action.support.TransportAction

execute, execute

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TransportRunRiverAction

@Inject
public TransportRunRiverAction(org.elasticsearch.common.settings.Settings settings,
                              org.elasticsearch.cluster.ClusterName clusterName,
                              org.elasticsearch.threadpool.ThreadPool threadPool,
                              org.elasticsearch.cluster.ClusterService clusterService,
                              org.elasticsearch.transport.TransportService transportService,
                              org.elasticsearch.common.inject.Injector injector)

Method Detail

executor

protected String executor()

Specified by:

executor in class org.elasticsearch.action.support.nodes.TransportNodesOperationAction<RunRiverRequest,RunRiverResponse,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteRequest,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteResponse>

nodeOperation

protected org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteResponse nodeOperation(org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteRequest request)
                                                                                                                throws org.elasticsearch.ElasticsearchException

Specified by:

nodeOperation in class org.elasticsearch.action.support.nodes.TransportNodesOperationAction<RunRiverRequest,RunRiverResponse,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteRequest,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteResponse>

Throws:

org.elasticsearch.ElasticsearchException

newRequest

protected RunRiverRequest newRequest()

Specified by:

newRequest in class org.elasticsearch.action.support.nodes.TransportNodesOperationAction<RunRiverRequest,RunRiverResponse,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteRequest,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteResponse>

newResponse

protected RunRiverResponse newResponse(RunRiverRequest request,
                           AtomicReferenceArray nodesResponses)

Specified by:

newResponse in class org.elasticsearch.action.support.nodes.TransportNodesOperationAction<RunRiverRequest,RunRiverResponse,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteRequest,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteResponse>

newNodeRequest

protected org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteRequest newNodeRequest()

Specified by:

newNodeRequest in class org.elasticsearch.action.support.nodes.TransportNodesOperationAction<RunRiverRequest,RunRiverResponse,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteRequest,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteResponse>

newNodeRequest

protected org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteRequest newNodeRequest(String nodeId,
                                                                                                           RunRiverRequest request)

Specified by:

newNodeRequest in class org.elasticsearch.action.support.nodes.TransportNodesOperationAction<RunRiverRequest,RunRiverResponse,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteRequest,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteResponse>

newNodeResponse

protected org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteResponse newNodeResponse()

Specified by:

newNodeResponse in class org.elasticsearch.action.support.nodes.TransportNodesOperationAction<RunRiverRequest,RunRiverResponse,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteRequest,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteResponse>

accumulateExceptions

protected boolean accumulateExceptions()

Specified by:

accumulateExceptions in class org.elasticsearch.action.support.nodes.TransportNodesOperationAction<RunRiverRequest,RunRiverResponse,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteRequest,org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction.NodeRiverExecuteResponse>

rivers

public static org.elasticsearch.common.collect.ImmutableMap<org.elasticsearch.river.RiverName,org.elasticsearch.river.River> rivers(org.elasticsearch.river.RiversService riversService)