question: public SetChangelogMapping ( String source , String taskName , int changelogPartitionNumber ) { super ( source ) ; setType ( TYPE ) ; setKey ( taskName ) ; putMessageValue ( CHANGELOG_VALUE_KEY , String . valueOf ( changelogPartitionNumber ) ) ; }
target:  The change log mapping message is used to store changelog partition information for a given task name.