Escritura masiva de filas
Catalyst te permite realizar trabajos de escritura masiva en una tabla específica presente en Data Store. La operación de escritura masiva puede obtener miles de registros de un archivo CSV subido en Stratus e insertarlos en una tabla específica. La tabla se identifica por su Table ID único. La columna en la que se debe realizar la operación de escritura se identifica por su ID de columna único.
Nota: Para realizar una operación de escritura masiva, primero debes subir los datos requeridos como un archivo CSV en Stratus.
Durante el trabajo de escritura, el archivo se referenciará usando los siguientes atributos:
* bucketName: El nombre del bucket, donde se almacena el objeto.
* objectKey: Puede contener la ruta o la URL del objeto del objeto requerido.
* versionID: Si el bucket tiene el versionado habilitado, entonces el versionID específico del archivo se almacenará en este atributo.
Estos detalles deberán resolverse como un objeto JSON llamado objectDetails, y pasarse al método setObjectDetails().
Catalyst soporta los siguientes métodos para escritura masiva en Java SDK:
| Método utilizado | Descripción |
|---|---|
| createBulkWriteJob(bulkWriteDetails) | Crear un nuevo trabajo de escritura masiva en una tabla específica. | createInsertBulkWriteJob(table ID, objectDetails) | Crear un nuevo trabajo de inserción de escritura masiva. |
| createUpsertBulkWriteJob(tableId, objectDetails, column ID) | Crear un nuevo trabajo de upsert de escritura masiva. |
| getBulkWriteJobDetails(jobID) | Obtener el estado y los resultados de un trabajo de escritura masiva. |
Package Imports
copy
import com.zc.component.object.bulk.ZCBulkWriteServices;
import com.zc.component.object.bulk.ZCDataStoreBulk;
import com.zc.component.object.bulk.result.ZCBulkResult;
import com.zc.component.object.bulk.ZCBucketObjectDetails;
import com.zc.component.object.bulk.ZCBulkWriteDetails copy
ZCBulkWriteServices bulkWrite = ZCDataStoreBulk.getInstance().getBulkWriteInstance();
// crear instancia de escritura masiva
ZCBulkWriteDetails bulkWriteDetails = ZCBulkWriteDetails.getInstance();
// crear y llenar el objeto de detalles de escritura masiva
bulkWriteDetails.setTableIdentifier(12096000000642178L); // Proporciona tu Table ID
bulkWriteDetails.setObjectDetails(objectDetails);
ZCBulkResult bulkWriteResult = bulkWrite.createBulkWriteJob(bulkWriteDetails);
// crear trabajo de escritura masiva
bulkWrite.createInsertBulkWriteJob(12096000000642178L, objectDetails); // Proporciona tu Table ID
// crear trabajo de inserción de escritura masiva
bulkWrite.createUpdateBulkWriteJob(12096000000642178L, objectDetails, 12096000000642900L); // Proporciona tu Table ID y Column ID
// crear trabajo de inserción de escritura masiva
bulkWrite.createUpsertBulkWriteJob(12096000000642178L, objectDetails, 12096000000642900L); // Proporciona tu Table ID y Column ID
// crear trabajo de upsert de escritura masiva
bulkWrite.getBulkWriteJobStatus(bulkWriteResult.getJobId());
// obtener el estado y resultados del trabajo de escritura masiva
Nota: Se puede escribir un máximo de 100,000 filas simultáneamente usando el método createBulkWriteJob().
Última actualización 2026-03-30 13:40:30 +0530 IST
Yes
No
Thank you for your feedback!
Send your feedback to us
Skip
Submit