Function getFileFormatValueForIcebergTable

core/utils.ts:332–349

(
  configFileFormat?: string,
)

 * @return File format used when creating an Iceberg table.
 */
export function getFileFormatValueForIcebergTable(
  configFileFormat?: string,
): dataform.FileFormat {
  if (!configFileFormat) {
    // Default to PARQUET if fileFormat is undefined.
    return dataform.FileFormat.PARQUET;
  }

  switch (configFileFormat.toUpperCase()) {
    case "PARQUET":
      return dataform.FileFormat.PARQUET;

    default:
      throw new Error(
        `File format ${configFileFormat} is not supported.`,
      );
  }
}

/**
 * Returns the connection for an Iceberg table, as specified in the user's config file.