@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);
  }
}

@ 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 ) ; } }
distinct count aggregate function which update the distinct count
