@@ -60,16 +60,27 @@ public FrameBlock decode(MatrixBlock in, FrameBlock out) {
6060
6161 @ Override
6262 public void decode (MatrixBlock in , FrameBlock out , int rl , int ru ) {
63- int clen = Math .min (_colList .length , out .getNumColumns ());
64- for ( int i =rl ; i <ru ; i ++ ) {
65- for ( int j =0 ; j <clen ; j ++ ) {
66- int srcColID = _srcCols [j ];
67- int tgtColID = _colList [j ];
68- double val = in .get (i , srcColID -1 );
69- out .set (i , tgtColID -1 ,
70- UtilFunctions .doubleToObject (_schema [tgtColID -1 ], val ));
63+ try {
64+
65+ int clen = Math .min (_colList .length , out .getNumColumns ());
66+ for ( int i =rl ; i <ru ; i ++ ) {
67+ for ( int j =0 ; j <clen ; j ++ ) {
68+ int srcColID = _srcCols [j ];
69+ int tgtColID = _colList [j ];
70+ double val = in .get (i , srcColID -1 );
71+ out .set (i , tgtColID -1 ,
72+ UtilFunctions .doubleToObject (_schema [tgtColID -1 ], val ));
73+ }
7174 }
7275 }
76+ catch (Exception e ){
77+ String decode_cols = Arrays .toString (_dcCols );
78+ String source_cols = Arrays .toString (_srcCols );
79+
80+ // LOG.error(Arrays.toString(_dcCols));
81+ // LOG.error(Arrays.toString( ))
82+ throw new RuntimeException ("Failed decoding with decode: " + decode_cols + " and source : " + source_cols ,e );
83+ }
7384 }
7485
7586 @ Override
0 commit comments