@ Override public void readIntegers ( int total , WritableColumnVector c , int rowId ) { int left = total ; while ( left > 0 ) { if ( this . currentCount == 0 ) this . readNextGroup ( ) ; int n = Math . min ( left , this . currentCount ) ; switch ( mode ) { case RLE : c . putInts ( rowId , n , currentValue ) ; break ; case PACKED : c . putInts ( rowId , n , currentBuffer , currentBufferIdx ) ; currentBufferIdx += n ; break ; } rowId += n ; left -= n ; currentCount -= n ; } }
Since this is only used to decode dictionary IDs only decoding integers is supported .