org.apache.streams.elasticsearch

Class ElasticsearchReaderConfiguration

java.lang.Object

org.apache.streams.elasticsearch.ElasticsearchConfiguration

org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration

All Implemented Interfaces:

Serializable

@Generated(value="org.jsonschema2pojo")
public class ElasticsearchReaderConfiguration
extends ElasticsearchConfiguration
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ElasticsearchReaderConfiguration()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object other)
Map<String,Object>	getAdditionalProperties()
List<String>	getIndexes() Indexes to read from
String	getScrollTimeout() Scroll Timeout (JodaTime)
Map	getSearch() Search definition
List<String>	getTypes() Types to read from
int	hashCode()
void	setAdditionalProperty(String name, Object value)
void	setIndexes(List<String> indexes) Indexes to read from
void	setScrollTimeout(String scrollTimeout) Scroll Timeout (JodaTime)
void	setSearch(Map Search) Search definition
void	setTypes(List<String> types) Types to read from
String	toString()
ElasticsearchReaderConfiguration	withAdditionalProperty(String name, Object value)
ElasticsearchReaderConfiguration	withIndexes(List<String> indexes)
ElasticsearchReaderConfiguration	withScrollTimeout(String scrollTimeout)
ElasticsearchReaderConfiguration	withSearch(Map Search)
ElasticsearchReaderConfiguration	withTypes(List<String> types)

Methods inherited from class org.apache.streams.elasticsearch.ElasticsearchConfiguration

getClusterName, getHosts, getPort, setClusterName, setHosts, setPort, withClusterName, withHosts, withPort

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ElasticsearchReaderConfiguration

public ElasticsearchReaderConfiguration()

Method Detail

getIndexes

@BeanProperty(value="indexes")
public List<String> getIndexes()

Indexes to read from

Returns:

The indexes

setIndexes

@BeanProperty(value="indexes")
public void setIndexes(List<String> indexes)

Indexes to read from

Parameters:

indexes - The indexes

withIndexes

public ElasticsearchReaderConfiguration withIndexes(List<String> indexes)

getTypes

@BeanProperty(value="types")
public List<String> getTypes()

Types to read from

Returns:

The types

setTypes

@BeanProperty(value="types")
public void setTypes(List<String> types)

Types to read from

Parameters:

types - The types

withTypes

public ElasticsearchReaderConfiguration withTypes(List<String> types)

getScrollTimeout

@BeanProperty(value="scrollTimeout")
public String getScrollTimeout()

Scroll Timeout (JodaTime)

Returns:

The scrollTimeout

setScrollTimeout

@BeanProperty(value="scrollTimeout")
public void setScrollTimeout(String scrollTimeout)

Scroll Timeout (JodaTime)

Parameters:

scrollTimeout - The scrollTimeout

withScrollTimeout

public ElasticsearchReaderConfiguration withScrollTimeout(String scrollTimeout)

getSearch

@BeanProperty(value="_search")
public Map getSearch()

Search definition

Returns:

The Search

setSearch

@BeanProperty(value="_search")
public void setSearch(Map Search)

Search definition

Parameters:

Search - The _search

withSearch

public ElasticsearchReaderConfiguration withSearch(Map Search)

toString

public String toString()

Overrides:

toString in class ElasticsearchConfiguration

getAdditionalProperties

@BeanProperty(name="*")
public Map<String,Object> getAdditionalProperties()

Overrides:

getAdditionalProperties in class ElasticsearchConfiguration

setAdditionalProperty

@BeanProperty(name="*")
public void setAdditionalProperty(String name,
                                                          Object value)

Overrides:

setAdditionalProperty in class ElasticsearchConfiguration

withAdditionalProperty

public ElasticsearchReaderConfiguration withAdditionalProperty(String name,
                                                               Object value)

Overrides:

withAdditionalProperty in class ElasticsearchConfiguration

hashCode

public int hashCode()

Overrides:

hashCode in class ElasticsearchConfiguration

equals

public boolean equals(Object other)

Overrides:

equals in class ElasticsearchConfiguration