File tree 2 files changed +6
-6
lines changed
kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/config
2 files changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -154,7 +154,7 @@ BigQuery Sink Connector Configuration Options
154
154
* Importance: medium
155
155
156
156
``useStorageWriteApi ``
157
- Use Google's New Storage Write API for data streaming. Not available for upsert/delete mode
157
+ (Beta feature: use with caution) Use Google's New Storage Write API for data streaming. Not available for upsert/delete mode
158
158
159
159
* Type: boolean
160
160
* Default: false
@@ -187,7 +187,7 @@ BigQuery Sink Connector Configuration Options
187
187
188
188
* Type: list
189
189
* Default: null
190
- * Valid Values: com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig$$Lambda/0x000000d8014d0440@325a48a1
190
+ * Valid Values: com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig$$Lambda/0x000000f001235108@5d9f3e38
191
191
* Importance: low
192
192
193
193
``commitInterval ``
@@ -273,7 +273,7 @@ BigQuery Sink Connector Configuration Options
273
273
274
274
* Type: long
275
275
* Default: null
276
- * Valid Values: com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig$$Lambda/0x000000d8014d0890@7f1de728
276
+ * Valid Values: com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig$$Lambda/0x000000f001235558@16147134
277
277
* Importance: low
278
278
279
279
``timestampPartitionFieldName ``
@@ -289,7 +289,7 @@ BigQuery Sink Connector Configuration Options
289
289
290
290
* Type: string
291
291
* Default: ""
292
- * Valid Values: com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig$$Lambda/0x000000d8014cf200@7dad73ea
292
+ * Valid Values: com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig$$Lambda/0x000000f001234000@69a3b76d
293
293
* Importance: low
294
294
295
295
``upsertEnabled ``
@@ -324,7 +324,7 @@ Common
324
324
325
325
* Type: string
326
326
* Default: DAY
327
- * Valid Values: com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig$$Lambda/0x000000d8014d75e8@4065faf5
327
+ * Valid Values: com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig$$Lambda/0x000000f001239e90@356a0fbe
328
328
* Importance: low
329
329
330
330
Original file line number Diff line number Diff line change @@ -340,7 +340,7 @@ public class BigQuerySinkConfig extends AbstractConfig {
340
340
private static final ConfigDef .Type USE_STORAGE_WRITE_API_TYPE = ConfigDef .Type .BOOLEAN ;
341
341
private static final ConfigDef .Importance USE_STORAGE_WRITE_API_IMPORTANCE = ConfigDef .Importance .MEDIUM ;
342
342
private static final String USE_STORAGE_WRITE_API_DOC =
343
- "Use Google's New Storage Write API for data streaming. Not available for upsert/delete mode" ;
343
+ "(Beta feature: use with caution) Use Google's New Storage Write API for data streaming. Not available for upsert/delete mode" ;
344
344
private static final ConfigDef .Type ENABLE_BATCH_MODE_TYPE = ConfigDef .Type .BOOLEAN ;
345
345
private static final ConfigDef .Importance ENABLE_BATCH_MODE_IMPORTANCE = ConfigDef .Importance .LOW ;
346
346
private static final String ENABLE_BATCH_MODE_DOC = "Use Google's New Storage Write API with batch mode" ;
You can’t perform that action at this time.
0 commit comments