org.apache.flink.streaming.connectors.elasticsearch2

Class Elasticsearch2ApiCallBridge

java.lang.Object

org.apache.flink.streaming.connectors.elasticsearch2.Elasticsearch2ApiCallBridge

All Implemented Interfaces:

Serializable, ElasticsearchApiCallBridge<org.elasticsearch.client.transport.TransportClient>

@Internal
public class Elasticsearch2ApiCallBridge
extends Object
implements ElasticsearchApiCallBridge<org.elasticsearch.client.transport.TransportClient>

Implementation of ElasticsearchApiCallBridge for Elasticsearch 2.x.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
void	configureBulkProcessorBackoff(org.elasticsearch.action.bulk.BulkProcessor.Builder builder, ElasticsearchSinkBase.BulkFlushBackoffPolicy flushBackoffPolicy) Set backoff-related configurations on the provided BulkProcessor.Builder.
org.elasticsearch.action.bulk.BulkProcessor.Builder	createBulkProcessorBuilder(org.elasticsearch.client.transport.TransportClient client, org.elasticsearch.action.bulk.BulkProcessor.Listener listener) Creates a BulkProcessor.Builder for creating the bulk processor.
org.elasticsearch.client.transport.TransportClient	createClient(Map<String,String> clientConfig) Creates an Elasticsearch client implementing AutoCloseable.
Throwable	extractFailureCauseFromBulkItemResponse(org.elasticsearch.action.bulk.BulkItemResponse bulkItemResponse) Extracts the cause of failure of a bulk item action.
void	verifyClientConnection(org.elasticsearch.client.transport.TransportClient client) Verify the client connection by making a test request/ping to the Elasticsearch cluster.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchApiCallBridge

cleanup, createBulkProcessorIndexer

Method Detail

createClient

public org.elasticsearch.client.transport.TransportClient createClient(Map<String,String> clientConfig)

Description copied from interface: ElasticsearchApiCallBridge

Creates an Elasticsearch client implementing AutoCloseable.

Specified by:

createClient in interface ElasticsearchApiCallBridge<org.elasticsearch.client.transport.TransportClient>

Parameters:

clientConfig - The configuration to use when constructing the client.

Returns:

The created client.

createBulkProcessorBuilder

public org.elasticsearch.action.bulk.BulkProcessor.Builder createBulkProcessorBuilder(org.elasticsearch.client.transport.TransportClient client,
                                                                                      org.elasticsearch.action.bulk.BulkProcessor.Listener listener)

Description copied from interface: ElasticsearchApiCallBridge

Creates a BulkProcessor.Builder for creating the bulk processor.

Specified by:

createBulkProcessorBuilder in interface ElasticsearchApiCallBridge<org.elasticsearch.client.transport.TransportClient>

Parameters:

client - the Elasticsearch client.

listener - the bulk processor listender.

Returns:

the bulk processor builder.

extractFailureCauseFromBulkItemResponse

public Throwable extractFailureCauseFromBulkItemResponse(org.elasticsearch.action.bulk.BulkItemResponse bulkItemResponse)

Description copied from interface: ElasticsearchApiCallBridge

Extracts the cause of failure of a bulk item action.

Specified by:

extractFailureCauseFromBulkItemResponse in interface ElasticsearchApiCallBridge<org.elasticsearch.client.transport.TransportClient>

Parameters:

bulkItemResponse - the bulk item response to extract cause of failure

Returns:

the extracted Throwable from the response (null is the response is successful).

configureBulkProcessorBackoff

public void configureBulkProcessorBackoff(org.elasticsearch.action.bulk.BulkProcessor.Builder builder,
                                          @Nullable
                                          ElasticsearchSinkBase.BulkFlushBackoffPolicy flushBackoffPolicy)

Description copied from interface: ElasticsearchApiCallBridge

Set backoff-related configurations on the provided BulkProcessor.Builder. The builder will be later on used to instantiate the actual BulkProcessor.

Specified by:

configureBulkProcessorBackoff in interface ElasticsearchApiCallBridge<org.elasticsearch.client.transport.TransportClient>

Parameters:

builder - the BulkProcessor.Builder to configure.

flushBackoffPolicy - user-provided backoff retry settings (null if the user disabled backoff retries).

verifyClientConnection

public void verifyClientConnection(org.elasticsearch.client.transport.TransportClient client)

Description copied from interface: ElasticsearchApiCallBridge

Verify the client connection by making a test request/ping to the Elasticsearch cluster.

Called by ElasticsearchSinkBase.open(org.apache.flink.configuration.Configuration) after creating the client. This makes sure the underlying client is closed if the connection is not successful and preventing thread leak.

Specified by:

verifyClientConnection in interface ElasticsearchApiCallBridge<org.elasticsearch.client.transport.TransportClient>

Parameters:

client - the Elasticsearch client.