Merge pull request #14933 from cbuescher/shapes-refactor-point
Make PointBuilder, CircleBuilder & EnvelopeBuilder implement Writable
This commit is contained in:
commit
e507ef807a
|
@ -21,17 +21,23 @@ package org.elasticsearch.common.geo.builders;
|
||||||
|
|
||||||
import com.spatial4j.core.shape.Circle;
|
import com.spatial4j.core.shape.Circle;
|
||||||
import com.vividsolutions.jts.geom.Coordinate;
|
import com.vividsolutions.jts.geom.Coordinate;
|
||||||
|
|
||||||
|
import org.elasticsearch.common.io.stream.StreamInput;
|
||||||
|
import org.elasticsearch.common.io.stream.StreamOutput;
|
||||||
import org.elasticsearch.common.unit.DistanceUnit;
|
import org.elasticsearch.common.unit.DistanceUnit;
|
||||||
import org.elasticsearch.common.unit.DistanceUnit.Distance;
|
import org.elasticsearch.common.unit.DistanceUnit.Distance;
|
||||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
public class CircleBuilder extends ShapeBuilder {
|
public class CircleBuilder extends ShapeBuilder {
|
||||||
|
|
||||||
public static final String FIELD_RADIUS = "radius";
|
public static final String FIELD_RADIUS = "radius";
|
||||||
public static final GeoShapeType TYPE = GeoShapeType.CIRCLE;
|
public static final GeoShapeType TYPE = GeoShapeType.CIRCLE;
|
||||||
|
|
||||||
|
public static final CircleBuilder PROTOTYPE = new CircleBuilder();
|
||||||
|
|
||||||
private DistanceUnit unit;
|
private DistanceUnit unit;
|
||||||
private double radius;
|
private double radius;
|
||||||
private Coordinate center;
|
private Coordinate center;
|
||||||
|
@ -57,6 +63,13 @@ public class CircleBuilder extends ShapeBuilder {
|
||||||
return center(new Coordinate(lon, lat));
|
return center(new Coordinate(lon, lat));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Get the center of the circle
|
||||||
|
*/
|
||||||
|
public Coordinate center() {
|
||||||
|
return center;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Set the radius of the circle. The String value will be parsed by {@link DistanceUnit}
|
* Set the radius of the circle. The String value will be parsed by {@link DistanceUnit}
|
||||||
* @param radius Value and unit of the circle combined in a string
|
* @param radius Value and unit of the circle combined in a string
|
||||||
|
@ -97,10 +110,24 @@ public class CircleBuilder extends ShapeBuilder {
|
||||||
return this;
|
return this;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Get the radius of the circle without unit
|
||||||
|
*/
|
||||||
|
public double radius() {
|
||||||
|
return this.radius;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Get the radius unit of the circle
|
||||||
|
*/
|
||||||
|
public DistanceUnit unit() {
|
||||||
|
return this.unit;
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
||||||
builder.startObject();
|
builder.startObject();
|
||||||
builder.field(FIELD_TYPE, TYPE.shapename);
|
builder.field(FIELD_TYPE, TYPE.shapeName());
|
||||||
builder.field(FIELD_RADIUS, unit.toString(radius));
|
builder.field(FIELD_RADIUS, unit.toString(radius));
|
||||||
builder.field(FIELD_COORDINATES);
|
builder.field(FIELD_COORDINATES);
|
||||||
toXContent(builder, center);
|
toXContent(builder, center);
|
||||||
|
@ -116,4 +143,37 @@ public class CircleBuilder extends ShapeBuilder {
|
||||||
public GeoShapeType type() {
|
public GeoShapeType type() {
|
||||||
return TYPE;
|
return TYPE;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(center, radius, unit.ordinal());
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (this == obj) {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
if (obj == null || getClass() != obj.getClass()) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
CircleBuilder other = (CircleBuilder) obj;
|
||||||
|
return Objects.equals(center, other.center) &&
|
||||||
|
Objects.equals(radius, other.radius) &&
|
||||||
|
Objects.equals(unit.ordinal(), other.unit.ordinal());
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void writeTo(StreamOutput out) throws IOException {
|
||||||
|
writeCoordinateTo(center, out);
|
||||||
|
out.writeDouble(radius);
|
||||||
|
DistanceUnit.writeDistanceUnit(out, unit);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public CircleBuilder readFrom(StreamInput in) throws IOException {
|
||||||
|
return new CircleBuilder()
|
||||||
|
.center(readCoordinateFrom(in))
|
||||||
|
.radius(in.readDouble(), DistanceUnit.readDistanceUnit(in));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -21,13 +21,19 @@ package org.elasticsearch.common.geo.builders;
|
||||||
|
|
||||||
import com.spatial4j.core.shape.Rectangle;
|
import com.spatial4j.core.shape.Rectangle;
|
||||||
import com.vividsolutions.jts.geom.Coordinate;
|
import com.vividsolutions.jts.geom.Coordinate;
|
||||||
|
|
||||||
|
import org.elasticsearch.common.io.stream.StreamInput;
|
||||||
|
import org.elasticsearch.common.io.stream.StreamOutput;
|
||||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
import java.util.Locale;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
public class EnvelopeBuilder extends ShapeBuilder {
|
public class EnvelopeBuilder extends ShapeBuilder {
|
||||||
|
|
||||||
public static final GeoShapeType TYPE = GeoShapeType.ENVELOPE;
|
public static final GeoShapeType TYPE = GeoShapeType.ENVELOPE;
|
||||||
|
public static final EnvelopeBuilder PROTOTYPE = new EnvelopeBuilder();
|
||||||
|
|
||||||
protected Coordinate topLeft;
|
protected Coordinate topLeft;
|
||||||
protected Coordinate bottomRight;
|
protected Coordinate bottomRight;
|
||||||
|
@ -61,7 +67,8 @@ public class EnvelopeBuilder extends ShapeBuilder {
|
||||||
@Override
|
@Override
|
||||||
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
||||||
builder.startObject();
|
builder.startObject();
|
||||||
builder.field(FIELD_TYPE, TYPE.shapename);
|
builder.field(FIELD_TYPE, TYPE.shapeName());
|
||||||
|
builder.field(FIELD_ORIENTATION, orientation.name().toLowerCase(Locale.ROOT));
|
||||||
builder.startArray(FIELD_COORDINATES);
|
builder.startArray(FIELD_COORDINATES);
|
||||||
toXContent(builder, topLeft);
|
toXContent(builder, topLeft);
|
||||||
toXContent(builder, bottomRight);
|
toXContent(builder, bottomRight);
|
||||||
|
@ -78,4 +85,38 @@ public class EnvelopeBuilder extends ShapeBuilder {
|
||||||
public GeoShapeType type() {
|
public GeoShapeType type() {
|
||||||
return TYPE;
|
return TYPE;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(orientation, topLeft, bottomRight);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (this == obj) {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
if (obj == null || getClass() != obj.getClass()) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
EnvelopeBuilder other = (EnvelopeBuilder) obj;
|
||||||
|
return Objects.equals(orientation, other.orientation) &&
|
||||||
|
Objects.equals(topLeft, other.topLeft) &&
|
||||||
|
Objects.equals(bottomRight, other.bottomRight);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void writeTo(StreamOutput out) throws IOException {
|
||||||
|
out.writeBoolean(orientation == Orientation.RIGHT);
|
||||||
|
writeCoordinateTo(topLeft, out);
|
||||||
|
writeCoordinateTo(bottomRight, out);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public EnvelopeBuilder readFrom(StreamInput in) throws IOException {
|
||||||
|
Orientation orientation = in.readBoolean() ? Orientation.RIGHT : Orientation.LEFT;
|
||||||
|
return new EnvelopeBuilder(orientation)
|
||||||
|
.topLeft(readCoordinateFrom(in))
|
||||||
|
.bottomRight(readCoordinateFrom(in));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -102,7 +102,7 @@ public class GeometryCollectionBuilder extends ShapeBuilder {
|
||||||
@Override
|
@Override
|
||||||
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
||||||
builder.startObject();
|
builder.startObject();
|
||||||
builder.field(FIELD_TYPE, TYPE.shapename);
|
builder.field(FIELD_TYPE, TYPE.shapeName());
|
||||||
builder.startArray(FIELD_GEOMETRIES);
|
builder.startArray(FIELD_GEOMETRIES);
|
||||||
for (ShapeBuilder shape : shapes) {
|
for (ShapeBuilder shape : shapes) {
|
||||||
shape.toXContent(builder, params);
|
shape.toXContent(builder, params);
|
||||||
|
|
|
@ -39,7 +39,7 @@ public class LineStringBuilder extends PointCollection<LineStringBuilder> {
|
||||||
@Override
|
@Override
|
||||||
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
||||||
builder.startObject();
|
builder.startObject();
|
||||||
builder.field(FIELD_TYPE, TYPE.shapename);
|
builder.field(FIELD_TYPE, TYPE.shapeName());
|
||||||
builder.field(FIELD_COORDINATES);
|
builder.field(FIELD_COORDINATES);
|
||||||
coordinatesToXcontent(builder, false);
|
coordinatesToXcontent(builder, false);
|
||||||
builder.endObject();
|
builder.endObject();
|
||||||
|
|
|
@ -57,7 +57,7 @@ public class MultiLineStringBuilder extends ShapeBuilder {
|
||||||
@Override
|
@Override
|
||||||
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
||||||
builder.startObject();
|
builder.startObject();
|
||||||
builder.field(FIELD_TYPE, TYPE.shapename);
|
builder.field(FIELD_TYPE, TYPE.shapeName());
|
||||||
builder.field(FIELD_COORDINATES);
|
builder.field(FIELD_COORDINATES);
|
||||||
builder.startArray();
|
builder.startArray();
|
||||||
for(LineStringBuilder line : lines) {
|
for(LineStringBuilder line : lines) {
|
||||||
|
|
|
@ -37,7 +37,7 @@ public class MultiPointBuilder extends PointCollection<MultiPointBuilder> {
|
||||||
@Override
|
@Override
|
||||||
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
||||||
builder.startObject();
|
builder.startObject();
|
||||||
builder.field(FIELD_TYPE, TYPE.shapename);
|
builder.field(FIELD_TYPE, TYPE.shapeName());
|
||||||
builder.field(FIELD_COORDINATES);
|
builder.field(FIELD_COORDINATES);
|
||||||
super.coordinatesToXcontent(builder, false);
|
super.coordinatesToXcontent(builder, false);
|
||||||
builder.endObject();
|
builder.endObject();
|
||||||
|
|
|
@ -51,7 +51,7 @@ public class MultiPolygonBuilder extends ShapeBuilder {
|
||||||
@Override
|
@Override
|
||||||
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
||||||
builder.startObject();
|
builder.startObject();
|
||||||
builder.field(FIELD_TYPE, TYPE.shapename);
|
builder.field(FIELD_TYPE, TYPE.shapeName());
|
||||||
builder.startArray(FIELD_COORDINATES);
|
builder.startArray(FIELD_COORDINATES);
|
||||||
for(PolygonBuilder polygon : polygons) {
|
for(PolygonBuilder polygon : polygons) {
|
||||||
builder.startArray();
|
builder.startArray();
|
||||||
|
|
|
@ -20,7 +20,10 @@
|
||||||
package org.elasticsearch.common.geo.builders;
|
package org.elasticsearch.common.geo.builders;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
|
import org.elasticsearch.common.io.stream.StreamInput;
|
||||||
|
import org.elasticsearch.common.io.stream.StreamOutput;
|
||||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||||
|
|
||||||
import com.spatial4j.core.shape.Point;
|
import com.spatial4j.core.shape.Point;
|
||||||
|
@ -30,6 +33,8 @@ public class PointBuilder extends ShapeBuilder {
|
||||||
|
|
||||||
public static final GeoShapeType TYPE = GeoShapeType.POINT;
|
public static final GeoShapeType TYPE = GeoShapeType.POINT;
|
||||||
|
|
||||||
|
public static final PointBuilder PROTOTYPE = new PointBuilder();
|
||||||
|
|
||||||
private Coordinate coordinate;
|
private Coordinate coordinate;
|
||||||
|
|
||||||
public PointBuilder coordinate(Coordinate coordinate) {
|
public PointBuilder coordinate(Coordinate coordinate) {
|
||||||
|
@ -48,7 +53,7 @@ public class PointBuilder extends ShapeBuilder {
|
||||||
@Override
|
@Override
|
||||||
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
||||||
builder.startObject();
|
builder.startObject();
|
||||||
builder.field(FIELD_TYPE, TYPE.shapename);
|
builder.field(FIELD_TYPE, TYPE.shapeName());
|
||||||
builder.field(FIELD_COORDINATES);
|
builder.field(FIELD_COORDINATES);
|
||||||
toXContent(builder, coordinate);
|
toXContent(builder, coordinate);
|
||||||
return builder.endObject();
|
return builder.endObject();
|
||||||
|
@ -63,4 +68,31 @@ public class PointBuilder extends ShapeBuilder {
|
||||||
public GeoShapeType type() {
|
public GeoShapeType type() {
|
||||||
return TYPE;
|
return TYPE;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(coordinate);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (this == obj) {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
if (obj == null || getClass() != obj.getClass()) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
PointBuilder other = (PointBuilder) obj;
|
||||||
|
return Objects.equals(coordinate, other.coordinate);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void writeTo(StreamOutput out) throws IOException {
|
||||||
|
writeCoordinateTo(coordinate, out);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public PointBuilder readFrom(StreamInput in) throws IOException {
|
||||||
|
return new PointBuilder().coordinate(readCoordinateFrom(in));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -172,7 +172,7 @@ public class PolygonBuilder extends ShapeBuilder {
|
||||||
@Override
|
@Override
|
||||||
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
|
||||||
builder.startObject();
|
builder.startObject();
|
||||||
builder.field(FIELD_TYPE, TYPE.shapename);
|
builder.field(FIELD_TYPE, TYPE.shapeName());
|
||||||
builder.startArray(FIELD_COORDINATES);
|
builder.startArray(FIELD_COORDINATES);
|
||||||
coordinatesArray(builder, params);
|
coordinatesArray(builder, params);
|
||||||
builder.endArray();
|
builder.endArray();
|
||||||
|
|
|
@ -26,8 +26,12 @@ import com.spatial4j.core.shape.jts.JtsGeometry;
|
||||||
import com.vividsolutions.jts.geom.Coordinate;
|
import com.vividsolutions.jts.geom.Coordinate;
|
||||||
import com.vividsolutions.jts.geom.Geometry;
|
import com.vividsolutions.jts.geom.Geometry;
|
||||||
import com.vividsolutions.jts.geom.GeometryFactory;
|
import com.vividsolutions.jts.geom.GeometryFactory;
|
||||||
|
|
||||||
import org.elasticsearch.ElasticsearchParseException;
|
import org.elasticsearch.ElasticsearchParseException;
|
||||||
import org.elasticsearch.action.support.ToXContentToBytes;
|
import org.elasticsearch.action.support.ToXContentToBytes;
|
||||||
|
import org.elasticsearch.common.io.stream.NamedWriteable;
|
||||||
|
import org.elasticsearch.common.io.stream.StreamInput;
|
||||||
|
import org.elasticsearch.common.io.stream.StreamOutput;
|
||||||
import org.elasticsearch.common.logging.ESLogger;
|
import org.elasticsearch.common.logging.ESLogger;
|
||||||
import org.elasticsearch.common.logging.ESLoggerFactory;
|
import org.elasticsearch.common.logging.ESLoggerFactory;
|
||||||
import org.elasticsearch.common.unit.DistanceUnit.Distance;
|
import org.elasticsearch.common.unit.DistanceUnit.Distance;
|
||||||
|
@ -43,7 +47,7 @@ import java.util.*;
|
||||||
/**
|
/**
|
||||||
* Basic class for building GeoJSON shapes like Polygons, Linestrings, etc
|
* Basic class for building GeoJSON shapes like Polygons, Linestrings, etc
|
||||||
*/
|
*/
|
||||||
public abstract class ShapeBuilder extends ToXContentToBytes {
|
public abstract class ShapeBuilder extends ToXContentToBytes implements NamedWriteable<ShapeBuilder> {
|
||||||
|
|
||||||
protected static final ESLogger LOGGER = ESLoggerFactory.getLogger(ShapeBuilder.class.getName());
|
protected static final ESLogger LOGGER = ESLoggerFactory.getLogger(ShapeBuilder.class.getName());
|
||||||
|
|
||||||
|
@ -173,6 +177,15 @@ public abstract class ShapeBuilder extends ToXContentToBytes {
|
||||||
return builder.startArray().value(coordinate.x).value(coordinate.y).endArray();
|
return builder.startArray().value(coordinate.x).value(coordinate.y).endArray();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
protected static void writeCoordinateTo(Coordinate coordinate, StreamOutput out) throws IOException {
|
||||||
|
out.writeDouble(coordinate.x);
|
||||||
|
out.writeDouble(coordinate.y);
|
||||||
|
}
|
||||||
|
|
||||||
|
protected Coordinate readCoordinateFrom(StreamInput in) throws IOException {
|
||||||
|
return new Coordinate(in.readDouble(), in.readDouble());
|
||||||
|
}
|
||||||
|
|
||||||
public static Orientation orientationFromString(String orientation) {
|
public static Orientation orientationFromString(String orientation) {
|
||||||
orientation = orientation.toLowerCase(Locale.ROOT);
|
orientation = orientation.toLowerCase(Locale.ROOT);
|
||||||
switch (orientation) {
|
switch (orientation) {
|
||||||
|
@ -565,12 +578,16 @@ public abstract class ShapeBuilder extends ToXContentToBytes {
|
||||||
ENVELOPE("envelope"),
|
ENVELOPE("envelope"),
|
||||||
CIRCLE("circle");
|
CIRCLE("circle");
|
||||||
|
|
||||||
protected final String shapename;
|
private final String shapename;
|
||||||
|
|
||||||
private GeoShapeType(String shapename) {
|
private GeoShapeType(String shapename) {
|
||||||
this.shapename = shapename;
|
this.shapename = shapename;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
protected String shapeName() {
|
||||||
|
return shapename;
|
||||||
|
}
|
||||||
|
|
||||||
public static GeoShapeType forName(String geoshapename) {
|
public static GeoShapeType forName(String geoshapename) {
|
||||||
String typename = geoshapename.toLowerCase(Locale.ROOT);
|
String typename = geoshapename.toLowerCase(Locale.ROOT);
|
||||||
for (GeoShapeType type : values()) {
|
for (GeoShapeType type : values()) {
|
||||||
|
@ -823,4 +840,20 @@ public abstract class ShapeBuilder extends ToXContentToBytes {
|
||||||
return geometryCollection;
|
return geometryCollection;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public String getWriteableName() {
|
||||||
|
return type().shapeName();
|
||||||
|
}
|
||||||
|
|
||||||
|
// NORELEASE this should be deleted as soon as all shape builders implement writable
|
||||||
|
@Override
|
||||||
|
public void writeTo(StreamOutput out) throws IOException {
|
||||||
|
}
|
||||||
|
|
||||||
|
// NORELEASE this should be deleted as soon as all shape builders implement writable
|
||||||
|
@Override
|
||||||
|
public ShapeBuilder readFrom(StreamInput in) throws IOException {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -0,0 +1,144 @@
|
||||||
|
/*
|
||||||
|
* Licensed to Elasticsearch under one or more contributor
|
||||||
|
* license agreements. See the NOTICE file distributed with
|
||||||
|
* this work for additional information regarding copyright
|
||||||
|
* ownership. Elasticsearch licenses this file to you under
|
||||||
|
* the Apache License, Version 2.0 (the "License"); you may
|
||||||
|
* not use this file except in compliance with the License.
|
||||||
|
* You may obtain a copy of the License at
|
||||||
|
*
|
||||||
|
* http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
*
|
||||||
|
* Unless required by applicable law or agreed to in writing,
|
||||||
|
* software distributed under the License is distributed on an
|
||||||
|
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
||||||
|
* KIND, either express or implied. See the License for the
|
||||||
|
* specific language governing permissions and limitations
|
||||||
|
* under the License.
|
||||||
|
*/
|
||||||
|
|
||||||
|
package org.elasticsearch.common.geo.builders;
|
||||||
|
|
||||||
|
import org.elasticsearch.common.io.stream.BytesStreamOutput;
|
||||||
|
import org.elasticsearch.common.io.stream.NamedWriteableAwareStreamInput;
|
||||||
|
import org.elasticsearch.common.io.stream.NamedWriteableRegistry;
|
||||||
|
import org.elasticsearch.common.io.stream.StreamInput;
|
||||||
|
import org.elasticsearch.common.xcontent.*;
|
||||||
|
import org.elasticsearch.test.ESTestCase;
|
||||||
|
import org.junit.AfterClass;
|
||||||
|
import org.junit.BeforeClass;
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
|
|
||||||
|
import static org.hamcrest.Matchers.*;
|
||||||
|
|
||||||
|
public abstract class AbstractShapeBuilderTestCase<SB extends ShapeBuilder> extends ESTestCase {
|
||||||
|
|
||||||
|
private static final int NUMBER_OF_TESTBUILDERS = 20;
|
||||||
|
private static NamedWriteableRegistry namedWriteableRegistry;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* setup for the whole base test class
|
||||||
|
*/
|
||||||
|
@BeforeClass
|
||||||
|
public static void init() {
|
||||||
|
if (namedWriteableRegistry == null) {
|
||||||
|
namedWriteableRegistry = new NamedWriteableRegistry();
|
||||||
|
namedWriteableRegistry.registerPrototype(ShapeBuilder.class, PointBuilder.PROTOTYPE);
|
||||||
|
namedWriteableRegistry.registerPrototype(ShapeBuilder.class, CircleBuilder.PROTOTYPE);
|
||||||
|
namedWriteableRegistry.registerPrototype(ShapeBuilder.class, EnvelopeBuilder.PROTOTYPE);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@AfterClass
|
||||||
|
public static void afterClass() throws Exception {
|
||||||
|
namedWriteableRegistry = null;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* create random shape that is put under test
|
||||||
|
*/
|
||||||
|
protected abstract SB createTestShapeBuilder();
|
||||||
|
|
||||||
|
/**
|
||||||
|
* mutate the given shape so the returned shape is different
|
||||||
|
*/
|
||||||
|
protected abstract SB mutate(SB original) throws IOException;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Test that creates new shape from a random test shape and checks both for equality
|
||||||
|
*/
|
||||||
|
public void testFromXContent() throws IOException {
|
||||||
|
for (int runs = 0; runs < NUMBER_OF_TESTBUILDERS; runs++) {
|
||||||
|
SB testShape = createTestShapeBuilder();
|
||||||
|
XContentBuilder contentBuilder = XContentFactory.contentBuilder(randomFrom(XContentType.values()));
|
||||||
|
if (randomBoolean()) {
|
||||||
|
contentBuilder.prettyPrint();
|
||||||
|
}
|
||||||
|
XContentBuilder builder = testShape.toXContent(contentBuilder, ToXContent.EMPTY_PARAMS);
|
||||||
|
XContentParser shapeParser = XContentHelper.createParser(builder.bytes());
|
||||||
|
XContentHelper.createParser(builder.bytes());
|
||||||
|
shapeParser.nextToken();
|
||||||
|
ShapeBuilder parsedShape = ShapeBuilder.parse(shapeParser);
|
||||||
|
assertNotSame(testShape, parsedShape);
|
||||||
|
assertEquals(testShape, parsedShape);
|
||||||
|
assertEquals(testShape.hashCode(), parsedShape.hashCode());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Test serialization and deserialization of the test shape.
|
||||||
|
*/
|
||||||
|
public void testSerialization() throws IOException {
|
||||||
|
for (int runs = 0; runs < NUMBER_OF_TESTBUILDERS; runs++) {
|
||||||
|
SB testShape = createTestShapeBuilder();
|
||||||
|
SB deserializedShape = copyShape(testShape);
|
||||||
|
assertEquals(deserializedShape, testShape);
|
||||||
|
assertEquals(deserializedShape.hashCode(), testShape.hashCode());
|
||||||
|
assertNotSame(deserializedShape, testShape);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Test equality and hashCode properties
|
||||||
|
*/
|
||||||
|
public void testEqualsAndHashcode() throws IOException {
|
||||||
|
for (int runs = 0; runs < NUMBER_OF_TESTBUILDERS; runs++) {
|
||||||
|
SB firstShape = createTestShapeBuilder();
|
||||||
|
assertFalse("shape is equal to null", firstShape.equals(null));
|
||||||
|
assertFalse("shape is equal to incompatible type", firstShape.equals(""));
|
||||||
|
assertTrue("shape is not equal to self", firstShape.equals(firstShape));
|
||||||
|
assertThat("same shape's hashcode returns different values if called multiple times", firstShape.hashCode(),
|
||||||
|
equalTo(firstShape.hashCode()));
|
||||||
|
assertThat("different shapes should not be equal", mutate(firstShape), not(equalTo(firstShape)));
|
||||||
|
assertThat("different shapes should have different hashcode", mutate(firstShape).hashCode(), not(equalTo(firstShape.hashCode())));
|
||||||
|
|
||||||
|
SB secondShape = copyShape(firstShape);
|
||||||
|
assertTrue("shape is not equal to self", secondShape.equals(secondShape));
|
||||||
|
assertTrue("shape is not equal to its copy", firstShape.equals(secondShape));
|
||||||
|
assertTrue("equals is not symmetric", secondShape.equals(firstShape));
|
||||||
|
assertThat("shape copy's hashcode is different from original hashcode", secondShape.hashCode(), equalTo(firstShape.hashCode()));
|
||||||
|
|
||||||
|
SB thirdShape = copyShape(secondShape);
|
||||||
|
assertTrue("shape is not equal to self", thirdShape.equals(thirdShape));
|
||||||
|
assertTrue("shape is not equal to its copy", secondShape.equals(thirdShape));
|
||||||
|
assertThat("shape copy's hashcode is different from original hashcode", secondShape.hashCode(), equalTo(thirdShape.hashCode()));
|
||||||
|
assertTrue("equals is not transitive", firstShape.equals(thirdShape));
|
||||||
|
assertThat("shape copy's hashcode is different from original hashcode", firstShape.hashCode(), equalTo(thirdShape.hashCode()));
|
||||||
|
assertTrue("equals is not symmetric", thirdShape.equals(secondShape));
|
||||||
|
assertTrue("equals is not symmetric", thirdShape.equals(firstShape));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
protected SB copyShape(SB original) throws IOException {
|
||||||
|
try (BytesStreamOutput output = new BytesStreamOutput()) {
|
||||||
|
original.writeTo(output);
|
||||||
|
try (StreamInput in = new NamedWriteableAwareStreamInput(StreamInput.wrap(output.bytes()), namedWriteableRegistry)) {
|
||||||
|
ShapeBuilder prototype = (ShapeBuilder) namedWriteableRegistry.getPrototype(ShapeBuilder.class, original.getWriteableName());
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
|
SB copy = (SB) prototype.readFrom(in);
|
||||||
|
return copy;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,58 @@
|
||||||
|
/*
|
||||||
|
* Licensed to Elasticsearch under one or more contributor
|
||||||
|
* license agreements. See the NOTICE file distributed with
|
||||||
|
* this work for additional information regarding copyright
|
||||||
|
* ownership. Elasticsearch licenses this file to you under
|
||||||
|
* the Apache License, Version 2.0 (the "License"); you may
|
||||||
|
* not use this file except in compliance with the License.
|
||||||
|
* You may obtain a copy of the License at
|
||||||
|
*
|
||||||
|
* http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
*
|
||||||
|
* Unless required by applicable law or agreed to in writing,
|
||||||
|
* software distributed under the License is distributed on an
|
||||||
|
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
||||||
|
* KIND, either express or implied. See the License for the
|
||||||
|
* specific language governing permissions and limitations
|
||||||
|
* under the License.
|
||||||
|
*/
|
||||||
|
|
||||||
|
package org.elasticsearch.common.geo.builders;
|
||||||
|
|
||||||
|
import com.vividsolutions.jts.geom.Coordinate;
|
||||||
|
|
||||||
|
import org.elasticsearch.common.unit.DistanceUnit;
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
|
|
||||||
|
public class CirlceBuilderTests extends AbstractShapeBuilderTestCase<CircleBuilder> {
|
||||||
|
|
||||||
|
@Override
|
||||||
|
protected CircleBuilder createTestShapeBuilder() {
|
||||||
|
double centerX = randomDoubleBetween(-180, 180, false);
|
||||||
|
double centerY = randomDoubleBetween(-90, 90, false);
|
||||||
|
return new CircleBuilder()
|
||||||
|
.center(new Coordinate(centerX, centerY))
|
||||||
|
.radius(randomDoubleBetween(0.1, 10.0, false), randomFrom(DistanceUnit.values()));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
protected CircleBuilder mutate(CircleBuilder original) throws IOException {
|
||||||
|
CircleBuilder mutation = copyShape(original);
|
||||||
|
double radius = original.radius();
|
||||||
|
DistanceUnit unit = original.unit();
|
||||||
|
|
||||||
|
if (randomBoolean()) {
|
||||||
|
mutation.center(new Coordinate(original.center().x/2, original.center().y/2));
|
||||||
|
} else if (randomBoolean()) {
|
||||||
|
radius = radius/2;
|
||||||
|
} else {
|
||||||
|
DistanceUnit newRandom = unit;
|
||||||
|
while (newRandom == unit) {
|
||||||
|
newRandom = randomFrom(DistanceUnit.values());
|
||||||
|
};
|
||||||
|
unit = newRandom;
|
||||||
|
}
|
||||||
|
return mutation.radius(radius, unit);
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,66 @@
|
||||||
|
/*
|
||||||
|
* Licensed to Elasticsearch under one or more contributor
|
||||||
|
* license agreements. See the NOTICE file distributed with
|
||||||
|
* this work for additional information regarding copyright
|
||||||
|
* ownership. Elasticsearch licenses this file to you under
|
||||||
|
* the Apache License, Version 2.0 (the "License"); you may
|
||||||
|
* not use this file except in compliance with the License.
|
||||||
|
* You may obtain a copy of the License at
|
||||||
|
*
|
||||||
|
* http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
*
|
||||||
|
* Unless required by applicable law or agreed to in writing,
|
||||||
|
* software distributed under the License is distributed on an
|
||||||
|
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
||||||
|
* KIND, either express or implied. See the License for the
|
||||||
|
* specific language governing permissions and limitations
|
||||||
|
* under the License.
|
||||||
|
*/
|
||||||
|
|
||||||
|
package org.elasticsearch.common.geo.builders;
|
||||||
|
|
||||||
|
import com.spatial4j.core.shape.Rectangle;
|
||||||
|
import com.vividsolutions.jts.geom.Coordinate;
|
||||||
|
|
||||||
|
import org.elasticsearch.common.geo.builders.ShapeBuilder.Orientation;
|
||||||
|
import org.elasticsearch.test.geo.RandomShapeGenerator;
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
|
|
||||||
|
public class EnvelopeBuilderTests extends AbstractShapeBuilderTestCase<EnvelopeBuilder> {
|
||||||
|
|
||||||
|
@Override
|
||||||
|
protected EnvelopeBuilder createTestShapeBuilder() {
|
||||||
|
EnvelopeBuilder envelope = new EnvelopeBuilder(randomFrom(Orientation.values()));
|
||||||
|
Rectangle box = RandomShapeGenerator.xRandomRectangle(getRandom(), RandomShapeGenerator.xRandomPoint(getRandom()));
|
||||||
|
envelope.topLeft(box.getMinX(), box.getMaxY())
|
||||||
|
.bottomRight(box.getMaxX(), box.getMinY());
|
||||||
|
return envelope;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
protected EnvelopeBuilder mutate(EnvelopeBuilder original) throws IOException {
|
||||||
|
EnvelopeBuilder mutation = copyShape(original);
|
||||||
|
if (randomBoolean()) {
|
||||||
|
// toggle orientation
|
||||||
|
mutation.orientation = (original.orientation == Orientation.LEFT ? Orientation.RIGHT : Orientation.LEFT);
|
||||||
|
} else {
|
||||||
|
// move one corner to the middle of original
|
||||||
|
switch (randomIntBetween(0, 3)) {
|
||||||
|
case 0:
|
||||||
|
mutation.topLeft(new Coordinate(randomDoubleBetween(-180.0, original.bottomRight.x, true), original.topLeft.y));
|
||||||
|
break;
|
||||||
|
case 1:
|
||||||
|
mutation.topLeft(new Coordinate(original.topLeft.x, randomDoubleBetween(original.bottomRight.y, 90.0, true)));
|
||||||
|
break;
|
||||||
|
case 2:
|
||||||
|
mutation.bottomRight(new Coordinate(randomDoubleBetween(original.topLeft.x, 180.0, true), original.bottomRight.y));
|
||||||
|
break;
|
||||||
|
case 3:
|
||||||
|
mutation.bottomRight(new Coordinate(original.bottomRight.x, randomDoubleBetween(-90.0, original.topLeft.y, true)));
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return mutation;
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,38 @@
|
||||||
|
/*
|
||||||
|
* Licensed to Elasticsearch under one or more contributor
|
||||||
|
* license agreements. See the NOTICE file distributed with
|
||||||
|
* this work for additional information regarding copyright
|
||||||
|
* ownership. Elasticsearch licenses this file to you under
|
||||||
|
* the Apache License, Version 2.0 (the "License"); you may
|
||||||
|
* not use this file except in compliance with the License.
|
||||||
|
* You may obtain a copy of the License at
|
||||||
|
*
|
||||||
|
* http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
*
|
||||||
|
* Unless required by applicable law or agreed to in writing,
|
||||||
|
* software distributed under the License is distributed on an
|
||||||
|
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
||||||
|
* KIND, either express or implied. See the License for the
|
||||||
|
* specific language governing permissions and limitations
|
||||||
|
* under the License.
|
||||||
|
*/
|
||||||
|
|
||||||
|
package org.elasticsearch.common.geo.builders;
|
||||||
|
|
||||||
|
import com.vividsolutions.jts.geom.Coordinate;
|
||||||
|
|
||||||
|
import org.elasticsearch.test.geo.RandomShapeGenerator;
|
||||||
|
import org.elasticsearch.test.geo.RandomShapeGenerator.ShapeType;
|
||||||
|
|
||||||
|
public class PointBuilderTests extends AbstractShapeBuilderTestCase<PointBuilder> {
|
||||||
|
|
||||||
|
@Override
|
||||||
|
protected PointBuilder createTestShapeBuilder() {
|
||||||
|
return (PointBuilder) RandomShapeGenerator.createShape(getRandom(), ShapeType.POINT);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
protected PointBuilder mutate(PointBuilder original) {
|
||||||
|
return new PointBuilder().coordinate(new Coordinate(original.longitude()/2, original.latitude()/2));
|
||||||
|
}
|
||||||
|
}
|
|
@ -57,4 +57,20 @@ public class DistanceUnitTests extends ESTestCase {
|
||||||
assertThat("Value can be parsed from '" + testValue + unit.toString() + "'", DistanceUnit.Distance.parseDistance(unit.toString(testValue)).value, equalTo(testValue));
|
assertThat("Value can be parsed from '" + testValue + unit.toString() + "'", DistanceUnit.Distance.parseDistance(unit.toString(testValue)).value, equalTo(testValue));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* This test ensures that we are aware of accidental reordering in the distance unit ordinals,
|
||||||
|
* since equality in e.g. CircleShapeBuilder, hashCode and serialization rely on them
|
||||||
|
*/
|
||||||
|
public void testDistanceUnitNames() {
|
||||||
|
assertEquals(0, DistanceUnit.INCH.ordinal());
|
||||||
|
assertEquals(1, DistanceUnit.YARD.ordinal());
|
||||||
|
assertEquals(2, DistanceUnit.FEET.ordinal());
|
||||||
|
assertEquals(3, DistanceUnit.KILOMETERS.ordinal());
|
||||||
|
assertEquals(4, DistanceUnit.NAUTICALMILES.ordinal());
|
||||||
|
assertEquals(5, DistanceUnit.MILLIMETERS.ordinal());
|
||||||
|
assertEquals(6, DistanceUnit.CENTIMETERS.ordinal());
|
||||||
|
assertEquals(7, DistanceUnit.MILES.ordinal());
|
||||||
|
assertEquals(8, DistanceUnit.METERS.ordinal());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue