jar

com.getindata : flink-http-connector

Maven & Gradle

Jul 05, 2023
157 stars

flink-http-connector · The HTTP TableLookup connector that allows for pulling data from external system via HTTP GET method and HTTP Sink that allows for sending data to external system via HTTP requests. The goal for HTTP TableLookup connector was to use it in Flink SQL statement as a standard table that can be later joined with other stream using pure SQL Flink.

Table Of Contents

Latest Version

Download com.getindata : flink-http-connector JAR file - Latest Versions:

All Versions

Download com.getindata : flink-http-connector JAR file - All Versions:

Version Vulnerabilities Size Updated
0.10.x
0.9.x
0.8.x
0.7.x
0.6.x
0.5.x
0.4.x
0.3.x
0.2.x
0.1.x

View Java Class Source Code in JAR file

  1. Download JD-GUI to open JAR file and explore Java source code file (.class .java)
  2. Click menu "File → Open File..." or just drag-and-drop the JAR file in the JD-GUI window flink-http-connector-0.10.0.jar file.
    Once you open a JAR file, all the java classes in the JAR file will be displayed.

com.getindata.connectors.http.internal.config

├─ com.getindata.connectors.http.internal.config.ConfigException.class - [JAR]

├─ com.getindata.connectors.http.internal.config.HttpConnectorConfigConstants.class - [JAR]

├─ com.getindata.connectors.http.internal.config.SinkRequestSubmitMode.class - [JAR]

com.getindata.connectors.http.internal.utils

├─ com.getindata.connectors.http.internal.utils.ConfigUtils.class - [JAR]

├─ com.getindata.connectors.http.internal.utils.ExceptionUtils.class - [JAR]

├─ com.getindata.connectors.http.internal.utils.HttpHeaderUtils.class - [JAR]

├─ com.getindata.connectors.http.internal.utils.JavaNetHttpClientFactory.class - [JAR]

├─ com.getindata.connectors.http.internal.utils.SerializationSchemaUtils.class - [JAR]

├─ com.getindata.connectors.http.internal.utils.ThreadUtils.class - [JAR]

com.getindata.connectors.http.internal.status

├─ com.getindata.connectors.http.internal.status.ComposeHttpStatusCodeChecker.class - [JAR]

├─ com.getindata.connectors.http.internal.status.HttpResponseCodeType.class - [JAR]

├─ com.getindata.connectors.http.internal.status.HttpStatusCodeChecker.class - [JAR]

├─ com.getindata.connectors.http.internal.status.SingleValueHttpStatusCodeChecker.class - [JAR]

├─ com.getindata.connectors.http.internal.status.TypeStatusCodeChecker.class - [JAR]

├─ com.getindata.connectors.http.internal.status.WhiteListHttpStatusCodeChecker.class - [JAR]

com.getindata.connectors.http.internal.security

├─ com.getindata.connectors.http.internal.security.SecurityContext.class - [JAR]

├─ com.getindata.connectors.http.internal.security.SelfSignedTrustManager.class - [JAR]

com.getindata.connectors.http.internal

├─ com.getindata.connectors.http.internal.BasicAuthHeaderValuePreprocessor.class - [JAR]

├─ com.getindata.connectors.http.internal.ComposeHeaderPreprocessor.class - [JAR]

├─ com.getindata.connectors.http.internal.HeaderPreprocessor.class - [JAR]

├─ com.getindata.connectors.http.internal.HeaderValuePreprocessor.class - [JAR]

├─ com.getindata.connectors.http.internal.PollingClient.class - [JAR]

├─ com.getindata.connectors.http.internal.PollingClientFactory.class - [JAR]

├─ com.getindata.connectors.http.internal.SinkHttpClient.class - [JAR]

├─ com.getindata.connectors.http.internal.SinkHttpClientBuilder.class - [JAR]

├─ com.getindata.connectors.http.internal.SinkHttpClientResponse.class - [JAR]

com.getindata.connectors.http.internal.sink

├─ com.getindata.connectors.http.internal.sink.HttpSinkInternal.class - [JAR]

├─ com.getindata.connectors.http.internal.sink.HttpSinkRequestEntry.class - [JAR]

├─ com.getindata.connectors.http.internal.sink.HttpSinkWriter.class - [JAR]

├─ com.getindata.connectors.http.internal.sink.HttpSinkWriterStateSerializer.class - [JAR]

com.getindata.connectors.http.internal.table.lookup

