WPI

Author: ypeckstadt

data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataexport/ExportManager.java

@@ -76,7 +76,6 @@ public ExportReport startExport(
     try {
       validateExportOptions(exportOptions, tableMetadata);
       Map<String, DataType> dataTypeByColumnName = tableMetadata.getColumnDataTypes();
-      handleTransactionMetadata(exportOptions, tableMetadata);
       processHeader(exportOptions, tableMetadata, writer);
 
       ExecutorService executorService =
@@ -198,21 +197,6 @@ private void validateExportOptions(ExportOptions exportOptions, TableMetadata ta
     ExportOptionsValidator.validate(exportOptions, tableMetadata);
   }
 
-  /**
-   * To update projection columns of export options if include metadata options is enabled
-   *
-   * @param exportOptions export options
-   * @param tableMetadata metadata of the table
-   */
-  private void handleTransactionMetadata(ExportOptions exportOptions, TableMetadata tableMetadata) {
-    if (!exportOptions.getProjectionColumns().isEmpty()) {
-      List<String> projectionMetadata =
-          TableMetadataUtil.populateProjectionsWithMetadata(
-              tableMetadata, exportOptions.getProjectionColumns());
-      exportOptions.setProjectionColumns(projectionMetadata);
-    }
-  }
-
   /**
    * To create a scanner object
    *

data-loader/core/src/main/java/com/scalar/db/dataloader/core/util/TableMetadataUtil.java

@@ -1,12 +1,7 @@
 package com.scalar.db.dataloader.core.util;
 
-import com.scalar.db.api.TableMetadata;
 import com.scalar.db.dataloader.core.Constants;
 import com.scalar.db.dataloader.core.dataimport.controlfile.ControlFileTable;
-import com.scalar.db.transaction.consensuscommit.Attribute;
-import com.scalar.db.transaction.consensuscommit.ConsensusCommitUtils;
-import java.util.ArrayList;
-import java.util.List;
 import lombok.AccessLevel;
 import lombok.NoArgsConstructor;
 
@@ -38,37 +33,4 @@ public static String getTableLookupKey(ControlFileTable controlFileTable) {
         controlFileTable.getNamespace(),
         controlFileTable.getTable());
   }
-
-  /**
-   * Adds metadata columns to a list of projection columns for a ScalarDB table.
-   *
-   * @param tableMetadata The metadata of the ScalarDB table.
-   * @param projections A list of projection column names.
-   * @return A new list containing projection columns along with metadata columns.
-   */
-  public static List<String> populateProjectionsWithMetadata(
-      TableMetadata tableMetadata, List<String> projections) {
-    List<String> projectionMetadata = new ArrayList<>();
-    projections.forEach(
-        projection -> {
-          projectionMetadata.add(projection);
-          if (!isKeyColumn(projection, tableMetadata)) {
-            projectionMetadata.add(Attribute.BEFORE_PREFIX + projection);
-          }
-        });
-    projectionMetadata.addAll(ConsensusCommitUtils.getTransactionMetaColumns().keySet());
-    return projectionMetadata;
-  }
-
-  /**
-   * Checks whether a column is a key column (partition key or clustering key) in the table.
-   *
-   * @param column The name of the column to check.
-   * @param tableMetadata The metadata of the ScalarDB table.
-   * @return {@code true} if the column is a key column; {@code false} otherwise.
-   */
-  private static boolean isKeyColumn(String column, TableMetadata tableMetadata) {
-    return tableMetadata.getPartitionKeyNames().contains(column)
-        || tableMetadata.getClusteringKeyNames().contains(column);
-  }
 }