ElasticsearchValidator (flink 1.11-SNAPSHOT API)

java.lang.Object
- org.apache.flink.table.descriptors.ConnectorDescriptorValidator
- - org.apache.flink.table.descriptors.ElasticsearchValidator

All Implemented Interfaces:: DescriptorValidator

@Internal
public class ElasticsearchValidator
extends ConnectorDescriptorValidator

The validator for Elasticsearch.

Field Summary

Fields
Modifier and Type	Field and Description
`static String`	`CONNECTOR_BULK_FLUSH_BACKOFF_DELAY`
`static String`	`CONNECTOR_BULK_FLUSH_BACKOFF_MAX_RETRIES`
`static String`	`CONNECTOR_BULK_FLUSH_BACKOFF_TYPE`
`static String`	`CONNECTOR_BULK_FLUSH_BACKOFF_TYPE_VALUE_CONSTANT`
`static String`	`CONNECTOR_BULK_FLUSH_BACKOFF_TYPE_VALUE_DISABLED`
`static String`	`CONNECTOR_BULK_FLUSH_BACKOFF_TYPE_VALUE_EXPONENTIAL`
`static String`	`CONNECTOR_BULK_FLUSH_INTERVAL`
`static String`	`CONNECTOR_BULK_FLUSH_MAX_ACTIONS`
`static String`	`CONNECTOR_BULK_FLUSH_MAX_SIZE`
`static String`	`CONNECTOR_CONNECTION_MAX_RETRY_TIMEOUT`
`static String`	`CONNECTOR_CONNECTION_PATH_PREFIX`
`static String`	`CONNECTOR_DOCUMENT_TYPE`
`static String`	`CONNECTOR_FAILURE_HANDLER`
`static String`	`CONNECTOR_FAILURE_HANDLER_CLASS`
`static String`	`CONNECTOR_FAILURE_HANDLER_VALUE_CUSTOM`
`static String`	`CONNECTOR_FAILURE_HANDLER_VALUE_FAIL`
`static String`	`CONNECTOR_FAILURE_HANDLER_VALUE_IGNORE`
`static String`	`CONNECTOR_FAILURE_HANDLER_VALUE_RETRY`
`static String`	`CONNECTOR_FLUSH_ON_CHECKPOINT`
`static String`	`CONNECTOR_HOSTS`
`static String`	`CONNECTOR_HOSTS_HOSTNAME`
`static String`	`CONNECTOR_HOSTS_PORT`
`static String`	`CONNECTOR_HOSTS_PROTOCOL`
`static String`	`CONNECTOR_INDEX`
`static String`	`CONNECTOR_KEY_DELIMITER`
`static String`	`CONNECTOR_KEY_NULL_LITERAL`
`static String`	`CONNECTOR_TYPE_VALUE_ELASTICSEARCH`
`static String`	`CONNECTOR_VERSION_VALUE_6`
`static String`	`CONNECTOR_VERSION_VALUE_7`

Fields inherited from class org.apache.flink.table.descriptors.ConnectorDescriptorValidator
CONNECTOR, CONNECTOR_PROPERTY_VERSION, CONNECTOR_TYPE, CONNECTOR_VERSION

Constructor Summary

Constructors
Constructor and Description

ElasticsearchValidator()

