Commit 3edb32e4 authored by Noel Alonso's avatar Noel Alonso
Browse files

Cambia clave de agregación

De esta manera se agregan todas las áreas con el mismo geoHashCode
parent d91f9475
Loading
Loading
Loading
Loading
+3 −2
Original line number Diff line number Diff line
@@ -17,14 +17,15 @@ public class AvroUtils {
	}

	public static HashMap<String, GenericRecord> aggregateGenericRecordInMap(String k, GenericRecord v,
			HashMap<String, GenericRecord> map) {
		map.put(k, v);
			HashMap<String, GenericRecord> map, String aggregateKey) {
		map.put(v.get(aggregateKey).toString(), v);
		return map;
	}

	public static GenericRecord getGenericRecordFromClass(Type classs) {

		Schema schema = ReflectData.get().getSchema(classs);

		return new GenericData.Record(schema);
	}
}