source/src/main/java/com/amazonaws/comprehend/esproxy/lambda/processor/BulkProcessor.java [61:84]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    @NonNull
    private final ComprehendSerializer<JsonNode> ingestionSerializer;

    @NonNull
    private final AmazonComprehend comprehendClient;

    @NonNull
    private final OpenSearchServiceClient esClient;

    @NonNull
    private final ConfigRetriever configRetriever;

    @NonNull
    private final ExecutorService executorService;

    /**
     * Process Comprehend OpenSearchService Bulk requests
     *
     * @param request The received OpenSearchService client request
     * @param logger  The LambdaLogger to output logs from the function code
     * @return OpenSearchService service response
     */
    @Override
    public Response processRequest(@NonNull final Request request, @NonNull final LambdaLogger logger) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



source/src/main/java/com/amazonaws/comprehend/esproxy/lambda/processor/IndexProcessor.java [58:81]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    @NonNull
    private final ComprehendSerializer<JsonNode> ingestionSerializer;

    @NonNull
    private final AmazonComprehend comprehendClient;

    @NonNull
    private final OpenSearchServiceClient esClient;

    @NonNull
    private final ConfigRetriever configRetriever;

    @NonNull
    private final ExecutorService executorService;

    /**
     * Process Comprehend OpenSearchService proxy Index requests
     *
     * @param request The received OpenSearchService client request
     * @param logger  The LambdaLogger to output logs from the function code
     * @return OpenSearchService service response
     */
    @Override
    public Response processRequest(@NonNull final Request request, @NonNull final LambdaLogger logger) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -