Http Connector for Apache Flink. Provides sources and sinks for Datastream , Table and SQL APIs.
gid.connector.http.security.cert.server
- path to server's certificate.gid.connector.http.security.cert.client
- path to connector's certificate.gid.connector.http.security.key.client
- path to connector's private key.gid.connector.http.security.cert.server.allowSelfSigned
- allowing for self-signed certificates without adding them to KeyStore (not recommended for a production).Authorization
header for Basic Authentication. The value will be converted to Base64, or if it starts from prefix Basic
, it will be used as is (without any extra modification).q
parameter query using Lucene query string syntax (in first versions of ElasticSearch called Search Lite).Full Changelog: https://github.com/getindata/flink-http-connector/commits/0.5.0
Full Changelog: https://github.com/getindata/flink-http-connector/commits/0.4.0
Full Changelog: https://github.com/getindata/flink-http-connector/commits/0.3.0
HttpSink
implementation by @swtwsk in https://github.com/getindata/flink-http-connector/pull/4
Full Changelog: https://github.com/getindata/flink-http-connector/commits/0.2.0