RiversService

java.lang.Object
- org.elasticsearch.common.component.AbstractComponent
- - org.elasticsearch.common.component.AbstractLifecycleComponent<RiversService>
  - - org.elasticsearch.river.RiversService

All Implemented Interfaces:

AutoCloseable, LifecycleComponent<RiversService>, Releasable
```
public class RiversService
extends AbstractLifecycleComponent<RiversService>
```

Field Summary
- Fields inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent
  lifecycle
- Fields inherited from class org.elasticsearch.common.component.AbstractComponent
  componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
`RiversService(Settings settings, Client client, ThreadPool threadPool, ClusterService clusterService, RiversTypesRegistry typesRegistry, RiverClusterService riverClusterService, Injector injector)`

Method Summary

All Methods

Instance Methods

Concrete Methods
Modifier and Type	Method and Description
`void`	`closeRiver(RiverName riverName)`
`void`	`createRiver(RiverName riverName, Map<String,Object> settings)`
`protected void`	`doClose()`
`protected void`	`doStart()`
`protected void`	`doStop()`

Methods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent
addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop

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

RiversService

@Inject
public RiversService(Settings settings,
                             Client client,
                             ThreadPool threadPool,
                             ClusterService clusterService,
                             RiversTypesRegistry typesRegistry,
                             RiverClusterService riverClusterService,
                             Injector injector)

Method Detail

doStart
```
protected void doStart()
                throws ElasticsearchException
```
Specified by:

doStart in class AbstractLifecycleComponent<RiversService>

Throws:

ElasticsearchException

doStop
```
protected void doStop()
               throws ElasticsearchException
```
Specified by:

doStop in class AbstractLifecycleComponent<RiversService>

Throws:

ElasticsearchException

doClose
```
protected void doClose()
                throws ElasticsearchException
```
Specified by:

doClose in class AbstractLifecycleComponent<RiversService>

Throws:

ElasticsearchException

createRiver

public void createRiver(RiverName riverName,
                        Map<String,Object> settings)
                 throws ElasticsearchException

Throws:: ElasticsearchException

closeRiver

public void closeRiver(RiverName riverName)
                throws ElasticsearchException

Throws:: ElasticsearchException

Class RiversService

Field Summary

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

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

Constructor Summary

Constructors

Method Summary

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

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

Methods inherited from class java.lang.Object

Constructor Detail

RiversService

Method Detail

doStart

doStop

doClose

createRiver

closeRiver