Default sqoop validator and how to change

Question

Hi. I am trying to add a validator to sqoop. I have read that it only compares the number of rows in the source and destination. I want to know which validator sqoop uses to check this. And also, I have written my own validator. How can I use this validator instead of the default?

Answer 1

The default validator used is  org.apache.sqoop.validation.RowCountValidator. If you want to use a custom validator, then you have to mention the validator class in the sqoop import command. Refer to the below syntax:

$ sqoop import <all other parameters> --validator <class_name>