@SuppressWarnings({"unchecked","rawtypes"}) public static LineByLineFileInputOperator restoreCheckPoint(LineByLineFileInputOperator checkPointOper,ByteArrayOutputStream bos) throws Exception {
  Kryo kryo=new Kryo();
  Input lInput=new Input(bos.toByteArray());
  LineByLineFileInputOperator oper=kryo.readObject(lInput,checkPointOper.getClass());
  lInput.close();
  return oper;
}

@ SuppressWarnings ( { "unchecked" , "rawtypes" } ) public static LineByLineFileInputOperator restoreCheckPoint ( LineByLineFileInputOperator checkPointOper , ByteArrayOutputStream bos ) throws Exception { Kryo kryo = new Kryo ( ) ; Input lInput = new Input ( bos . toByteArray ( ) ) ; LineByLineFileInputOperator oper = kryo . readObject ( lInput , checkPointOper . getClass ( ) ) ; lInput . close ( ) ; return oper ; }
restores the checkpointed operator .
