handleOutput

suspend fun handleOutput(inputKey: K1, checkpointCounts: Map<CheckpointId, CheckpointValue>, output: U, inputCount: Long, context: PipelineContext? = null)