jar

com.wepay.kcbq : kcbq-connector

Maven & Gradle

Sep 11, 2020
1 usages
155 stars

Kafka Connect BigQuery Connector · A Kafka Connector used to load data into BigQuery

Table Of Contents

Latest Version

Download com.wepay.kcbq : kcbq-connector JAR file - Latest Versions:

All Versions

Download com.wepay.kcbq : kcbq-connector JAR file - All Versions:

Version Vulnerabilities Size Updated
2.0.x
1.6.x
1.5.x
1.4.x
1.3.x
1.1.x
1.0.x
0.4.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 kcbq-connector-2.0.0-alpha.jar file.
    Once you open a JAR file, all the java classes in the JAR file will be displayed.

com.wepay.kafka.connect.bigquery.convert

├─ com.wepay.kafka.connect.bigquery.convert.BigQueryRecordConverter.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.convert.BigQuerySchemaConverter.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.convert.KafkaDataBuilder.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.convert.RecordConverter.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.convert.SchemaConverter.class - [JAR]

com.wepay.kafka.connect.bigquery.utils

├─ com.wepay.kafka.connect.bigquery.utils.FieldNameSanitizer.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.utils.PartitionedTableId.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.utils.SinkRecordConverter.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.utils.Version.class - [JAR]

com.wepay.kafka.connect.bigquery

├─ com.wepay.kafka.connect.bigquery.BigQueryHelper.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.BigQuerySinkConnector.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.BigQuerySinkTask.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.GCSBuilder.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.GCSToBQLoadRunnable.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.SchemaManager.class - [JAR]

com.wepay.kafka.connect.bigquery.retrieve

├─ com.wepay.kafka.connect.bigquery.retrieve.IdentitySchemaRetriever.class - [JAR]

com.wepay.kafka.connect.bigquery.write.row

├─ com.wepay.kafka.connect.bigquery.write.row.AdaptiveBigQueryWriter.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.write.row.BigQueryWriter.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.write.row.GCSToBQWriter.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.write.row.SimpleBigQueryWriter.class - [JAR]

com.wepay.kafka.connect.bigquery.exception

├─ com.wepay.kafka.connect.bigquery.exception.BigQueryConnectException.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.exception.ConversionConnectException.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.exception.GCSConnectException.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.exception.SinkConfigConnectException.class - [JAR]

com.wepay.kafka.connect.bigquery.write.batch

├─ com.wepay.kafka.connect.bigquery.write.batch.CountDownRunnable.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.write.batch.GCSBatchTableWriter.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.write.batch.KCBQThreadPoolExecutor.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.write.batch.TableWriter.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.write.batch.TableWriterBuilder.class - [JAR]

com.wepay.kafka.connect.bigquery.config

├─ com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.config.BigQuerySinkTaskConfig.class - [JAR]

com.wepay.kafka.connect.bigquery.convert.logicaltype

├─ com.wepay.kafka.connect.bigquery.convert.logicaltype.DebeziumLogicalConverters.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.convert.logicaltype.KafkaLogicalConverters.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.convert.logicaltype.LogicalConverterRegistry.class - [JAR]

├─ com.wepay.kafka.connect.bigquery.convert.logicaltype.LogicalTypeConverter.class - [JAR]

Advertisement