RunnableInterface

Default implementation of batch, which calls invoke N times. Subclasses should override this method if they can batch more efficiently.

Method to invoke the document transformation. This method calls the transformDocuments method with the provided input.

Stream output in chunks.

Default implementation of transform, which buffers input and then calls stream. Subclasses should override this method if they can start producing output while input is still being generated.