Updates comments for copyTableQuery

airbytehq · Dec 6, 2022 · 162c86d · 162c86d
1 parent 46b377e
commit 162c86d
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...estination-jdbc/src/main/java/io/airbyte/integrations/destination/jdbc/SqlOperations.java b/...estination-jdbc/src/main/java/io/airbyte/integrations/destination/jdbc/SqlOperations.java
@@ -20,7 +20,7 @@
  *   <li>Create - overloaded function but primarily to create tables if they don't exist (e.g. tmp tables to "stage" records before finalizing
  *   to final table</li>
  *   <li>Drop - removes a table from the schema</li>
- *   <li>Copy - move data from one table to another table - usually used for copying data from tmp to final table (aka airbyte_raw)</li>
+ *   <li>Insert - move data from one table to another table - usually used for inserting data from tmp to final table (aka airbyte_raw)</li>
  * </ul>
  */
 public interface SqlOperations {

diff --git a/...dbc/src/main/java/io/airbyte/integrations/destination/staging/StagingConsumerFactory.java b/...dbc/src/main/java/io/airbyte/integrations/destination/staging/StagingConsumerFactory.java
@@ -196,7 +196,7 @@ private CheckedBiConsumer<AirbyteStreamNameNamespacePair, SerializableBuffer, Ex
    * Upon processing all {@link AirbyteMessage} wrap up lingering logic. This logic includes:
    * <li>Migrating data stored in staging area to temporary tables</li>
    * <li>Creates a final table (if one does not already exist)</li>
-   * <li>Copies all data from the temporary table into the final table</li>
+   * <li>Inserts all data from the temporary table into the final table</li>
    *
    * @param database database used for syncing
    * @param stagingOperations SQL queries used to write and delete data from the staging folder

diff --git a/...ion-jdbc/src/main/java/io/airbyte/integrations/destination/staging/StagingOperations.java b/...ion-jdbc/src/main/java/io/airbyte/integrations/destination/staging/StagingOperations.java
@@ -69,7 +69,7 @@ void copyIntoTmpTableFromStage(JdbcDatabase database,
    *
    * @param database database used for syncing
    * @param stageName name of staging area folder
-   * @param stagedFiles collection of the staging files
+   * @param stagedFiles collection of the staging files to remove
    */
   void cleanUpStage(JdbcDatabase database, String stageName, List<String> stagedFiles) throws Exception;