org.apache.streams.elasticsearch

Class ElasticsearchWriterConfiguration

java.lang.Object

org.apache.streams.elasticsearch.ElasticsearchConfiguration

org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

All Implemented Interfaces:

Serializable

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ElasticsearchWriterConfiguration()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object other)
Map<String,Object>	getAdditionalProperties()
Long	getBatchBytes() Number of bytes before flush
Long	getBatchSize() Item Count before flush
Boolean	getBulk() Index in large or small batches
Boolean	getCleanupTags() Whether to remove _percolator rules on shutdown
Boolean	getForceUseConfig() Whether or not we force the values that are set in the configuration
String	getIndex() Index to write to
Long	getMaxTimeBetweenFlushMs()
Boolean	getRefresh() Whether to refresh during cleanup
Boolean	getReplaceTags() Whether to overwrite _percolator rules on startup
String	getScript() Script to execute during index
Tags	getTags() Tags to apply during index
String	getType() Type to write as
int	hashCode()
void	setAdditionalProperty(String name, Object value)
void	setBatchBytes(Long batchBytes) Number of bytes before flush
void	setBatchSize(Long batchSize) Item Count before flush
void	setBulk(Boolean bulk) Index in large or small batches
void	setCleanupTags(Boolean cleanupTags) Whether to remove _percolator rules on shutdown
void	setForceUseConfig(Boolean forceUseConfig) Whether or not we force the values that are set in the configuration
void	setIndex(String index) Index to write to
void	setMaxTimeBetweenFlushMs(Long maxTimeBetweenFlushMs)
void	setRefresh(Boolean refresh) Whether to refresh during cleanup
void	setReplaceTags(Boolean replaceTags) Whether to overwrite _percolator rules on startup
void	setScript(String script) Script to execute during index
void	setTags(Tags tags) Tags to apply during index
void	setType(String type) Type to write as
String	toString()
ElasticsearchWriterConfiguration	withAdditionalProperty(String name, Object value)
ElasticsearchWriterConfiguration	withBatchBytes(Long batchBytes)
ElasticsearchWriterConfiguration	withBatchSize(Long batchSize)
ElasticsearchWriterConfiguration	withBulk(Boolean bulk)
ElasticsearchWriterConfiguration	withCleanupTags(Boolean cleanupTags)
ElasticsearchWriterConfiguration	withForceUseConfig(Boolean forceUseConfig)
ElasticsearchWriterConfiguration	withIndex(String index)
ElasticsearchWriterConfiguration	withMaxTimeBetweenFlushMs(Long maxTimeBetweenFlushMs)
ElasticsearchWriterConfiguration	withRefresh(Boolean refresh)
ElasticsearchWriterConfiguration	withReplaceTags(Boolean replaceTags)
ElasticsearchWriterConfiguration	withScript(String script)
ElasticsearchWriterConfiguration	withTags(Tags tags)
ElasticsearchWriterConfiguration	withType(String type)

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

ElasticsearchWriterConfiguration

public ElasticsearchWriterConfiguration()

Method Detail

getIndex

@BeanProperty(value="index")
public String getIndex()

Index to write to

Returns:

The index

setIndex

@BeanProperty(value="index")
public void setIndex(String index)

Index to write to

Parameters:

index - The index

withIndex

public ElasticsearchWriterConfiguration withIndex(String index)

getType

@BeanProperty(value="type")
public String getType()

Type to write as

Returns:

The type

setType

@BeanProperty(value="type")
public void setType(String type)

Type to write as

Parameters:

type - The type

withType

public ElasticsearchWriterConfiguration withType(String type)

getBulk

@BeanProperty(value="bulk")
public Boolean getBulk()

Index in large or small batches

Returns:

The bulk

setBulk

@BeanProperty(value="bulk")
public void setBulk(Boolean bulk)

Index in large or small batches

Parameters:

bulk - The bulk

withBulk

public ElasticsearchWriterConfiguration withBulk(Boolean bulk)

getBatchSize

@BeanProperty(value="batchSize")
public Long getBatchSize()

