Package com.boomi.connector.sample.json
Class SizeLimitedBatchJsonOperation
- java.lang.Object
-
- com.boomi.connector.util.ContextualOperation
-
- com.boomi.connector.util.BaseOperation
-
- com.boomi.connector.util.BaseUpdateOperation
-
- com.boomi.connector.util.SizeLimitedUpdateOperation
-
- com.boomi.connector.sample.json.SizeLimitedBatchJsonOperation
-
- All Implemented Interfaces:
Operation
public class SizeLimitedBatchJsonOperation extends SizeLimitedUpdateOperation
Sample update operation that builds a JSON array containing the input documents in a memory efficient manner. Individual documents the exceed the allowed size are filtered out byBaseUpdateOperation.execute(com.boomi.connector.api.OperationRequest, OperationResponse)
. A streaming writer is used to build the array to avoid loading multiple input documents into memory at the same time.
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
SizeLimitedBatchJsonOperation(OperationContext context)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
executeSizeLimitedUpdate(UpdateRequest request, OperationResponse response)
Execute the implementation update logic-
Methods inherited from class com.boomi.connector.util.SizeLimitedUpdateOperation
executeUpdate, getSizeExceededMessage, getSizeExceededStatusCode, includeSizeExceededPayload
-
Methods inherited from class com.boomi.connector.util.BaseUpdateOperation
execute
-
Methods inherited from class com.boomi.connector.util.ContextualOperation
getConnection, getContext
-
-
-
-
Constructor Detail
-
SizeLimitedBatchJsonOperation
protected SizeLimitedBatchJsonOperation(OperationContext context)
-
-
Method Detail
-
executeSizeLimitedUpdate
protected void executeSizeLimitedUpdate(UpdateRequest request, OperationResponse response)
Description copied from class:SizeLimitedUpdateOperation
Execute the implementation update logic- Specified by:
executeSizeLimitedUpdate
in classSizeLimitedUpdateOperation
- Parameters:
request
- the filtered requestresponse
- the operation response
-
-