Called when stopping to process one partition of new data in the executor side.
the error thrown during processing data or null if there was no error.
Called when starting to process one partition of new data in the executor.
the partition id.
a unique id for data deduplication.
true if the corresponding partition and version id should be processed.
indicates the partition should be skipped.
Called to process the data in the executor side.