private RowMap processHeartbeats(RowMap row) throws SQLException {
  String hbClientID=(String)row.getData("client_id");
  if (!Objects.equals(hbClientID,this.clientID))   return row;
  Object heartbeat_at=row.getData("heartbeat_at");
  Object old_heartbeat_at=row.getOldData("heartbeat_at");
  if (heartbeat_at != null && old_heartbeat_at != null) {
    Long thisHeartbeat=(Long)heartbeat_at;
    if (!thisHeartbeat.equals(lastHeartbeatRead)) {
      this.lastHeartbeatRead=thisHeartbeat;
      return HeartbeatRowMap.valueOf(row.getDatabase(),row.getPosition(),thisHeartbeat);
    }
  }
  return row;
}

private RowMap processHeartbeats ( RowMap row ) throws SQLException { String hbClientID = ( String ) row . getData ( "client_id" ) ; if ( ! Objects . equals ( hbClientID , this . clientID ) ) return row ; Object heartbeat_at = row . getData ( "heartbeat_at" ) ; Object old_heartbeat_at = row . getOldData ( "heartbeat_at" ) ; if ( heartbeat_at != null && old_heartbeat_at != null ) { Long thisHeartbeat = ( Long ) heartbeat_at ; if ( ! thisHeartbeat . equals ( lastHeartbeatRead ) ) { this . lastHeartbeatRead = thisHeartbeat ; return HeartbeatRowMap . valueOf ( row . getDatabase ( ) , row . getPosition ( ) , thisHeartbeat ) ; } } return row ; }
possibly convert a rowmap object into a heartbeatrowmap process a rowmap that represents a write to ` maxwell ` . ` positions ` . if it ' s a write for a different client_id , or it ' s not a heartbeat , we return just the rowmap . otherwise , we transform it into a heartbeatrowmap and set lastheartbeatread .
