Bq storage api (raystack#8)

* chore: version bump * chore: remove default addition of storage api
Meghajit · May 8, 2023 · e744184 · e744184
1 parent ed28420
commit e744184
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 6 deletions.
diff --git a/build.gradle b/build.gradle
@@ -33,7 +33,7 @@ lombok {
 }
 
 group 'com.gotocompany'
-version '0.8.5'
+version '0.8.6'
 
 def projName = "firehose"
 

diff --git a/src/main/java/com/gotocompany/firehose/sink/SinkFactory.java b/src/main/java/com/gotocompany/firehose/sink/SinkFactory.java
@@ -81,7 +81,6 @@ public void init() {
                 return;
             case BIGQUERY:
                 BigquerySinkUtils.addMetadataColumns(config);
-                BigquerySinkUtils.enableStorageAPI(config);
                 bigQuerySinkFactory = new BigQuerySinkFactory(
                         ConfigFactory.create(BigQuerySinkConfig.class, config),
                         statsDReporter,

diff --git a/src/main/java/com/gotocompany/firehose/sink/bigquery/BigquerySinkUtils.java b/src/main/java/com/gotocompany/firehose/sink/bigquery/BigquerySinkUtils.java
@@ -12,8 +12,4 @@ public static void addMetadataColumns(Map<String, String> config) {
         config.put("SINK_BIGQUERY_METADATA_COLUMNS_TYPES",
                 "message_offset=integer,message_topic=string,load_time=timestamp,message_timestamp=timestamp,message_partition=integer");
     }
-
-    public static void enableStorageAPI(Map<String, String> config) {
-        config.put("SINK_BIGQUERY_STORAGE_API_ENABLE", "true");
-    }
 }