A library you can include in your Spark job to validate the counters and perform operations on success. Goal is scala/java/python support. - View it on GitHub