Constructors
Constructor and Description
`ElasticsearchValidator()`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`validate(DescriptorProperties properties)` Performs basic validation such as completeness tests.
`static List<ElasticsearchUpsertTableSinkBase.Host>`	`validateAndParseHostsString(DescriptorProperties descriptorProperties)` Parse Hosts String to list.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - CONNECTOR_TYPE_VALUE_ELASTICSEARCH
```
public static final String CONNECTOR_TYPE_VALUE_ELASTICSEARCH
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_VERSION_VALUE_6
```
public static final String CONNECTOR_VERSION_VALUE_6
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_VERSION_VALUE_7
```
public static final String CONNECTOR_VERSION_VALUE_7
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_HOSTS
```
public static final String CONNECTOR_HOSTS
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_HOSTS_HOSTNAME
```
public static final String CONNECTOR_HOSTS_HOSTNAME
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_HOSTS_PORT
```
public static final String CONNECTOR_HOSTS_PORT
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_HOSTS_PROTOCOL
```
public static final String CONNECTOR_HOSTS_PROTOCOL
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_INDEX
```
public static final String CONNECTOR_INDEX
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_DOCUMENT_TYPE
```
public static final String CONNECTOR_DOCUMENT_TYPE
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_KEY_DELIMITER
```
public static final String CONNECTOR_KEY_DELIMITER
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_KEY_NULL_LITERAL
```
public static final String CONNECTOR_KEY_NULL_LITERAL
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_FAILURE_HANDLER
```
public static final String CONNECTOR_FAILURE_HANDLER
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_FAILURE_HANDLER_VALUE_FAIL
```
public static final String CONNECTOR_FAILURE_HANDLER_VALUE_FAIL
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_FAILURE_HANDLER_VALUE_IGNORE
```
public static final String CONNECTOR_FAILURE_HANDLER_VALUE_IGNORE
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_FAILURE_HANDLER_VALUE_RETRY
```
public static final String CONNECTOR_FAILURE_HANDLER_VALUE_RETRY
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_FAILURE_HANDLER_VALUE_CUSTOM
```
public static final String CONNECTOR_FAILURE_HANDLER_VALUE_CUSTOM
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_FAILURE_HANDLER_CLASS
```
public static final String CONNECTOR_FAILURE_HANDLER_CLASS
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_FLUSH_ON_CHECKPOINT
```
public static final String CONNECTOR_FLUSH_ON_CHECKPOINT
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_BULK_FLUSH_MAX_ACTIONS
```
public static final String CONNECTOR_BULK_FLUSH_MAX_ACTIONS
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_BULK_FLUSH_MAX_SIZE
```
public static final String CONNECTOR_BULK_FLUSH_MAX_SIZE
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_BULK_FLUSH_INTERVAL
```
public static final String CONNECTOR_BULK_FLUSH_INTERVAL
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_BULK_FLUSH_BACKOFF_TYPE
```
public static final String CONNECTOR_BULK_FLUSH_BACKOFF_TYPE
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_BULK_FLUSH_BACKOFF_TYPE_VALUE_DISABLED
```
public static final String CONNECTOR_BULK_FLUSH_BACKOFF_TYPE_VALUE_DISABLED
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_BULK_FLUSH_BACKOFF_TYPE_VALUE_CONSTANT
```
public static final String CONNECTOR_BULK_FLUSH_BACKOFF_TYPE_VALUE_CONSTANT
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_BULK_FLUSH_BACKOFF_TYPE_VALUE_EXPONENTIAL
```
public static final String CONNECTOR_BULK_FLUSH_BACKOFF_TYPE_VALUE_EXPONENTIAL
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_BULK_FLUSH_BACKOFF_MAX_RETRIES
```
public static final String CONNECTOR_BULK_FLUSH_BACKOFF_MAX_RETRIES
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_BULK_FLUSH_BACKOFF_DELAY
```
public static final String CONNECTOR_BULK_FLUSH_BACKOFF_DELAY
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_CONNECTION_MAX_RETRY_TIMEOUT
```
public static final String CONNECTOR_CONNECTION_MAX_RETRY_TIMEOUT
```
    See Also:
    
    Constant Field Values
  - CONNECTOR_CONNECTION_PATH_PREFIX
```
public static final String CONNECTOR_CONNECTION_PATH_PREFIX
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - ElasticsearchValidator
```
public ElasticsearchValidator()
```
- Method Detail
  - validate
```
public void validate(DescriptorProperties properties)
```
    Description copied from interface: DescriptorValidator
    
    Performs basic validation such as completeness tests.
    
    Specified by:
    
    validate in interface DescriptorValidator
    
    Overrides:
    
    validate in class ConnectorDescriptorValidator
  - validateAndParseHostsString
```
public static List<ElasticsearchUpsertTableSinkBase.Host> validateAndParseHostsString(DescriptorProperties descriptorProperties)
```
    Parse Hosts String to list.
    Hosts String format was given as following:
```
     connector.hosts = http://host_name:9092;http://host_name:9093
 
```

Back to Flink Website

Class ElasticsearchValidator

Field Summary

Fields inherited from class org.apache.flink.table.descriptors.ConnectorDescriptorValidator

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

CONNECTOR_TYPE_VALUE_ELASTICSEARCH

CONNECTOR_VERSION_VALUE_6

CONNECTOR_VERSION_VALUE_7

CONNECTOR_HOSTS

CONNECTOR_HOSTS_HOSTNAME

CONNECTOR_HOSTS_PORT

CONNECTOR_HOSTS_PROTOCOL

CONNECTOR_INDEX

CONNECTOR_DOCUMENT_TYPE

CONNECTOR_KEY_DELIMITER

CONNECTOR_KEY_NULL_LITERAL

CONNECTOR_FAILURE_HANDLER

CONNECTOR_FAILURE_HANDLER_VALUE_FAIL

CONNECTOR_FAILURE_HANDLER_VALUE_IGNORE

CONNECTOR_FAILURE_HANDLER_VALUE_RETRY

CONNECTOR_FAILURE_HANDLER_VALUE_CUSTOM

CONNECTOR_FAILURE_HANDLER_CLASS

CONNECTOR_FLUSH_ON_CHECKPOINT

CONNECTOR_BULK_FLUSH_MAX_ACTIONS

CONNECTOR_BULK_FLUSH_MAX_SIZE

CONNECTOR_BULK_FLUSH_INTERVAL

CONNECTOR_BULK_FLUSH_BACKOFF_TYPE

CONNECTOR_BULK_FLUSH_BACKOFF_TYPE_VALUE_DISABLED

CONNECTOR_BULK_FLUSH_BACKOFF_TYPE_VALUE_CONSTANT

CONNECTOR_BULK_FLUSH_BACKOFF_TYPE_VALUE_EXPONENTIAL

CONNECTOR_BULK_FLUSH_BACKOFF_MAX_RETRIES

CONNECTOR_BULK_FLUSH_BACKOFF_DELAY

CONNECTOR_CONNECTION_MAX_RETRY_TIMEOUT

CONNECTOR_CONNECTION_PATH_PREFIX

Constructor Detail

ElasticsearchValidator

Method Detail

validate

validateAndParseHostsString