Convertir Parquet FIXED_LEN_BYTE_ARRAY en DECIMAL carte natif Java réduire

Question

Mes données sous-jacente est écrit en utilisant le format de sortie HIVE (org.apache.hadoop.hive.ql.io.parquet.MapredParquetOutputFormat)

Essayer de lire ces données en utilisant Java natif la carte réduire

byte[] b = value.getBinary(value.getType().getFieldIndex(field), 0).getBytes(); 

HiveDecimal hd = HiveDecimal.create(b, true); 

valeur

est org.apache.parquet.example.data.Group hd type ici dans ce cas devient NULL.

Mais ci-dessous fonctionne très bien pour les types string/int.

value.getValueToString(value.getType().getFieldIndex(field), 0); 

Answer 1

Peu importe, je trouve un moyen à l'aide de DecimalUtils Parquet DECIMAL à la conversion Java BigDecimal en porc.

Ajouter lien Github link for DecimalUtils