Fixed compile

Author: podgaietska

kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/config/BigQuerySinkConfig.java

@@ -1214,6 +1214,10 @@ public boolean isUpsertDeleteEnabled() {
     return getBoolean(UPSERT_ENABLED_CONFIG) || getBoolean(DELETE_ENABLED_CONFIG);
   }
 
+  public boolean isIgnoreUnknownFields() {
+    return getBoolean(BigQuerySinkConfig.IGNORE_UNKNOWN_FIELDS_CONFIG);
+  }
+
   public Optional<TimePartitioning.Type> getTimePartitioningType() {
     return parseTimePartitioningType(getString(TIME_PARTITIONING_TYPE_CONFIG));
   }

kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/write/row/AdaptiveBigQueryWriter.java

@@ -86,17 +86,17 @@ public AdaptiveBigQueryWriter(BigQuery bigQuery,
   }
 
   /**
-   * @deprecated This constructor does not support configuration of additional write settings.
-   * Use {@link #AdaptiveBigQueryWriter(BigQuery bigQuery, SchemaManager schemaManager, int retry, long retryWait,
-   * boolean autoCreateTables, ErrantRecordHandler errantRecordHandler, Time time, BigQuerySinkConfig config)}.
-   *
    * @param bigQuery            Used to send write requests to BigQuery.
    * @param schemaManager       Used to update BigQuery tables.
    * @param retry               How many retries to make in the event of a 500/503 error.
    * @param retryWait           How long to wait in between retries.
    * @param autoCreateTables    Whether tables should be automatically created
    * @param errantRecordHandler Used to handle errant records
    * @param time                used to wait during backoff periods
+   *
+   * @deprecated This constructor does not support configuration of additional write settings.
+   * Use {@link #AdaptiveBigQueryWriter(BigQuery bigQuery, SchemaManager schemaManager, int retry, long retryWait,
+   * boolean autoCreateTables, ErrantRecordHandler errantRecordHandler, Time time, BigQuerySinkConfig config)}.
    */
   @Deprecated
   public AdaptiveBigQueryWriter(BigQuery bigQuery,

kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/write/row/BigQueryWriter.java

@@ -75,20 +75,20 @@ public BigQueryWriter(int retries, long retryWaitMs, ErrantRecordHandler errantR
     this.random = new Random();
     this.errantRecordHandler = errantRecordHandler;
     this.time = time;
-    this.ignoreUnknownFields = config.getBoolean(BigQuerySinkConfig.IGNORE_UNKNOWN_FIELDS_CONFIG);
+    this.ignoreUnknownFields = config.isIgnoreUnknownFields();
   }
 
   /**
-   * @deprecated This constructor does not support configuration of additional write settings.
-   * Use {@link #BigQueryWriter(int retries, long retryWaitMs, ErrantRecordHandler errantRecordHandler,
-   * Time time, BigQuerySinkConfig config)} instead.
-   *
    * @param retries             the number of times to retry a request if BQ returns an internal service error
    *                            or a service unavailable error.
    * @param retryWaitMs         the amount of time to wait in between reattempting a request if BQ returns
    *                            an internal service error or a service unavailable error.
    * @param errantRecordHandler used to handle errant records
    * @param time                used to wait during backoff periods
+   *
+   * @deprecated This constructor does not support configuration of additional write settings.
+   * Use {@link #BigQueryWriter(int retries, long retryWaitMs, ErrantRecordHandler errantRecordHandler,
+   * Time time, BigQuerySinkConfig config)} instead.
    */
   @Deprecated
   public BigQueryWriter(int retries, long retryWaitMs, ErrantRecordHandler errantRecordHandler, Time time) {

kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/write/row/SimpleBigQueryWriter.java

@@ -63,15 +63,15 @@ public SimpleBigQueryWriter(BigQuery bigQuery, int retry, long retryWait, Errant
   }
 
   /**
-   * @deprecated This constructor does not support configuration of additional write settings.
-   * Use {@link #SimpleBigQueryWriter(BigQuery bigQuery, int retry, long retryWait, ErrantRecordHandler errantRecordHandler,
-   * Time time, BigQuerySinkConfig config)}.
-   *
    * @param bigQuery            The object used to send write requests to BigQuery.
    * @param retry               How many retries to make in the event of a 500/503 error.
    * @param retryWait           How long to wait in between retries.
    * @param errantRecordHandler Used to handle errant records
    * @param time                used to wait during backoff periods
+   *
+   * @deprecated This constructor does not support configuration of additional write settings.
+   * Use {@link #SimpleBigQueryWriter(BigQuery bigQuery, int retry, long retryWait, ErrantRecordHandler errantRecordHandler,
+   * Time time, BigQuerySinkConfig config)}.
    */
   @Deprecated
   public SimpleBigQueryWriter(BigQuery bigQuery, int retry, long retryWait, ErrantRecordHandler errantRecordHandler,

kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/write/row/UpsertDeleteBigQueryWriter.java

@@ -77,11 +77,6 @@ public UpsertDeleteBigQueryWriter(BigQuery bigQuery,
   }
 
   /**
-   * @deprecated This constructor does not support configuration of additional write settings.
-   * Use {@link #UpsertDeleteBigQueryWriter(BigQuery bigQuery, SchemaManager schemaManager, int retry,
-   * long retryWait, boolean autoCreateTables, Map intermediateToDestinationTables,
-   * ErrantRecordHandler errantRecordHandler, Time time, BigQuerySinkConfig config)} instead.
-   *
    * @param bigQuery                        Used to send write requests to BigQuery.
    * @param schemaManager                   Used to update BigQuery tables.
    * @param retry                           How many retries to make in the event of a 500/503 error.
@@ -93,6 +88,11 @@ public UpsertDeleteBigQueryWriter(BigQuery bigQuery,
    *                                        table
    * @param errantRecordHandler             Used to handle errant records
    * @param time                            used to wait during backoff periods
+   *
+   * @deprecated This constructor does not support configuration of additional write settings.
+   * Use {@link #UpsertDeleteBigQueryWriter(BigQuery bigQuery, SchemaManager schemaManager, int retry,
+   * long retryWait, boolean autoCreateTables, Map intermediateToDestinationTables,
+   * ErrantRecordHandler errantRecordHandler, Time time, BigQuerySinkConfig config)} instead.
    */
   @Deprecated
   public UpsertDeleteBigQueryWriter(BigQuery bigQuery,

kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/write/storage/StorageWriteApiBase.java

@@ -98,7 +98,7 @@ protected StorageWriteApiBase(int retry,
     this.errantRecordHandler = errantRecordHandler;
     this.schemaManager = schemaManager;
     this.attemptSchemaUpdate = attemptSchemaUpdate;
-    this.ignoreUnknownFields = config.getBoolean(BigQuerySinkConfig.IGNORE_UNKNOWN_FIELDS_CONFIG);
+    this.ignoreUnknownFields = config.isIgnoreUnknownFields();
     try {
       this.writeClient = getWriteClient();
     } catch (IOException e) {
@@ -110,16 +110,16 @@ protected StorageWriteApiBase(int retry,
   }
 
   /**
-   * @deprecated This constructor does not support does not support configuration of additional write settings.
-   * Use {@link #StorageWriteApiBase(int retry, long retryWait, BigQueryWriteSettings writeSettings,
-   * boolean autoCreateTables, ErrantRecordHandler errantRecordHandler, SchemaManager schemaManager,
-   * boolean attemptSchemaUpdate, BigQuerySinkConfig config)} instead.
-   *
    * @param retry               How many retries to make in the event of a retriable error.
    * @param retryWait           How long to wait in between retries.
    * @param writeSettings       Write Settings for stream which carry authentication and other header information
    * @param autoCreateTables    boolean flag set if table should be created automatically
    * @param errantRecordHandler Used to handle errant records
+   *
+   * @deprecated This constructor does not support does not support configuration of additional write settings.
+   * Use {@link #StorageWriteApiBase(int retry, long retryWait, BigQueryWriteSettings writeSettings,
+   * boolean autoCreateTables, ErrantRecordHandler errantRecordHandler, SchemaManager schemaManager,
+   * boolean attemptSchemaUpdate, BigQuerySinkConfig config)} instead.
    */
   @Deprecated
   protected StorageWriteApiBase(int retry,