This is an automated email from the ASF dual-hosted git repository.
fcsaky pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-http.git
from 0c46b8e [FLIP-532] Initialize repo
add 8bcc01f Init commit
add 01fd4e6 Create LICENCE
add 30b7b7d Create CONTRIBUTING.md
add bd1378c Create CHANGELOG.md
add c8e002e Add Run Example to README.md
add 0509f52 Remove log4j2.properties from src/main folder.
add 5e05558 Update README.md
add 4ea192e Update README.md
add ad1a003 flink upgrade to 1.15
add e79a21b update readme
add 0c06999 upgrade log4j
add 858bf81 Add build Workflow
add e6c8b47 Modify pom.xml to conform with OSSRH requirements
add d81bccf Prepare rest of the GitHub workflows
add 440b45b Fix CI/CD for prepare release (#3)
add 28dc735 Bump CHANGELOG for release 0.1.0
add 5425c62 Bump development version to 0.2.0-SNAPSHOT
add 990c9b7 Attach Maven sources
add 27b2b42 Add initial `HttpSink` implementation (#4)
add 7543b24 Http Sink Table API (#5)
add b8b9ba7 Disable retries of failed requests (#6)
add 1f8cf65 Bump version to 0.3.0-SNAPSHOT (#7)
add ccb6387 Package_refactoring - add internal package and expose public
API
add 72c5c8c checkstyle - add checkstyle based on delta.io/connectors
checkstyle
add 465fe74 ReadmeUpdate - add Maven link to readme.
add 0de047e Add Maven badge to README
add 5212974 TestPackageRefactoring - refactoring test package to match
source folder. Fix checkstyle issues.
add 18e7955 ESP-98ESP-98_SinkParameters - pass headers via properties to
Http client
add 9805699 ESP-98ESP-98_SinkParameters - add unit tests
add 2829ef6 ESP-98ESP-98_SinkParameters - add unit tests
add 762e2d0 ESP-98ESP-98_SinkParameters - add properties to Table API.
add 5d08435 ESP-98ESP-98_SinkParameters - add properties to Table API.
add 3311e62 ESP-98ESP-98_SinkParameters - CHANGELOG.md and README.md
update
add 4b16f2c ESP-98ESP-98_SinkParameters - changes after code review
add f3a5cdc Bump development version after release of 0.3.0 (#13)
add 97b9e33 Fix JavaDoc errors (#14)
add 762b13e Add JavaDoc.io badge (#15)
add c58277e ESP-99_ErrorCodes - Error Code configuration from properties.
(#16)
add a7dc4f6 Drop Dependency for Apache HttpClient (#17)
add f21d2e5 ESP-148_UseFlink_JsonFormat_InSource - Use Flink Json Format
instead custom implemented Json Format for Source Lookup. (#19)
add 89065e2 LookupSource_TestRename - Source Test name change + remove
unused method argument in source factory. (#20)
add 0d366de 1ESP-119_Http_headers_SourceSupport - Add Http header support
for Http Lookup Source. (#21)
add 80a8935 ESP-171_HttpLookupSource_ErrorCodeSupport - HTTP ErrorCode
Status config for Lookup Source (#22)
add 87c9a8a Introduce custom HTTP Sink Post Request Callback and its
Factory (#23)
add ae8b3dd Bump development version after release of 0.4.0 (#24)
add 5c82a84 ESP-117 adding tls and mTLS support for Http Connector (#25)
add cc7d58c ESP-221_BasicAuth - adding HeaderPreprocessor and support for
Basic Authentication mechanism. (#26)
add 39921c2 Introduce LookupQueryCreator and its Factory
add c504ac9 Increase the coverage a bit
add a7d0143 Add ElasticSearchLiteQueryCreator
add dd167a0 Bump CHANGELOG for release 0.5.0
add e654078 Bump development version to 0.6.0-SNAPSHOT
add 5a861a6 ESP-263 - Adding body based REST methods to Lookup Source.
add 8fc8c1a Bump development version after release of 0.6.0 (#30)
add 9941292 [HTTP-34] Add support for lookup on Row type (#35)
add 25b959f Bump development version after release of 0.7.0 (#36)
add 01ccca9 [HTTP-38] - Fixing issue with handling Http timeout where
Event task was not removed from Flink's Operator AsyncIO internal queue.
add 5c55729 Bump CHANGELOG for release 0.8.0
add d9f7cd3 Bump development version to 0.9.0-SNAPSHOT
add a2bfb67 [HTTP-43] - Remove Encoding format from HttpLookupTableSource
add 77d8167 Fix typo in examples in README.md.
add 4bdb5a5 [HTTP-45] - Fix issue with not printing HttpRequest
body/parameters for Lookup Source by Slf4JHttpLookupPostRequestCallback.
add f665da4 Prepare 0.8.1 hotfix version
add 3c8397a Bump CHANGELOG for release 0.8.1
add 1ee6a72 Bump development version to 0.9.0-SNAPSHOT
add e20f492 Update README.md TODO list
add 537b689 [HTTP-37] - Add support for Flink 1.16. Modify CI/CD to run
builds for Flink 1.15 and 1.16.
add 29ee64b Bump CHANGELOG for release 0.9.0
add c0c3f57 Bump development version to 0.10.0-SNAPSHOT
add d3c438a rc-0.9.0_testRunFix - fix publish build #2
add 8baed99 Update README.md
add b485a64 Cleaning unused gitlab ci definition (#56)
add 99365f3 HTTP-42 Add support for Batch request submission in HTTP
Sink. (#58)
add 4209cd4 Bump development version after release of 0.10.0 (#60)
add 1b2b164 Update README.md - how to use request per element mode in
Http Sink
add 17d0621 Update README.md
add 02cf022 main - add test for passing properties to format used by
lookup query creator.
add b4614c0 Issue54 Fix class loader and Prefixed Config option issues
(#68)
add 58e7b46 Bump development version after release of 0.11.0 (#70)
add 99d7f2b HTTP-76 Allow enforcing the use of raw Authorization header
(#77)
add 61e6ca7 HTTP-78 Support for optional query parameters for body-based
requests (#79)
add c6683d7 Bump vsoch/pull-request-action version (#81)
add 2952b73 Bump development version after release of 0.12.0 (#82)
add 43786bc [HTTP-64] move to junit 5 and fix junit failures (#72)
add 93a6a9d HTTP-74 Add path parameter support (#87)
add 91fac5a HTTP-74 Add path parameter support (#84)
add 27b0f61 Bump development version after release of 0.13.0 (#88)
add feeabd5 HTTP-92 Customization of HTTP lookup source logger
add 09286ef Bump development version after release of 0.14.0 (#95)
add c74f09e HTTP-96 Fix logging code in JavaNetHttpPollingClient (#97)
add 959e60e Fix jacoco code coverage info in PR. Remove printing jacoco
stat to console (#101)
add 23ba94f Reinstatiate javadoc step in common build (#102)
add 5fc9341 PR from forked repo fix (#105)
add 48ae840 HTTP-63 Add caching (#109)
add 44e30db Bump development version after release of 0.15.0 (#110)
add b391b3e update publish to maven setup (#112)
add 91958ee Maven publish fix (#113)
add 01c6217 Maven publish fix (#114)
add a9e21f3 Maven publish fix (#115)
add 45643b6 Maven publish fix (#116)
add e38d73d Update publish.yml
add 1e62389 Update publish.yml
add f026603 maven-publish-fix - fixing maven central publish
add d65de80 HTTP-91 Bearer token support (#117)
add 75a469d Fix adding coverage to PRs (#131)
add ea9e9f4 HTTP-121 Ensure SerializationSchema is used in thread-safe
way (#127)
add de8096b Add missing tests (#130)
add d32368d HTTP-119 Pickup up public CAs when there are no security
options configured (#128)
add 350c62f Bump CHANGELOG for release 0.16.0
add 85cf545 Bump development version to 0.17.0-SNAPSHOT
add eb8995a Support source lookup array results (#135)
add 202d358 Bump CHANGELOG for release 0.17.0
add 1ca7b4c Bump development version to 0.18.0-SNAPSHOT
add a0db115 HTTP-138 ignore Eclipse files in .gitignore (#139)
add cb93c76 HTTP-103 Support Flink 1.20 (#140)
add 2ea462e Bump CHANGELOG for release 0.18.0
add 203c8e3 Bump development version to 0.19.0-SNAPSHOT
add b32c518 HTTP-145 SQL explain drives rest flow to OIDC endpoint (#146)
add be88683 Bump CHANGELOG for release 0.19.0
add 849a97f Bump development version to 0.20.0-SNAPSHOT
add 4c7d376 HTTP-122 Retry for source lookup table (#148)
add 869b275 HTTP-99 Add support for generic json and URL query creator
(#149)
add 444ea89 HTTP-150 Add Proxy to HttpClient for Lookup Source (#151)
add 99a1e52 Add missing permission in prepare_release_branch (#152)
add 19dd386 Bump CHANGELOG for release 0.20.0
add 4e395c5 Bump development version to 0.21.0-SNAPSHOT
new 645c950 [FLINK-38245] Initial contribution of Getindata connector
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.checkstyle | 15 +
.github/boring-cyborg.yml | 86 ++
.github/workflows/push_pr.yml | 37 +
.github/workflows/weekly.yml | 41 +
.gitignore | 37 +
.mvn/jvm.config | 7 +
.mvn/wrapper/maven-wrapper.properties | 22 +
CHANGELOG.md | 285 +++++
NOTICE | 17 +
README.md | 68 ++
docs/content/docs/datastream/http.md | 179 ++++
docs/content/docs/table/http.md | 545 ++++++++++
flink-connector-http/pom.xml | 465 ++++++++
.../connector/http/HttpPostRequestCallback.java | 46 +
.../http/HttpPostRequestCallbackFactory.java | 79 ++
.../org/apache/flink/connector/http/HttpSink.java | 90 ++
.../flink/connector/http/HttpSinkBuilder.java | 211 ++++
.../HttpStatusCodeValidationFailedException.java | 33 +
.../org/apache/flink/connector/http/LookupArg.java | 33 +
.../flink/connector/http/LookupQueryCreator.java | 43 +
.../connector/http/LookupQueryCreatorFactory.java | 68 ++
.../http/SchemaLifecycleAwareElementConverter.java | 50 +
.../http/auth/OidcAccessTokenManager.java | 155 +++
.../connector/http/clients/PollingClient.java | 42 +
.../http/clients/PollingClientFactory.java | 36 +
.../connector/http/clients/SinkHttpClient.java | 43 +
.../http/clients/SinkHttpClientBuilder.java | 40 +
.../http/clients/SinkHttpClientResponse.java | 42 +
.../connector/http/config/ConfigException.java | 52 +
.../http/config/HttpConnectorConfigConstants.java | 159 +++
.../http/config/SinkRequestSubmitMode.java | 34 +
.../BasicAuthHeaderValuePreprocessor.java | 72 ++
.../preprocessor/ComposeHeaderPreprocessor.java | 60 ++
.../http/preprocessor/HeaderPreprocessor.java | 33 +
.../http/preprocessor/HeaderValuePreprocessor.java | 35 +
.../OIDCAuthHeaderValuePreprocessor.java | 64 ++
.../connector/http/retry/HttpClientWithRetry.java | 93 ++
.../connector/http/retry/RetryConfigProvider.java | 75 ++
.../connector/http/retry/RetryStrategyType.java | 45 +
.../connector/http/security/SecurityContext.java | 244 +++++
.../http/security/SelfSignedTrustManager.java | 71 ++
.../connector/http/sink/HttpSinkInternal.java | 202 ++++
.../connector/http/sink/HttpSinkRequestEntry.java | 48 +
.../flink/connector/http/sink/HttpSinkWriter.java | 161 +++
.../http/sink/HttpSinkWriterStateSerializer.java | 53 +
.../sink/httpclient/AbstractRequestSubmitter.java | 64 ++
.../sink/httpclient/BatchRequestSubmitter.java | 153 +++
.../httpclient/BatchRequestSubmitterFactory.java | 89 ++
.../http/sink/httpclient/HttpRequest.java | 33 +
.../httpclient/JavaNetHttpResponseWrapper.java | 46 +
.../sink/httpclient/JavaNetSinkHttpClient.java | 137 +++
.../PerRequestRequestSubmitterFactory.java | 50 +
.../http/sink/httpclient/PerRequestSubmitter.java | 94 ++
.../http/sink/httpclient/RequestSubmitter.java | 30 +
.../sink/httpclient/RequestSubmitterFactory.java | 26 +
.../http/status/ComposeHttpStatusCodeChecker.java | 176 +++
.../connector/http/status/HttpCodesParser.java | 85 ++
.../connector/http/status/HttpResponseChecker.java | 78 ++
.../http/status/HttpResponseCodeType.java | 63 ++
.../http/status/HttpStatusCodeChecker.java | 34 +
.../status/IncludeListHttpStatusCodeChecker.java | 39 +
.../status/SingleValueHttpStatusCodeChecker.java | 44 +
.../http/status/TypeStatusCodeChecker.java | 61 ++
.../table/SerializationSchemaElementConverter.java | 61 ++
.../table/lookup/AsyncHttpTableLookupFunction.java | 131 +++
.../http/table/lookup/BodyBasedRequestFactory.java | 88 ++
.../http/table/lookup/GetRequestFactory.java | 90 ++
.../http/table/lookup/HttpLookupConfig.java | 48 +
.../table/lookup/HttpLookupConnectorOptions.java | 200 ++++
.../table/lookup/HttpLookupSourceRequestEntry.java | 47 +
.../http/table/lookup/HttpLookupTableSource.java | 258 +++++
.../table/lookup/HttpLookupTableSourceFactory.java | 232 ++++
.../http/table/lookup/HttpRequestFactory.java | 35 +
.../http/table/lookup/HttpTableLookupFunction.java | 88 ++
.../table/lookup/JavaNetHttpPollingClient.java | 252 +++++
.../lookup/JavaNetHttpPollingClientFactory.java | 46 +
.../http/table/lookup/LookupQueryInfo.java | 86 ++
.../connector/http/table/lookup/LookupRow.java | 72 ++
.../http/table/lookup/LookupSchemaEntry.java | 43 +
.../http/table/lookup/RequestFactoryBase.java | 134 +++
.../table/lookup/RowDataLookupSchemaEntryBase.java | 48 +
.../RowDataSingleValueLookupSchemaEntry.java | 93 ++
.../table/lookup/RowTypeLookupSchemaEntry.java | 102 ++
.../lookup/Slf4JHttpLookupPostRequestCallback.java | 84 ++
.../Slf4jHttpLookupPostRequestCallbackFactory.java | 53 +
.../http/table/lookup/TableSourceHelper.java | 73 ++
.../ElasticSearchLiteQueryCreator.java | 69 ++
.../ElasticSearchLiteQueryCreatorFactory.java | 56 +
.../querycreators/GenericGetQueryCreator.java | 58 +
.../GenericGetQueryCreatorFactory.java | 56 +
.../GenericJsonAndUrlQueryCreator.java | 285 +++++
.../GenericJsonAndUrlQueryCreatorFactory.java | 157 +++
.../querycreators/GenericJsonQueryCreator.java | 71 ++
.../GenericJsonQueryCreatorFactory.java | 92 ++
.../lookup/querycreators/ObjectMapperAdapter.java | 42 +
.../lookup/querycreators/PrefixedConfigOption.java | 102 ++
.../QueryFormatAwareConfiguration.java | 59 ++
.../connector/http/table/sink/HttpDynamicSink.java | 277 +++++
.../sink/HttpDynamicSinkConnectorOptions.java | 44 +
.../table/sink/HttpDynamicTableSinkFactory.java | 116 ++
.../table/sink/Slf4jHttpPostRequestCallback.java | 69 ++
.../sink/Slf4jHttpPostRequestCallbackFactory.java | 53 +
.../flink/connector/http/utils/ConfigUtils.java | 132 +++
.../connector/http/utils/HttpHeaderUtils.java | 150 +++
.../http/utils/JavaNetHttpClientFactory.java | 235 ++++
.../flink/connector/http/utils/ProxyConfig.java | 61 ++
.../http/utils/SerializationSchemaUtils.java | 67 ++
.../utils/SynchronizedSerializationSchema.java | 52 +
.../flink/connector/http/utils/ThreadUtils.java | 37 +
.../connector/http/utils/uri/CharArrayBuffer.java | 117 ++
.../connector/http/utils/uri/NameValuePair.java | 43 +
.../connector/http/utils/uri/ParserCursor.java | 72 ++
.../connector/http/utils/uri/TokenParser.java | 135 +++
.../flink/connector/http/utils/uri/URIBuilder.java | 172 +++
.../connector/http/utils/uri/URLEncodedUtils.java | 437 ++++++++
.../org.apache.flink.table.factories.Factory | 28 +
.../http/HttpPostRequestCallbackFactoryTest.java | 194 ++++
.../connector/http/HttpsConnectionTestBase.java | 62 ++
.../flink/connector/http/StreamTableJob.java | 77 ++
.../apache/flink/connector/http/TestHelper.java | 65 ++
.../http/TestLookupPostRequestCallbackFactory.java | 53 +
.../http/TestPostRequestCallbackFactory.java | 51 +
.../http/WireMockServerPortAllocator.java | 36 +
.../flink/connector/http/app/HttpStubApp.java | 57 +
.../flink/connector/http/app/JsonTransform.java | 125 +++
.../http/auth/OidcAccessTokenManagerTest.java | 257 +++++
.../connector/http/config/ConfigExceptionTest.java | 40 +
.../http/retry/HttpClientWithRetryTest.java | 171 +++
.../http/retry/RetryConfigProviderTest.java | 89 ++
.../http/retry/RetryStrategyTypeTest.java | 61 ++
.../connector/http/sink/HttpSinkBuilderTest.java | 93 ++
.../http/sink/HttpSinkConnectionTest.java | 378 +++++++
.../sink/HttpSinkWriterStateSerializerTest.java | 52 +
.../connector/http/sink/HttpSinkWriterTest.java | 114 ++
.../BatchRequestSubmitterFactoryTest.java | 96 ++
.../sink/httpclient/BatchRequestSubmitterTest.java | 103 ++
.../JavaNetSinkHttpClientConnectionTest.java | 329 ++++++
.../sink/httpclient/JavaNetSinkHttpClientTest.java | 138 +++
.../status/ComposeHttpStatusCodeCheckerTest.java | 181 ++++
.../connector/http/status/HttpCodesParserTest.java | 105 ++
.../http/status/HttpResponseCheckerTest.java | 127 +++
.../BasicAuthHeaderValuePreprocessorTest.java | 46 +
.../http/table/ComposeHeaderPreprocessorTest.java | 43 +
.../lookup/AsyncHttpTableLookupFunctionTest.java | 238 +++++
.../table/lookup/BodyBasedRequestFactoryTest.java | 145 +++
.../lookup/HttpLookupTableSourceFactoryTest.java | 139 +++
.../lookup/HttpLookupTableSourceITCaseTest.java | 1118 ++++++++++++++++++++
.../table/lookup/HttpLookupTableSourceTest.java | 258 +++++
.../JavaNetHttpPollingClientConnectionTest.java | 542 ++++++++++
.../JavaNetHttpPollingClientFactoryTest.java | 51 +
...avaNetHttpPollingClientHttpsConnectionTest.java | 363 +++++++
.../table/lookup/JavaNetHttpPollingClientTest.java | 237 +++++
.../JavaNetHttpPollingClientWithWireTest.java | 191 ++++
.../connector/http/table/lookup/JsonTransform.java | 126 +++
.../http/table/lookup/LookupQueryInfoTest.java | 107 ++
.../RowDataSingleValueLookupSchemaEntryTest.java | 47 +
.../table/lookup/RowTypeLookupSchemaEntryTest.java | 177 ++++
.../http/table/lookup/TableSourceHelperTest.java | 53 +
.../lookup/querycreators/CustomFormatFactory.java | 66 ++
.../querycreators/CustomJsonFormatFactory.java | 67 ++
.../ElasticSearchLiteQueryCreatorTest.java | 158 +++
.../querycreators/GenericGetQueryCreatorTest.java | 208 ++++
.../GenericJsonAndUrlQueryCreatorFactoryTest.java | 138 +++
.../GenericJsonAndUrlQueryCreatorTest.java | 267 +++++
.../GenericJsonQueryCreatorFactoryTest.java | 111 ++
.../querycreators/GenericJsonQueryCreatorTest.java | 92 ++
.../table/lookup/querycreators/PersonBean.java | 28 +
.../lookup/querycreators/QueryCreatorUtils.java | 76 ++
.../QueryFormatAwareConfigurationTest.java | 59 ++
.../BatchRequestHttpDynamicSinkInsertTest.java | 364 +++++++
.../http/table/sink/HttpDynamicSinkTest.java | 134 +++
.../sink/HttpDynamicTableSinkFactoryTest.java | 113 ++
.../sink/PerRequestHttpDynamicSinkInsertTest.java | 331 ++++++
.../connector/http/utils/ConfigUtilsTest.java | 292 +++++
.../connector/http/utils/HttpHeaderUtilsTest.java | 47 +
.../http/utils/JavaNetHttpClientFactoryTest.java | 141 +++
.../http/utils/uri/CharArrayBufferTest.java | 96 ++
.../connector/http/utils/uri/ParserCursorTest.java | 49 +
.../connector/http/utils/uri/TokenParserTest.java | 41 +
.../connector/http/utils/uri/URIBuilderTest.java | 298 ++++++
.../http/utils/uri/URLEncodedUtilsTest.java | 125 +++
.../org.apache.flink.table.factories.Factory | 24 +
.../src/test/resources/auth/AuthResult.json | 4 +
.../http-array-result-with-nulls/HttpResult.json | 20 +
.../resources/http-array-result/HttpResult.json | 36 +
.../src/test/resources/http/HttpResult.json | 51 +
.../src/test/resources/json/sink/allInOneBatch.txt | 47 +
.../resources/json/sink/fourSingleEventBatches.txt | 60 ++
.../src/test/resources/json/sink/threeBatches.txt | 53 +
.../src/test/resources/json/sink/twoBatches.txt | 50 +
.../src/test/resources/security/certs/ca.crt | 34 +
.../src/test/resources/security/certs/ca.key | 51 +
.../src/test/resources/security/certs/ca.pass.key | 54 +
.../src/test/resources/security/certs/ca.srl | 1 +
.../security/certs/ca_server_bundle.cert.pem | 66 ++
.../src/test/resources/security/certs/client.crt | 32 +
.../src/test/resources/security/certs/client.csr | 29 +
.../src/test/resources/security/certs/client.key | 51 +
.../test/resources/security/certs/client.pass.key | 54 +
.../resources/security/certs/clientPrivateKey.der | Bin 0 -> 2375 bytes
.../resources/security/certs/clientPrivateKey.pem | 52 +
.../resources/security/certs/client_keyStore.p12 | Bin 0 -> 4181 bytes
.../src/test/resources/security/certs/server.crt | 32 +
.../src/test/resources/security/certs/server.csr | 29 +
.../src/test/resources/security/certs/server.key | 51 +
.../test/resources/security/certs/server.pass.key | 54 +
.../resources/security/certs/serverKeyStore.jks | Bin 0 -> 4383 bytes
.../resources/security/certs/serverTrustStore.jks | Bin 0 -> 4383 bytes
flink-sql-connector-http/pom.xml | 147 +++
.../src/main/resources/META-INF/NOTICE | 12 +
.../flink/connector/http/PackagingITCase.java | 42 +
lombok.config | 1 +
pom.xml | 611 +++++++++++
tools/ci/log4j.properties | 72 ++
tools/maven/checkstyle.xml | 564 ++++++++++
tools/maven/suppressions.xml | 27 +
216 files changed, 23973 insertions(+)
create mode 100644 .checkstyle
create mode 100644 .github/boring-cyborg.yml
create mode 100644 .github/workflows/push_pr.yml
create mode 100644 .github/workflows/weekly.yml
create mode 100644 .gitignore
create mode 100644 .mvn/jvm.config
create mode 100644 .mvn/wrapper/maven-wrapper.properties
create mode 100644 CHANGELOG.md
create mode 100644 NOTICE
create mode 100644 README.md
create mode 100644 docs/content/docs/datastream/http.md
create mode 100644 docs/content/docs/table/http.md
create mode 100644 flink-connector-http/pom.xml
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/HttpPostRequestCallback.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/HttpPostRequestCallbackFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/HttpSink.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/HttpSinkBuilder.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/HttpStatusCodeValidationFailedException.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/LookupArg.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/LookupQueryCreator.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/LookupQueryCreatorFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/SchemaLifecycleAwareElementConverter.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/auth/OidcAccessTokenManager.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/clients/PollingClient.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/clients/PollingClientFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/clients/SinkHttpClient.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/clients/SinkHttpClientBuilder.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/clients/SinkHttpClientResponse.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/config/ConfigException.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/config/HttpConnectorConfigConstants.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/config/SinkRequestSubmitMode.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/preprocessor/BasicAuthHeaderValuePreprocessor.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/preprocessor/ComposeHeaderPreprocessor.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/preprocessor/HeaderPreprocessor.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/preprocessor/HeaderValuePreprocessor.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/preprocessor/OIDCAuthHeaderValuePreprocessor.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/retry/HttpClientWithRetry.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/retry/RetryConfigProvider.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/retry/RetryStrategyType.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/security/SecurityContext.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/security/SelfSignedTrustManager.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/sink/HttpSinkInternal.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/sink/HttpSinkRequestEntry.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/sink/HttpSinkWriter.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/sink/HttpSinkWriterStateSerializer.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/sink/httpclient/AbstractRequestSubmitter.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/sink/httpclient/BatchRequestSubmitter.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/sink/httpclient/BatchRequestSubmitterFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/sink/httpclient/HttpRequest.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/sink/httpclient/JavaNetHttpResponseWrapper.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/sink/httpclient/JavaNetSinkHttpClient.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/sink/httpclient/PerRequestRequestSubmitterFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/sink/httpclient/PerRequestSubmitter.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/sink/httpclient/RequestSubmitter.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/sink/httpclient/RequestSubmitterFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/status/ComposeHttpStatusCodeChecker.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/status/HttpCodesParser.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/status/HttpResponseChecker.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/status/HttpResponseCodeType.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/status/HttpStatusCodeChecker.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/status/IncludeListHttpStatusCodeChecker.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/status/SingleValueHttpStatusCodeChecker.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/status/TypeStatusCodeChecker.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/SerializationSchemaElementConverter.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/AsyncHttpTableLookupFunction.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/BodyBasedRequestFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/GetRequestFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/HttpLookupConfig.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/HttpLookupConnectorOptions.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/HttpLookupSourceRequestEntry.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/HttpLookupTableSource.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/HttpLookupTableSourceFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/HttpRequestFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/HttpTableLookupFunction.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/JavaNetHttpPollingClient.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/JavaNetHttpPollingClientFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/LookupQueryInfo.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/LookupRow.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/LookupSchemaEntry.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/RequestFactoryBase.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/RowDataLookupSchemaEntryBase.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/RowDataSingleValueLookupSchemaEntry.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/RowTypeLookupSchemaEntry.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/Slf4JHttpLookupPostRequestCallback.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/Slf4jHttpLookupPostRequestCallbackFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/TableSourceHelper.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/querycreators/ElasticSearchLiteQueryCreator.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/querycreators/ElasticSearchLiteQueryCreatorFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/querycreators/GenericGetQueryCreator.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/querycreators/GenericGetQueryCreatorFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/querycreators/GenericJsonAndUrlQueryCreator.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/querycreators/GenericJsonAndUrlQueryCreatorFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/querycreators/GenericJsonQueryCreator.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/querycreators/GenericJsonQueryCreatorFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/querycreators/ObjectMapperAdapter.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/querycreators/PrefixedConfigOption.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/lookup/querycreators/QueryFormatAwareConfiguration.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/sink/HttpDynamicSink.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/sink/HttpDynamicSinkConnectorOptions.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/sink/HttpDynamicTableSinkFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/sink/Slf4jHttpPostRequestCallback.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/table/sink/Slf4jHttpPostRequestCallbackFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/utils/ConfigUtils.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/utils/HttpHeaderUtils.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/utils/JavaNetHttpClientFactory.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/utils/ProxyConfig.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/utils/SerializationSchemaUtils.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/utils/SynchronizedSerializationSchema.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/utils/ThreadUtils.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/utils/uri/CharArrayBuffer.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/utils/uri/NameValuePair.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/utils/uri/ParserCursor.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/utils/uri/TokenParser.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/utils/uri/URIBuilder.java
create mode 100644
flink-connector-http/src/main/java/org/apache/flink/connector/http/utils/uri/URLEncodedUtils.java
create mode 100644
flink-connector-http/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/HttpPostRequestCallbackFactoryTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/HttpsConnectionTestBase.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/StreamTableJob.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/TestHelper.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/TestLookupPostRequestCallbackFactory.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/TestPostRequestCallbackFactory.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/WireMockServerPortAllocator.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/app/HttpStubApp.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/app/JsonTransform.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/auth/OidcAccessTokenManagerTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/config/ConfigExceptionTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/retry/HttpClientWithRetryTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/retry/RetryConfigProviderTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/retry/RetryStrategyTypeTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/sink/HttpSinkBuilderTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/sink/HttpSinkConnectionTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/sink/HttpSinkWriterStateSerializerTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/sink/HttpSinkWriterTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/sink/httpclient/BatchRequestSubmitterFactoryTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/sink/httpclient/BatchRequestSubmitterTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/sink/httpclient/JavaNetSinkHttpClientConnectionTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/sink/httpclient/JavaNetSinkHttpClientTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/sink/httpclient/status/ComposeHttpStatusCodeCheckerTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/status/HttpCodesParserTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/status/HttpResponseCheckerTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/BasicAuthHeaderValuePreprocessorTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/ComposeHeaderPreprocessorTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/AsyncHttpTableLookupFunctionTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/BodyBasedRequestFactoryTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/HttpLookupTableSourceFactoryTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/HttpLookupTableSourceITCaseTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/HttpLookupTableSourceTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/JavaNetHttpPollingClientConnectionTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/JavaNetHttpPollingClientFactoryTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/JavaNetHttpPollingClientHttpsConnectionTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/JavaNetHttpPollingClientTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/JavaNetHttpPollingClientWithWireTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/JsonTransform.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/LookupQueryInfoTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/RowDataSingleValueLookupSchemaEntryTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/RowTypeLookupSchemaEntryTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/TableSourceHelperTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/querycreators/CustomFormatFactory.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/querycreators/CustomJsonFormatFactory.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/querycreators/ElasticSearchLiteQueryCreatorTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/querycreators/GenericGetQueryCreatorTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/querycreators/GenericJsonAndUrlQueryCreatorFactoryTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/querycreators/GenericJsonAndUrlQueryCreatorTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/querycreators/GenericJsonQueryCreatorFactoryTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/querycreators/GenericJsonQueryCreatorTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/querycreators/PersonBean.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/querycreators/QueryCreatorUtils.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/lookup/querycreators/QueryFormatAwareConfigurationTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/sink/BatchRequestHttpDynamicSinkInsertTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/sink/HttpDynamicSinkTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/sink/HttpDynamicTableSinkFactoryTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/table/sink/PerRequestHttpDynamicSinkInsertTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/utils/ConfigUtilsTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/utils/HttpHeaderUtilsTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/utils/JavaNetHttpClientFactoryTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/utils/uri/CharArrayBufferTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/utils/uri/ParserCursorTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/utils/uri/TokenParserTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/utils/uri/URIBuilderTest.java
create mode 100644
flink-connector-http/src/test/java/org/apache/flink/connector/http/utils/uri/URLEncodedUtilsTest.java
create mode 100644
flink-connector-http/src/test/resources/META-INF/services/org.apache.flink.table.factories.Factory
create mode 100644 flink-connector-http/src/test/resources/auth/AuthResult.json
create mode 100644
flink-connector-http/src/test/resources/http-array-result-with-nulls/HttpResult.json
create mode 100644
flink-connector-http/src/test/resources/http-array-result/HttpResult.json
create mode 100644 flink-connector-http/src/test/resources/http/HttpResult.json
create mode 100644
flink-connector-http/src/test/resources/json/sink/allInOneBatch.txt
create mode 100644
flink-connector-http/src/test/resources/json/sink/fourSingleEventBatches.txt
create mode 100644
flink-connector-http/src/test/resources/json/sink/threeBatches.txt
create mode 100644
flink-connector-http/src/test/resources/json/sink/twoBatches.txt
create mode 100644
flink-connector-http/src/test/resources/security/certs/ca.crt
create mode 100644
flink-connector-http/src/test/resources/security/certs/ca.key
create mode 100644
flink-connector-http/src/test/resources/security/certs/ca.pass.key
create mode 100644
flink-connector-http/src/test/resources/security/certs/ca.srl
create mode 100644
flink-connector-http/src/test/resources/security/certs/ca_server_bundle.cert.pem
create mode 100644
flink-connector-http/src/test/resources/security/certs/client.crt
create mode 100644
flink-connector-http/src/test/resources/security/certs/client.csr
create mode 100644
flink-connector-http/src/test/resources/security/certs/client.key
create mode 100644
flink-connector-http/src/test/resources/security/certs/client.pass.key
create mode 100644
flink-connector-http/src/test/resources/security/certs/clientPrivateKey.der
create mode 100644
flink-connector-http/src/test/resources/security/certs/clientPrivateKey.pem
create mode 100644
flink-connector-http/src/test/resources/security/certs/client_keyStore.p12
create mode 100644
flink-connector-http/src/test/resources/security/certs/server.crt
create mode 100644
flink-connector-http/src/test/resources/security/certs/server.csr
create mode 100644
flink-connector-http/src/test/resources/security/certs/server.key
create mode 100644
flink-connector-http/src/test/resources/security/certs/server.pass.key
create mode 100644
flink-connector-http/src/test/resources/security/certs/serverKeyStore.jks
create mode 100644
flink-connector-http/src/test/resources/security/certs/serverTrustStore.jks
create mode 100644 flink-sql-connector-http/pom.xml
create mode 100644 flink-sql-connector-http/src/main/resources/META-INF/NOTICE
create mode 100644
flink-sql-connector-http/src/test/java/org/apache/flink/connector/http/PackagingITCase.java
create mode 100644 lombok.config
create mode 100644 pom.xml
create mode 100644 tools/ci/log4j.properties
create mode 100644 tools/maven/checkstyle.xml
create mode 100644 tools/maven/suppressions.xml
