wepay / kafka-connect-bigquery

DEPRECATED. PLEASE USE https://github.com/confluentinc/kafka-connect-bigquery. A Kafka Connect BigQuery sink connector
Apache License 2.0
155 stars 192 forks source link

Generalize schema retriever #291

Closed sahithi03 closed 4 years ago

sahithi03 commented 4 years ago

Changes made according to the Github issue - #245

CLAassistant commented 4 years ago

CLA assistant check
All committers have signed the CLA.

codecov-commenter commented 4 years ago

Codecov Report

Merging #291 into generalization-feature will decrease coverage by 4.76%. The diff coverage is 45.68%.

@@                     Coverage Diff                      @@
##             generalization-feature     #291      +/-   ##
============================================================
- Coverage                     70.87%   66.10%   -4.77%     
+ Complexity                      301      267      -34     
============================================================
  Files                            32       32              
  Lines                          1538     1484      -54     
  Branches                        164      152      -12     
============================================================
- Hits                           1090      981     -109     
- Misses                          390      450      +60     
+ Partials                         58       53       -5     
Impacted Files Coverage Δ Complexity Δ
.../kafka/connect/bigquery/BigQuerySinkConnector.java 78.37% <ø> (+10.45%) 11.00 <0.00> (-3.00) :arrow_up:
...ect/bigquery/retrieve/IdentitySchemaRetriever.java 0.00% <0.00%> (ø) 0.00 <0.00> (?)
...om/wepay/kafka/connect/bigquery/SchemaManager.java 28.28% <4.28%> (-48.19%) 6.00 <0.00> (-3.00)
...afka/connect/bigquery/write/row/GCSToBQWriter.java 80.00% <25.00%> (ø) 13.00 <1.00> (ø)
...ect/bigquery/write/row/AdaptiveBigQueryWriter.java 39.68% <40.00%> (-0.95%) 6.00 <1.00> (ø)
...wepay/kafka/connect/bigquery/BigQuerySinkTask.java 57.21% <48.57%> (-1.74%) 27.00 <7.00> (ø)
...ka/connect/bigquery/utils/SinkRecordConverter.java 66.66% <66.66%> (ø) 3.00 <3.00> (?)
...onnect/bigquery/config/BigQuerySinkTaskConfig.java 95.38% <75.00%> (-0.21%) 14.00 <0.00> (ø)
...ka/connect/bigquery/config/BigQuerySinkConfig.java 78.94% <90.47%> (-2.83%) 16.00 <1.00> (-13.00)
...nect/bigquery/write/batch/GCSBatchTableWriter.java 86.20% <100.00%> (-0.46%) 3.00 <2.00> (ø)
... and 5 more