Skip to content

Commit 2d4b9bf

Browse files
committed
refactoring
1 parent 02a56c3 commit 2d4b9bf

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

src/main/java/org/embulk/output/snowflake/SnowflakeCopyBatchInsert.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -40,15 +40,15 @@ public class SnowflakeCopyBatchInsert implements BatchInsert {
4040
private List<Future<Void>> uploadAndCopyFutures;
4141
private boolean emptyFieldAsNull;
4242

43-
private String[] insertColumnNames;
43+
private String[] copyIntoTableColumnNames;
4444

45-
private int[] insertCSVColumnNums;
45+
private int[] copyIntoCSVColumnNumbers;
4646

4747
public SnowflakeCopyBatchInsert(
4848
JdbcOutputConnector connector,
4949
StageIdentifier stageIdentifier,
50-
String[] insertColumnNames,
51-
int[] insertCSVColumnNums,
50+
String[] copyIntoTableColumnNames,
51+
int[] copyIntoCSVColumnNumbers,
5252
boolean deleteStageFile,
5353
int maxUploadRetries,
5454
boolean emptyFieldAsNull)
@@ -57,8 +57,8 @@ public SnowflakeCopyBatchInsert(
5757
openNewFile();
5858
this.connector = connector;
5959
this.stageIdentifier = stageIdentifier;
60-
this.insertColumnNames = insertColumnNames;
61-
this.insertCSVColumnNums = insertCSVColumnNums;
60+
this.copyIntoTableColumnNames = copyIntoTableColumnNames;
61+
this.copyIntoCSVColumnNumbers = copyIntoCSVColumnNumbers;
6262
this.executorService = Executors.newCachedThreadPool();
6363
this.deleteStageFile = deleteStageFile;
6464
this.uploadAndCopyFutures = new ArrayList();
@@ -426,8 +426,8 @@ public Void call() throws SQLException, InterruptedException, ExecutionException
426426
tableIdentifier,
427427
stageIdentifier,
428428
snowflakeStageFileName,
429-
insertColumnNames,
430-
insertCSVColumnNums,
429+
copyIntoTableColumnNames,
430+
copyIntoCSVColumnNumbers,
431431
delimiterString,
432432
emptyFieldAsNull);
433433

0 commit comments

Comments
 (0)