@@ -46,7 +46,7 @@ public class DecoderRecode extends Decoder
4646 private static final long serialVersionUID = -3784249774608228805L ;
4747
4848 private HashMap <Long , Object >[] _rcMaps = null ;
49- private Object [][] _rcMapsDirect = null ;
49+ // private Object[][] _rcMapsDirect = null;
5050 private boolean _onOut = false ;
5151
5252 public DecoderRecode () {
@@ -59,9 +59,10 @@ protected DecoderRecode(ValueType[] schema, boolean onOut, int[] rcCols) {
5959 }
6060
6161 public Object getRcMapValue (int i , long key ) {
62- LOG .error (_rcMapsDirect );
63- return (_rcMapsDirect != null ) ?
64- _rcMapsDirect [i ][(int )key -1 ] : _rcMaps [i ].get (key );
62+ // LOG.error(_rcMapsDirect);
63+ // return (_rcMapsDirect != null) ?
64+ // _rcMapsDirect[i][(int)key-1] :
65+ return _rcMaps [i ].get (key );
6566 }
6667
6768 @ Override
@@ -142,15 +143,15 @@ public void initMetaData(FrameBlock meta) {
142143 }
143144
144145 //convert to direct lookup arrays
145- if ( Arrays .stream (max ).allMatch (v -> v < Integer .MAX_VALUE ) ) {
146- _rcMapsDirect = new Object [_rcMaps .length ][];
147- for ( int i =0 ; i <_rcMaps .length ; i ++ ) {
148- Object [] arr = new Object [(int )max [i ]];
149- for (Entry <Long ,Object > e1 : _rcMaps [i ].entrySet ())
150- arr [e1 .getKey ().intValue ()-1 ] = e1 .getValue ();
151- _rcMapsDirect [i ] = arr ;
152- }
153- }
146+ // if( Arrays.stream(max).allMatch(v -> v < Integer.MAX_VALUE) ) {
147+ // _rcMapsDirect = new Object[_rcMaps.length][];
148+ // for( int i=0; i<_rcMaps.length; i++ ) {
149+ // Object[] arr = new Object[(int)max[i]];
150+ // for(Entry<Long,Object> e1 : _rcMaps[i].entrySet())
151+ // arr[e1.getKey().intValue()-1] = e1.getValue();
152+ // _rcMapsDirect[i] = arr;
153+ // }
154+ // }
154155 }
155156
156157 /**
0 commit comments