public Object decode ( Decoder decoder ) throws IOException { try { return outputGenerator . read ( decoder , schema ) ; } catch ( IOException e ) { LOG . error ( "Cannot instantiate object of type {}" , outputClass . getName ( ) , e ) ; throw e ; } }
This function is called for each incoming byte record .