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 by BaseUpdateOperation.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 and Description
protected	SizeLimitedBatchJsonOperation(OperationContext context)

Method Summary

Modifier and Type	Method and 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 class SizeLimitedUpdateOperation

Parameters:

request - the filtered request

response - the operation response