├─ com.getindata.connectors.http.internal.table.lookup.AsyncHttpTableLookupFunction.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.BodyBasedRequestFactory.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.GetRequestFactory.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.HttpLookupConfig.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.HttpLookupConnectorOptions.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.HttpLookupSourceRequestEntry.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.HttpLookupTableSource.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.HttpLookupTableSourceFactory.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.HttpRequestFactory.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.HttpTableLookupFunction.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.JavaNetHttpPollingClient.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.JavaNetHttpPollingClientFactory.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.LookupRow.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.LookupSchemaEntry.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.RequestFactoryBase.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.RowDataLookupSchemaEntryBase.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.RowDataSingleValueLookupSchemaEntry.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.RowTypeLookupSchemaEntry.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.Slf4JHttpLookupPostRequestCallback.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.TableSourceHelper.class - [JAR]

com.getindata.connectors.http.internal.sink.httpclient

├─ com.getindata.connectors.http.internal.sink.httpclient.AbstractRequestSubmitter.class - [JAR]

├─ com.getindata.connectors.http.internal.sink.httpclient.BatchRequestSubmitter.class - [JAR]

├─ com.getindata.connectors.http.internal.sink.httpclient.BatchRequestSubmitterFactory.class - [JAR]

├─ com.getindata.connectors.http.internal.sink.httpclient.HttpRequest.class - [JAR]

├─ com.getindata.connectors.http.internal.sink.httpclient.JavaNetHttpResponseWrapper.class - [JAR]

├─ com.getindata.connectors.http.internal.sink.httpclient.JavaNetSinkHttpClient.class - [JAR]

├─ com.getindata.connectors.http.internal.sink.httpclient.PerRequestRequestSubmitterFactory.class - [JAR]

├─ com.getindata.connectors.http.internal.sink.httpclient.PerRequestSubmitter.class - [JAR]

├─ com.getindata.connectors.http.internal.sink.httpclient.RequestSubmitter.class - [JAR]

├─ com.getindata.connectors.http.internal.sink.httpclient.RequestSubmitterFactory.class - [JAR]

com.getindata.connectors.http.internal.table.lookup.querycreators

├─ com.getindata.connectors.http.internal.table.lookup.querycreators.ElasticSearchLiteQueryCreator.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.querycreators.ElasticSearchLiteQueryCreatorFactory.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.querycreators.GenericGetQueryCreator.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.querycreators.GenericGetQueryCreatorFactory.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.querycreators.GenericJsonQueryCreator.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.querycreators.GenericJsonQueryCreatorFactory.class - [JAR]

├─ com.getindata.connectors.http.internal.table.lookup.querycreators.QueryFormatAwareConfiguration.class - [JAR]

com.getindata.connectors.http

├─ com.getindata.connectors.http.HttpPostRequestCallback.class - [JAR]

├─ com.getindata.connectors.http.HttpPostRequestCallbackFactory.class - [JAR]

├─ com.getindata.connectors.http.HttpSink.class - [JAR]

├─ com.getindata.connectors.http.HttpSinkBuilder.class - [JAR]

├─ com.getindata.connectors.http.LookupArg.class - [JAR]

├─ com.getindata.connectors.http.LookupQueryCreator.class - [JAR]

├─ com.getindata.connectors.http.LookupQueryCreatorFactory.class - [JAR]

├─ com.getindata.connectors.http.SchemaLifecycleAwareElementConverter.class - [JAR]

com.getindata.connectors.http.internal.table

├─ com.getindata.connectors.http.internal.table.SerializationSchemaElementConverter.class - [JAR]

org.apache.flink.configuration

├─ org.apache.flink.configuration.PrefixedConfigOption.class - [JAR]

com.getindata.connectors.http.internal.utils.uri

├─ com.getindata.connectors.http.internal.utils.uri.CharArrayBuffer.class - [JAR]

├─ com.getindata.connectors.http.internal.utils.uri.NameValuePair.class - [JAR]

├─ com.getindata.connectors.http.internal.utils.uri.ParserCursor.class - [JAR]

├─ com.getindata.connectors.http.internal.utils.uri.TokenParser.class - [JAR]

├─ com.getindata.connectors.http.internal.utils.uri.URIBuilder.class - [JAR]

├─ com.getindata.connectors.http.internal.utils.uri.URLEncodedUtils.class - [JAR]

com.getindata.connectors.http.internal.table.sink

├─ com.getindata.connectors.http.internal.table.sink.HttpDynamicSink.class - [JAR]

├─ com.getindata.connectors.http.internal.table.sink.HttpDynamicSinkConnectorOptions.class - [JAR]

├─ com.getindata.connectors.http.internal.table.sink.HttpDynamicTableSinkFactory.class - [JAR]

├─ com.getindata.connectors.http.internal.table.sink.Slf4jHttpPostRequestCallback.class - [JAR]

├─ com.getindata.connectors.http.internal.table.sink.Slf4jHttpPostRequestCallbackFactory.class - [JAR]