2017-08-09 7 views
0

シェイプファイル(TM_WORLD_BORDERS-0.3.shp)からネイティブAPIを介してgeomesa(累積)にデータを取り込みます。次に、ネイティブApiを使用して、ユーザーが指定したポイント(lat、lon)を含むgeomesaのデータを照会します(基本的に、ポイントを含むジオメサの任意のポリゴン)。私は、クエリを実行するとGeoMesaネイティブAPI(Accumulo) - SimpleFeatureの "the_geom"が抜けています。

http://docs.geotools.org/latest/userguide/library/main/filter.html

GeoMesaQuery q = GeoMesaQuery.GeoMesaQueryBuilder.builder() 
.within(-180.0,-90.0,180.0,90.0) // needed or the query throws a null-pointer ex 
.filter(ff.contains(ff.property("the_geom"), ff.literal(point))) 
.build(); 
しかし

から「私は上?:利用ポリゴンレイヤを確認するためのポイントをクリックしたのは何Q.」多かれ少なかれ模倣を、私はエラーを取得します(accumuloで):

Failed to get multiscan result 
java.util.concurrent.ExecutionException: java.lang.RuntimeException: Can't handle property 'the_geom' for feature type dtg:Date,payload:Bytes,*geom:Geometry:srid=4326:index-value=true,FIPS:String,ISO2:String,ISO3:String 
    at org.apache.accumulo.tserver.scan.ScanTask.get(ScanTask.java:126) 
    at org.apache.accumulo.tserver.TabletServer$ThriftClientHandler.continueMultiScan(TabletServer.java:700) 
    at org.apache.accumulo.tserver.TabletServer$ThriftClientHandler.startMultiScan(TabletServer.java:665) 
    at sun.reflect.GeneratedMethodAccessor9.invoke(Unknown Source) 
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
    at java.lang.reflect.Method.invoke(Method.java:498) 
    at org.apache.accumulo.core.trace.wrappers.RpcServerInvocationHandler.invoke(RpcServerInvocationHandler.java:46) 
    at org.apache.accumulo.server.rpc.RpcWrapper$1.invoke(RpcWrapper.java:74) 
    at com.sun.proxy.$Proxy21.startMultiScan(Unknown Source) 
    at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Processor$startMultiScan.getResult(TabletClientService.java:2381) 
    at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Processor$startMultiScan.getResult(TabletClientService.java:2365) 
    at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:39) 
    at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:39) 
    at org.apache.accumulo.server.rpc.TimedProcessor.process(TimedProcessor.java:63) 
    at org.apache.thrift.server.AbstractNonblockingServer$FrameBuffer.invoke(AbstractNonblockingServer.java:518) 
    at org.apache.accumulo.server.rpc.CustomNonBlockingServer$CustomFrameBuffer.invoke(CustomNonBlockingServer.java:106) 
    at org.apache.thrift.server.Invocation.run(Invocation.java:18) 
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 
    at org.apache.accumulo.fate.util.LoggingRunnable.run(LoggingRunnable.java:35) 
    at java.lang.Thread.run(Thread.java:745) 
Caused by: java.lang.RuntimeException: Can't handle property 'the_geom' for feature type dtg:Date,payload:Bytes,*geom:Geometry:srid=4326:index-value=true,FIPS:String,ISO2:String,ISO3:String 
    at org.locationtech.geomesa.filter.expression.FastPropertyName.evaluate(FastPropertyName.scala:61) 
    at org.geotools.filter.GeometryFilterImpl.getGeometries(GeometryFilterImpl.java:108) 
    at org.geotools.filter.GeometryFilterImpl.evaluate(GeometryFilterImpl.java:237) 
    at org.geotools.filter.AndImpl.evaluate(AndImpl.java:44) 
    at org.locationtech.geomesa.accumulo.iterators.KryoLazyFilterTransformIterator$$anonfun$init$5.apply(KryoLazyFilterTransformIterator.scala:78) 
    at org.locationtech.geomesa.accumulo.iterators.KryoLazyFilterTransformIterator$$anonfun$init$5.apply(KryoLazyFilterTransformIterator.scala:78) 
    at org.locationtech.geomesa.accumulo.iterators.KryoLazyFilterTransformIterator.findTop(KryoLazyFilterTransformIterator.scala:117) 
    at org.locationtech.geomesa.accumulo.iterators.KryoLazyFilterTransformIterator.seek(KryoLazyFilterTransformIterator.scala:94) 
    at org.apache.accumulo.core.iterators.system.SourceSwitchingIterator.readNext(SourceSwitchingIterator.java:135) 
    at org.apache.accumulo.core.iterators.system.SourceSwitchingIterator.seek(SourceSwitchingIterator.java:182) 
    at org.apache.accumulo.tserver.tablet.Tablet.lookup(Tablet.java:562) 
    at org.apache.accumulo.tserver.tablet.Tablet.lookup(Tablet.java:681) 
    at org.apache.accumulo.tserver.scan.LookupTask.run(LookupTask.java:114) 
    at org.apache.htrace.wrappers.TraceRunnable.run(TraceRunnable.java:57) 

