org.apache.beam.sdk.io.elasticsearch

Class ElasticsearchIO.ConnectionConfiguration

java.lang.Object

org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO.ConnectionConfiguration

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

ElasticsearchIO

public abstract static class ElasticsearchIO.ConnectionConfiguration
extends java.lang.Object
implements java.io.Serializable

A POJO describing a connection configuration to Elasticsearch.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ConnectionConfiguration()

Method Summary

Modifier and Type	Method and Description
static ElasticsearchIO.ConnectionConfiguration	create(java.lang.String[] addresses, java.lang.String index, java.lang.String type) Creates a new Elasticsearch connection configuration.
ElasticsearchIO.ConnectionConfiguration	withPassword(java.lang.String password) If Elasticsearch authentication is enabled, provide the password.
ElasticsearchIO.ConnectionConfiguration	withUsername(java.lang.String username) If Elasticsearch authentication is enabled, provide the username.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionConfiguration

public ConnectionConfiguration()

Method Detail

create

public static ElasticsearchIO.ConnectionConfiguration create(java.lang.String[] addresses,
                                                             java.lang.String index,
                                                             java.lang.String type)
                                                      throws java.io.IOException

Creates a new Elasticsearch connection configuration.

Parameters:

addresses - list of addresses of Elasticsearch nodes

index - the index toward which the requests will be issued

type - the document type toward which the requests will be issued

Returns:

the connection configuration object

Throws:

java.io.IOException - when it fails to connect to Elasticsearch

withUsername

public ElasticsearchIO.ConnectionConfiguration withUsername(java.lang.String username)

If Elasticsearch authentication is enabled, provide the username.

Parameters:

username - the username used to authenticate to Elasticsearch

Returns:

the ElasticsearchIO.ConnectionConfiguration object with username set

withPassword

public ElasticsearchIO.ConnectionConfiguration withPassword(java.lang.String password)

If Elasticsearch authentication is enabled, provide the password.

Parameters:

password - the password used to authenticate to Elasticsearch

Returns:

the ElasticsearchIO.ConnectionConfiguration object with password set