question: @ 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 ; }
target:  Restores the checkpointed operator.