Package com.boomi.connector.sample.json
Class SizeLimitedJsonOperation
- 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.SizeLimitedJsonOperation
-
- All Implemented Interfaces:
Operation
public class SizeLimitedJsonOperation extends SizeLimitedUpdateOperation
SampleSizeLimitedUpdateOperation
that demonstrates binding the document input streams toJsonNode
instances. These instances are held entirely in memory but since this operation extendsSizeLimitedUpdateOperation
, any "large" inputs are filtered out before reaching this operation. Only a SINGLE input should be held in memory at a time. If a batch of all documents is required,SizeLimitedBatchJsonOperation
demonstrates how to combine documents using a streaming json writer.
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
SizeLimitedJsonOperation(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
-
SizeLimitedJsonOperation
protected SizeLimitedJsonOperation(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
-
-