org.xbib.elasticsearch.plugin.jdbc.state

Class RiverState

java.lang.Object

org.xbib.elasticsearch.plugin.jdbc.state.RiverState

All Implemented Interfaces:

Comparable<RiverState>, org.elasticsearch.common.io.stream.Streamable, org.elasticsearch.common.xcontent.ToXContent

public class RiverState
extends Object
implements org.elasticsearch.common.io.stream.Streamable, org.elasticsearch.common.xcontent.ToXContent, Comparable<RiverState>

A river state represents a point in time when a river has a defined behavior with a set of parameters

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.common.xcontent.ToXContent

org.elasticsearch.common.xcontent.ToXContent.DelegatingMapParams, org.elasticsearch.common.xcontent.ToXContent.MapParams, org.elasticsearch.common.xcontent.ToXContent.Params

Field Summary

Fields inherited from interface org.elasticsearch.common.xcontent.ToXContent

EMPTY_PARAMS

Constructor Summary

Constructors

Constructor and Description
RiverState()

Method Summary

Methods

Modifier and Type	Method and Description
int	compareTo(RiverState o)
RiverState	fromXContent(org.elasticsearch.common.xcontent.XContentParser parser)
Integer	getCounter()
Map<String,Object>	getCustom()
org.elasticsearch.common.joda.time.DateTime	getLastActiveBegin()
org.elasticsearch.common.joda.time.DateTime	getLastActiveEnd()
Map<String,Object>	getMap()
String	getName()
org.elasticsearch.common.joda.time.DateTime	getStarted()
String	getType()
boolean	isAborted()
boolean	isSuspended()
void	readFrom(org.elasticsearch.common.io.stream.StreamInput in)
RiverState	setCounter(Integer counter)
RiverState	setCustom(Map<String,Object> custom)
RiverState	setLastActive(org.elasticsearch.common.joda.time.DateTime begin, org.elasticsearch.common.joda.time.DateTime end) Set the last river activity.
RiverState	setMap(Map<String,Object> map)
RiverState	setName(String name)
RiverState	setStarted(org.elasticsearch.common.joda.time.DateTime started)
RiverState	setType(String type)
String	toString()
org.elasticsearch.common.xcontent.XContentBuilder	toXContent(org.elasticsearch.common.xcontent.XContentBuilder builder, org.elasticsearch.common.xcontent.ToXContent.Params params)
boolean	wasActiveAt(org.elasticsearch.common.joda.time.DateTime instant) Was the river active at a certain time? Only the last activity can be checked.
boolean	wasInactiveAt(org.elasticsearch.common.joda.time.DateTime instant)
void	writeTo(org.elasticsearch.common.io.stream.StreamOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

RiverState

public RiverState()

Method Detail

setName

public RiverState setName(String name)

getName

public String getName()

setType

public RiverState setType(String type)

getType

public String getType()

setMap

public RiverState setMap(Map<String,Object> map)

getMap

public Map<String,Object> getMap()

setStarted

public RiverState setStarted(org.elasticsearch.common.joda.time.DateTime started)

getStarted

public org.elasticsearch.common.joda.time.DateTime getStarted()

setLastActive

public RiverState setLastActive(org.elasticsearch.common.joda.time.DateTime begin,
                       org.elasticsearch.common.joda.time.DateTime end)

Set the last river activity. Null means, time is unknown

Parameters:

begin - when the last river activity began

end - when the last river activity ended

Returns:

this state

getLastActiveBegin

public org.elasticsearch.common.joda.time.DateTime getLastActiveBegin()

Returns:

the begin of the last river activity

getLastActiveEnd

public org.elasticsearch.common.joda.time.DateTime getLastActiveEnd()

Returns:

the end of the last river activity

wasActiveAt

public boolean wasActiveAt(org.elasticsearch.common.joda.time.DateTime instant)

Was the river active at a certain time? Only the last activity can be checked.

Parameters:

instant - the time to check

Returns:

true if river was active, false if not

wasInactiveAt

public boolean wasInactiveAt(org.elasticsearch.common.joda.time.DateTime instant)

setCounter

public RiverState setCounter(Integer counter)

getCounter

public Integer getCounter()

setCustom

public RiverState setCustom(Map<String,Object> custom)

getCustom

public Map<String,Object> getCustom()

isAborted

public boolean isAborted()

isSuspended

public boolean isSuspended()

fromXContent

public RiverState fromXContent(org.elasticsearch.common.xcontent.XContentParser parser)
                        throws IOException

Throws:

IOException

toXContent

public org.elasticsearch.common.xcontent.XContentBuilder toXContent(org.elasticsearch.common.xcontent.XContentBuilder builder,
                                                           org.elasticsearch.common.xcontent.ToXContent.Params params)
                                                             throws IOException

Specified by:

toXContent in interface org.elasticsearch.common.xcontent.ToXContent

Throws:

IOException

readFrom

public void readFrom(org.elasticsearch.common.io.stream.StreamInput in)
              throws IOException

Specified by:

readFrom in interface org.elasticsearch.common.io.stream.Streamable

Throws:

IOException

writeTo

public void writeTo(org.elasticsearch.common.io.stream.StreamOutput out)
             throws IOException

Specified by:

writeTo in interface org.elasticsearch.common.io.stream.Streamable

Throws:

IOException

compareTo

public int compareTo(RiverState o)

Specified by:

compareTo in interface Comparable<RiverState>

toString

public String toString()

Overrides:

toString in class Object