public org.apache.flink.table.descriptors.Elasticsearch version(String version) {
		internalProperties.putString(CONNECTOR_VERSION, version);
		return this;
	}
Sets the Elasticsearch version to be used. Required.

@param version Elasticsearch version. E.g., "6".
elasticsearch5-xh/elasticsearch5-xh-sink/src/main/java/org/apache/flink/table/descriptors/Elasticsearch.java