私は私の機能は*のGEOMタイプではなく、 "the_geom" タイプを持っていることがわかります。私はSimpleFeatureViewの 'populate'と 'getExtraAttributes'メソッドを上書きしようとしましたが、getExtraAttributesはジオメトリをバインドさせません...(注:setAttributeにgmtrを同じエラーのポピュレートシグネチャから渡そうとしました) 。エラーと

GeoMesaIndex<Shapefile> index = AccumuloGeoMesaIndex.build(
               config.getString("tableName"), 
               config.getString("zookeeperHostPort"), 
               config.getString("accumuloInstance"), 
               config.getString("user"), 
               config.getString("password"), 
               false, 
               new ShapefileValueSerializer(), 
               new SimpleFeatureView<Shapefile>() { 
                @Override 
                public void populate(SimpleFeature sf, Shapefile t, String string, byte[] bytes, Geometry gmtr, Date date) { 
                 sf.setAttribute("the_geom", t.the_geom); 
               } 

                @Override 
                public List<AttributeDescriptor> getExtraAttributes() { 
                 AttributeTypeBuilder atb = new AttributeTypeBuilder(); 
                 return Lists.newArrayList(
                  atb.binding(Geometry.class).buildDescriptor("the_geom") 
                                 ); 
                } 
               }); 

Exception in thread "main" java.lang.IllegalArgumentException: Invalid spec string at index 85. Expected one of: attribute type binding, geometry type binding. 
at org.locationtech.geomesa.utils.geotools.SimpleFeatureTypes$.createType(SimpleFeatureTypes.scala:98) 
at org.locationtech.geomesa.utils.geotools.SimpleFeatureTypes$.createType(SimpleFeatureTypes.scala:85) 
at org.locationtech.geomesa.utils.geotools.InitBuilder.build(SftBuilder.scala:174) 
at org.locationtech.geomesa.api.BaseBigTableIndex$.org$locationtech$geomesa$api$BaseBigTableIndex$$buildSimpleFeatureType(BaseBigTableIndex.scala:132) 
at org.locationtech.geomesa.api.BaseBigTableIndex.<init>(BaseBigTableIndex.scala:40) 
at org.locationtech.geomesa.accumulo.nativeapi.AccumuloGeoMesaIndex.<init>(AccumuloGeoMesaIndex.scala:26) 
at org.locationtech.geomesa.accumulo.nativeapi.AccumuloGeoMesaIndex$.buildWithView(AccumuloGeoMesaIndex.scala:72) 
at org.locationtech.geomesa.accumulo.nativeapi.AccumuloGeoMesaIndex$.build(AccumuloGeoMesaIndex.scala:53) 
at org.locationtech.geomesa.accumulo.nativeapi.AccumuloGeoMesaIndex.build(AccumuloGeoMesaIndex.scala) 
at com.comcept.geomesa.ingesttool.AccumuloGeomesaNGAIngest.main(AccumuloGeomesaNGAIngest.java:148) 
Caused by: org.parboiled.errors.ParsingException: Invalid spec string at index 85. Expected one of: attribute type binding, geometry type binding. 
at org.locationtech.geomesa.utils.geotools.SimpleFeatureSpecParser$$anonfun$parse$1.apply(SimpleFeatureSpecParser.scala:39) 
at org.locationtech.geomesa.utils.geotools.SimpleFeatureSpecParser$$anonfun$parse$1.apply(SimpleFeatureSpecParser.scala:39) 
at scala.Option.getOrElse(Option.scala:121) 
at org.locationtech.geomesa.utils.geotools.SimpleFeatureSpecParser$.parse(SimpleFeatureSpecParser.scala:39) 
at org.locationtech.geomesa.utils.geotools.SimpleFeatureSpecParser$.parse(SimpleFeatureSpecParser.scala:28) 
... 10 more 

そう言ったことすべてと、それはGeoMesaのネイティブAPIを使用してフィルタを使用してポリゴンポイント封じ込めチェックを行うことが可能ですか? ff.property( "geom"のいずれかのバージョン、 "the_geom"、 "* geom"など)を使用してジオメトリをクエリできませんでした。

+1

シェイプファイルからどのようにデータを取り込みましたか?ネイティブAPIのinsertメソッドでは、the_geomからジオメトリを渡すと、 'geom'という名前でジオメトリをクエリできます。 https://github.com/locationtech/geomesa/blob/master/geomesa-native-api/src/main/java/org/locationtech/geomesa/api/GeoMesaIndex.java#L51 –

+0

あなたは男です、私はgf.createPointを介して挿入していました(私がチュートリアルやgeomesaのgithubページのテストで見たように)。私はこの質問を下すか、間違って挿入している可能性のある他の人々を助けるためにそれを残すべきでしょうか? –

+0

ニース、喜んで助けてください。うん、私は後世のためにそれを残すだろう。ドキュメント/チュートリアルに、わかりやすくなるものがあれば、私たちの巨乳でチャットしたり、ユーザーリストに電子メールを送ることができます(geomesa.orgのリンク) –

答えて

1

正式回答として追加: 可能ですGeoMesaネイティブAPIを使用したポリゴンポイント包含チェック - inserthereを呼び出すときに照会するジオメトリを確実に使用する必要があります。次に、ジオメトリは"geom"という名前でクエリに使用できます。

関連する問題