Skip to content

Commit d9ebe7b

Browse files
authored
Merge pull request #63 from trocco-io/change-create-empty-table-logic
2 parents 80301d2 + 6fdd489 commit d9ebe7b

File tree

1 file changed

+9
-3
lines changed

1 file changed

+9
-3
lines changed

src/main/java/org/embulk/output/bigquery_java/BigqueryJavaOutputPlugin.java

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -61,9 +61,15 @@ public ConfigDiff transaction(ConfigSource config,
6161
if (paths.isEmpty()) {
6262
logger.info("embulk-output-bigquery: Nothing for transfer");
6363
client.createTableIfNotExist(task.getTable(), task.getDataset());
64-
// append, replace, delete_in_advance
65-
if (! "append_direct".equals(task.getMode())) {
66-
client.deleteTable(task.getTempTable().get());
64+
65+
switch (task.getMode()){
66+
case "append":
67+
case "replace":
68+
case "delete_in_advance":
69+
if(task.getTempTable().isPresent()){
70+
client.deleteTable(task.getTempTable().get());
71+
}
72+
break;
6773
}
6874

6975
return Exec.newConfigDiff();

0 commit comments

Comments
 (0)