question: @ Override public void agg ( Object newVal ) { if ( newVal instanceof byte [ ] ) { byte [ ] values = ( byte [ ] ) newVal ; ByteBuffer buffer = ByteBuffer . wrap ( values ) ; buffer . rewind ( ) ; while ( buffer . hasRemaining ( ) ) { valueSet . add ( buffer . getInt ( ) ) ; } return ; } else { double value = new Double ( newVal . toString ( ) ) ; agg ( value ) ; } }
target:  Distinct count Aggregate function which update the Distinct count