NewInterStepDataForward creates an inter-step forwarder.

WithCallbackUploader sets the callback uploader for the vertex.

WithLogger is used to return logger information.

WithReadBatchSize sets the read batch size.

WithRetryInterval sets the retry interval.

WithUDFBatchMap enables the batch map for UDF if provided with a non-nil applier.

WithUDFConcurrency sets concurrency for map UDF processing.

WithUDFStreamingMap sets streaming for map UDF processing if provided with a non-nil applier.

WithUDFUnaryMap enables the unary map for UDF if provided with a non-nil applier.

InterStepDataForward forwards the data from previous step to the current step via inter-step buffer.

Shutdown tracks and enforces the shutdown activity.