String getFieldPath ( String columnName , Map < String , String > columnsToField , int op ) { return columnsToField . get ( columnName ) ; }
This function simply returns field path in record for the corresponding column name . This is needed because records generated by CDC origins store data in different location for different operation . Subclasses will override this function and implement special handling .