Adapt Http Lookup Source to Elastic

getindata / flink-http-connector

Http Connector for Apache Flink. Provides sources and sinks for Datastream , Table and SQL APIs.

Apache License 2.0

150 stars 43 forks source link

Closed swtwsk closed 2 years ago

swtwsk commented 2 years ago

Add LookupQueryCreator and LookupQueryCreatorFactory interfaces (along with a "default" GenericGetQueryCreator implementation) for customization of queries prepared by Lookup Source for its HTTP requests.
Add ElasticSearchLiteQueryCreator that prepares q parameter query using Lucene query string syntax (in first versions of ElasticSearch called Search Lite).

github-actions[bot] commented 2 years ago

File	Coverage [95.59%]	:green_apple:
HttpLookupTableSourceFactory.java	100%	:green_apple:
JavaNetHttpPollingClientFactory.java	100%	:green_apple:
NameValuePair.java	100%	:green_apple:
GenericGetQueryCreator.java	100%	:green_apple:
ElasticSearchLiteQueryCreator.java	100%	:green_apple:
URLEncodedUtils.java	98.51%	:green_apple:
HttpTableLookupFunction.java	95.97%	:green_apple:
JavaNetHttpPollingClient.java	91.76%	:green_apple:
HttpLookupTableSource.java	82.57%	:green_apple:
GenericGetQueryCreatorFactory.java	69.23%	:green_apple:
ElasticSearchLiteQueryCreatorFactory.java	38.46%	:x:

Total Project Coverage	94.93%	:green_apple: