@Override
	protected Map<String, String> toConnectorProperties() {
		final DescriptorProperties properties = new DescriptorProperties();
		properties.putProperties(internalProperties);

		if (hosts.size() > 0) {
			properties.putString(
				CONNECTOR_HOSTS,
				hosts.stream()
					.map(Host::toString)
					.collect(Collectors.joining(";")));
		}
		return properties.asMap();
	}
Sets connection properties to be used during REST communication to Elasticsearch.

<p>Adds a path prefix to every REST communication.

@param pathPrefix prefix string to be added to every REST communication
elasticsearch5-xh/elasticsearch5-xh-sink/src/main/java/org/apache/flink/table/descriptors/Elasticsearch.java