Method Stop

api.go:72–72

Force the input to stop as clean as possible, at a good boundary. This is usually issued at the user's request of exiting the process. For instance, it might make sense to finish processing the current batch of data or the current file, and then save in stable storage the checkpoint to resume it lat

()

	// batch of data or the current file, and then save in stable storage
	// the checkpoint to resume it later.
	Stop()

	// Return stats about the input
	Stats() InputStats