Class KnnJudgementUsingIndex<U extends org.locationtech.jts.geom.Geometry,​T extends org.locationtech.jts.geom.Geometry>

  • All Implemented Interfaces:
    Serializable, org.apache.spark.api.java.function.FlatMapFunction<Iterator<org.locationtech.jts.index.SpatialIndex>,​T>

    public class KnnJudgementUsingIndex<U extends org.locationtech.jts.geom.Geometry,​T extends org.locationtech.jts.geom.Geometry>
    extends Object
    implements org.apache.spark.api.java.function.FlatMapFunction<Iterator<org.locationtech.jts.index.SpatialIndex>,​T>, Serializable
    The Class KnnJudgementUsingIndex.
    See Also:
    Serialized Form
    • Constructor Detail

      • KnnJudgementUsingIndex

        public KnnJudgementUsingIndex​(U queryCenter,
                                      int k)
        Instantiates a new knn judgement using index.
        Parameters:
        queryCenter - the query center
        k - the k
    • Method Detail

      • call

        public Iterator<T> call​(Iterator<org.locationtech.jts.index.SpatialIndex> treeIndexes)
                         throws Exception
        Specified by:
        call in interface org.apache.spark.api.java.function.FlatMapFunction<U extends org.locationtech.jts.geom.Geometry,​T extends org.locationtech.jts.geom.Geometry>
        Throws:
        Exception