Commit 4a7fa00a authored by Noel Alonso's avatar Noel Alonso
Browse files

Cambia avro schema de geometry de bytes a string 

De esta manera el connect puede deserializarlo y elasticsearch reconoce la
geometría
parent 35b543bb

vessels-lib/src/main/java/es/redmic/vesselslib/dto/tracking/VesselTrackingDTO.java

+5 −4
Original line number Diff line number Diff line 
package es.redmic.vesselslib.dto.tracking;



import java.io.IOException;

import java.nio.ByteBuffer;



import org.apache.avro.Schema;

import org.locationtech.jts.geom.Point;
@@ -24,7 +23,7 @@ public class VesselTrackingDTO extends FeatureDTO<VesselTrackingPropertiesDTO, P 
					+ "\"type\":\"enum\",\"name\":\"GeoJSONFeatureType\"," + 

						"\"symbols\":[\"FEATURE\"]}},"

				+ "{\"name\":\"properties\",\"type\":" + VesselTrackingPropertiesDTO.SCHEMA$.toString() + "},"

				+ "{\"name\":\"geometry\",\"type\":[\"bytes\", \"null\"]},"

				+ "{\"name\":\"geometry\",\"type\":[\"string\", \"null\"]},"

				+ "{\"name\":\"id\",\"type\":\"string\"}"

			+ "]}");
@@ -53,7 +52,7 @@ public class VesselTrackingDTO extends FeatureDTO<VesselTrackingPropertiesDTO, P 
			return getProperties();

		case 3:

			try {

				return ByteBuffer.wrap(mapper.writeValueAsBytes(getGeometry()));

				return mapper.writeValueAsString(getGeometry());

			} catch (JsonProcessingException e) {

				e.printStackTrace();

				return null;
@@ -82,7 +81,9 @@ public class VesselTrackingDTO extends FeatureDTO<VesselTrackingPropertiesDTO, P 
			break;

		case 3:

			try {

				setGeometry(mapper.readValue(((ByteBuffer) value).array(), Point.class));

				if (value != null) {

					setGeometry(mapper.readValue((value.toString()), Point.class));

				}

			} catch (IOException e) {

				e.printStackTrace();

			}