Item Count before flush

Returns:

The batchSize

setBatchSize

@BeanProperty(value="batchSize")
public void setBatchSize(Long batchSize)

Item Count before flush

Parameters:

batchSize - The batchSize

withBatchSize

public ElasticsearchWriterConfiguration withBatchSize(Long batchSize)

getBatchBytes

@BeanProperty(value="batchBytes")
public Long getBatchBytes()

Number of bytes before flush

Returns:

The batchBytes

setBatchBytes

@BeanProperty(value="batchBytes")
public void setBatchBytes(Long batchBytes)

Number of bytes before flush

Parameters:

batchBytes - The batchBytes

withBatchBytes

public ElasticsearchWriterConfiguration withBatchBytes(Long batchBytes)

getMaxTimeBetweenFlushMs

@BeanProperty(value="maxTimeBetweenFlushMs")
public Long getMaxTimeBetweenFlushMs()

Returns:

The maxTimeBetweenFlushMs

setMaxTimeBetweenFlushMs

@BeanProperty(value="maxTimeBetweenFlushMs")
public void setMaxTimeBetweenFlushMs(Long maxTimeBetweenFlushMs)

Parameters:

maxTimeBetweenFlushMs - The maxTimeBetweenFlushMs

withMaxTimeBetweenFlushMs

public ElasticsearchWriterConfiguration withMaxTimeBetweenFlushMs(Long maxTimeBetweenFlushMs)

getScript

@BeanProperty(value="script")
public String getScript()

Script to execute during index

Returns:

The script

setScript

@BeanProperty(value="script")
public void setScript(String script)

Script to execute during index

Parameters:

script - The script

withScript

public ElasticsearchWriterConfiguration withScript(String script)

getTags

@BeanProperty(value="tags")
public Tags getTags()

Tags to apply during index

Returns:

The tags

setTags

@BeanProperty(value="tags")
public void setTags(Tags tags)

Tags to apply during index

Parameters:

tags - The tags

withTags

public ElasticsearchWriterConfiguration withTags(Tags tags)

getReplaceTags

@BeanProperty(value="replaceTags")
public Boolean getReplaceTags()

Whether to overwrite _percolator rules on startup

Returns:

The replaceTags

setReplaceTags

@BeanProperty(value="replaceTags")
public void setReplaceTags(Boolean replaceTags)

Whether to overwrite _percolator rules on startup

Parameters:

replaceTags - The replaceTags

withReplaceTags

public ElasticsearchWriterConfiguration withReplaceTags(Boolean replaceTags)

getCleanupTags

@BeanProperty(value="cleanupTags")
public Boolean getCleanupTags()

Whether to remove _percolator rules on shutdown

Returns:

The cleanupTags

setCleanupTags

@BeanProperty(value="cleanupTags")
public void setCleanupTags(Boolean cleanupTags)

Whether to remove _percolator rules on shutdown

Parameters:

cleanupTags - The cleanupTags

withCleanupTags

public ElasticsearchWriterConfiguration withCleanupTags(Boolean cleanupTags)

getForceUseConfig

@BeanProperty(value="forceUseConfig")
public Boolean getForceUseConfig()

Whether or not we force the values that are set in the configuration

Returns:

The forceUseConfig

setForceUseConfig

@BeanProperty(value="forceUseConfig")
public void setForceUseConfig(Boolean forceUseConfig)

Whether or not we force the values that are set in the configuration

Parameters:

forceUseConfig - The forceUseConfig

withForceUseConfig

public ElasticsearchWriterConfiguration withForceUseConfig(Boolean forceUseConfig)

getRefresh

@BeanProperty(value="refresh")
public Boolean getRefresh()

Whether to refresh during cleanup

Returns:

The refresh

setRefresh

@BeanProperty(value="refresh")
public void setRefresh(Boolean refresh)

Whether to refresh during cleanup

Parameters:

refresh - The refresh

withRefresh

public ElasticsearchWriterConfiguration withRefresh(Boolean refresh)

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 ElasticsearchWriterConfiguration 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