Vaibhav Kumar
07/19/2021, 10:03 AMSubodh (Airbyte)
MySqlSource class. If you see the main method of MySqlSource,
public static void main(String[] args) throws Exception {
final Source source = new MySqlSource();
<http://LOGGER.info|LOGGER.info>("starting source: {}", MySqlSource.class);
new IntegrationRunner(source).run(args);
<http://LOGGER.info|LOGGER.info>("completed source: {}", MySqlSource.class);
}
You will see that the read method of MySqlSource is being triggered. MySqlSource extends AbstractJdbcSource which further extends AbstractRelationalDbSource and thats where the read method is present.