Modifier and Type | Method and Description |
---|---|
RiverState |
GetRiverStateResponse.getRiverState() |
Modifier and Type | Method and Description |
---|---|
org.elasticsearch.common.collect.ImmutableList<RiverState> |
GetRiverStateResponse.getRiverStates() |
Constructor and Description |
---|
GetRiverStateResponse(org.elasticsearch.common.collect.ImmutableList<RiverState> riverStates) |
Modifier and Type | Method and Description |
---|---|
RiverState |
PostRiverStateRequest.getRiverState() |
Modifier and Type | Method and Description |
---|---|
PostRiverStateRequestBuilder |
PostRiverStateRequestBuilder.setRiverState(RiverState riverState) |
PostRiverStateRequest |
PostRiverStateRequest.setRiverState(RiverState riverState) |
Modifier and Type | Method and Description |
---|---|
RiverState |
PutRiverStateRequest.getRiverState() |
Modifier and Type | Method and Description |
---|---|
PutRiverStateRequestBuilder |
PutRiverStateRequestBuilder.setRiverState(RiverState riverState) |
PutRiverStateRequest |
PutRiverStateRequest.setRiverState(RiverState riverState) |
Modifier and Type | Method and Description |
---|---|
RiverState |
JDBCRiver.getRiverState() |
Modifier and Type | Method and Description |
---|---|
RiverState |
RiverState.fromXContent(org.elasticsearch.common.xcontent.XContentParser parser) |
RiverState |
StatefulRiver.getRiverState() |
RiverState |
RiverState.setCounter(Integer counter) |
RiverState |
RiverState.setCustom(Map<String,Object> custom) |
RiverState |
RiverState.setLastActive(org.elasticsearch.common.joda.time.DateTime begin,
org.elasticsearch.common.joda.time.DateTime end)
Set the last river activity.
|
RiverState |
RiverState.setMap(Map<String,Object> map) |
RiverState |
RiverState.setName(String name) |
RiverState |
RiverState.setStarted(org.elasticsearch.common.joda.time.DateTime started) |
RiverState |
RiverState.setType(String type) |
Modifier and Type | Method and Description |
---|---|
org.elasticsearch.common.collect.ImmutableList<RiverState> |
RiverStatesMetaData.getRiverStates()
Returns list of current river states
|
org.elasticsearch.common.collect.ImmutableList<RiverState> |
RiverStatesMetaData.getRiverStates(String name,
String type)
Returns a river state with a given name or null if such river doesn't exist
|
Modifier and Type | Method and Description |
---|---|
int |
RiverState.compareTo(RiverState o) |
Constructor and Description |
---|
RiverStateService.RiverStateRequest(String cause,
RiverState riverState)
Constructs new register river request
|
RiverStatesMetaData(RiverState... riverStates)
Constructs new river state metadata
|
Modifier and Type | Method and Description |
---|---|
RiverState |
RiverContext.getRiverState()
Get river state
|
Modifier and Type | Method and Description |
---|---|
RiverContext |
RiverContext.setRiverState(RiverState riverState)
Set river state
|
Modifier and Type | Method and Description |
---|---|
protected ColumnRiverContext |
ColumnRiverFlow.fillRiverContext(ColumnRiverContext riverContext,
RiverState state,
RiverSource riverSource,
RiverMouth riverMouth) |
Modifier and Type | Method and Description |
---|---|
RiverState |
SimpleRiverContext.getRiverState() |
Modifier and Type | Method and Description |
---|---|
protected RC |
SimpleRiverFlow.fillRiverContext(RC riverContext,
RiverState state,
RiverSource riverSource,
RiverMouth riverMouth) |
SimpleRiverContext |
SimpleRiverContext.setRiverState(RiverState riverState) |
elasticsearch-river-jdbc