public class LoaderRequest extends VaultRequest
HTTP_HEADER_AUTHORIZATION, HTTP_HEADER_VAULT_CLIENT_ID, vaultClient
Modifier and Type | Method and Description |
---|---|
LoaderRequest |
addLoaderTask(LoaderTask loaderTask)
Add an individual Vault Loader Task to the request
Throws
IllegalArgumentException when maximum number of loader tasks is reached (10). |
LoaderRequest |
addLoaderTasks(List<LoaderTask> loaderTasks)
Add a full list of Vault Loader Tasks to the request
Throws
IllegalArgumentException when maximum number of loader tasks is reached (10). |
LoaderResponse |
extractDataFiles()
Extract Data Files
|
LoaderResponse |
loadDataObjects()
Load Data Objects
|
VaultResponse |
retrieveExtractRenditionResults(int jobId,
int taskId)
Retrieve Loader Extract Renditions Results
|
VaultResponse |
retrieveExtractResults(int jobId,
int taskId)
Retrieve Extract Results
|
VaultResponse |
retrieveLoadFailureLogResults(int jobId,
int taskId)
Retrieve Load Success Log Results
|
VaultResponse |
retrieveLoadSuccessLogResults(int jobId,
int taskId)
Retrieve Load Success Log Results
|
LoaderRequest |
setJson(String json)
Set a raw JSON string to the Vault Loader request
|
LoaderRequest |
setOutputPath(String outputPath)
Specify source data in an output file
|
LoaderRequest |
setSendNotification(Boolean sendNotification)
To send a Vault notification when the job completes, set to true.
|
getBaseObjectMapper, send, send, sendReturnBinary, sendReturnBinary, sendToFile, sendToFile, setVaultClient
public LoaderResponse extractDataFiles()
POST /api/{version}/services/loader/extract
public LoaderResponse loadDataObjects()
POST /api/{version}/services/loader/load
public VaultResponse retrieveExtractResults(int jobId, int taskId)
jobId
- The Job IdtaskId
- The Task IdGET /api/{version}/services/loader/{job_id}/tasks/{task_id}/results
public VaultResponse retrieveExtractRenditionResults(int jobId, int taskId)
jobId
- The Job IdtaskId
- The Task IdGET /api/{version}/services/loader/{job_id}/tasks/{task_id}/results/renditions
public VaultResponse retrieveLoadSuccessLogResults(int jobId, int taskId)
jobId
- The Job IdtaskId
- The Task IdGET /api/{version}/services/loader/{job_id}/tasks/{task_id}/successlog
public VaultResponse retrieveLoadFailureLogResults(int jobId, int taskId)
jobId
- The Job IdtaskId
- The Task IdGET /api/{version}/services/loader/{job_id}/tasks/{task_id}/failurelog
public LoaderRequest setJson(String json)
json
- Fully formed Vault Loader requestpublic LoaderRequest addLoaderTask(LoaderTask loaderTask) throws Exception
IllegalArgumentException
when maximum number of loader tasks is reached (10).loaderTask
- The Vault Loader Task to addException
- The exceptionpublic LoaderRequest addLoaderTasks(List<LoaderTask> loaderTasks) throws Exception
IllegalArgumentException
when maximum number of loader tasks is reached (10).loaderTasks
- The Vault Loader Task to addException
- maximum number of loader tasks exceededpublic LoaderRequest setOutputPath(String outputPath)
outputPath
- Absolute path to the file for the responsepublic LoaderRequest setSendNotification(Boolean sendNotification)
sendNotification
- send notification to userCopyright © 2021. All rights reserved.