mirror of
https://github.com/OpenSPG/openspg.git
synced 2025-12-06 04:01:13 +00:00
fix(reasoner): bugfix in catalog (#173)
This commit is contained in:
parent
b99849d2b9
commit
3f9fadb22c
2
pom.xml
2
pom.xml
@ -38,7 +38,7 @@
|
|||||||
<properties>
|
<properties>
|
||||||
<antlr4.version>4.8</antlr4.version>
|
<antlr4.version>4.8</antlr4.version>
|
||||||
<dropwizard.metrics.version>4.2.9</dropwizard.metrics.version>
|
<dropwizard.metrics.version>4.2.9</dropwizard.metrics.version>
|
||||||
<geotools.version>28.0</geotools.version>
|
<geotools.version>27.0</geotools.version>
|
||||||
<google.s2.version>2.0.0</google.s2.version>
|
<google.s2.version>2.0.0</google.s2.version>
|
||||||
<groovy.version>3.0.9</groovy.version>
|
<groovy.version>3.0.9</groovy.version>
|
||||||
<gson.version>2.10.1</gson.version>
|
<gson.version>2.10.1</gson.version>
|
||||||
|
|||||||
@ -39,6 +39,9 @@ class PropertyGraphSchema(val nodes: mutable.Map[String, Node], val edges: mutab
|
|||||||
}
|
}
|
||||||
|
|
||||||
def getNodeField(nodeType: String, fieldName: String): Field = {
|
def getNodeField(nodeType: String, fieldName: String): Field = {
|
||||||
|
if (fieldName.equals(Constants.NODE_ID_KEY)) {
|
||||||
|
return new Field(fieldName, KTString, true)
|
||||||
|
}
|
||||||
val node = nodes.get(nodeType)
|
val node = nodes.get(nodeType)
|
||||||
if (node.isEmpty) {
|
if (node.isEmpty) {
|
||||||
null
|
null
|
||||||
|
|||||||
@ -41,7 +41,7 @@
|
|||||||
<properties>
|
<properties>
|
||||||
<antlr4.version>4.8</antlr4.version>
|
<antlr4.version>4.8</antlr4.version>
|
||||||
<fastjson.version>1.2.71_noneautotype</fastjson.version>
|
<fastjson.version>1.2.71_noneautotype</fastjson.version>
|
||||||
<geotools.version>28.0</geotools.version>
|
<geotools.version>27.0</geotools.version>
|
||||||
<google.s2.version>2.0.0</google.s2.version>
|
<google.s2.version>2.0.0</google.s2.version>
|
||||||
<hadoop.version>2.7.2</hadoop.version>
|
<hadoop.version>2.7.2</hadoop.version>
|
||||||
<hive.version>3.1.0</hive.version>
|
<hive.version>3.1.0</hive.version>
|
||||||
|
|||||||
@ -11,7 +11,7 @@
|
|||||||
* or implied.
|
* or implied.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
package com.antgroup.reasoner.session
|
package com.antgroup.openspg.reasoner.session
|
||||||
|
|
||||||
import com.antgroup.openspg.reasoner.lube.block.{DDLOp, SortItem}
|
import com.antgroup.openspg.reasoner.lube.block.{DDLOp, SortItem}
|
||||||
import com.antgroup.openspg.reasoner.lube.common.expr.{Aggregator, Expr}
|
import com.antgroup.openspg.reasoner.lube.common.expr.{Aggregator, Expr}
|
||||||
@ -11,7 +11,7 @@
|
|||||||
* or implied.
|
* or implied.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
package com.antgroup.reasoner.session
|
package com.antgroup.openspg.reasoner.session
|
||||||
|
|
||||||
import com.antgroup.openspg.reasoner.lube.logical.Var
|
import com.antgroup.openspg.reasoner.lube.logical.Var
|
||||||
import com.antgroup.openspg.reasoner.lube.physical.rdg.Row
|
import com.antgroup.openspg.reasoner.lube.physical.rdg.Row
|
||||||
@ -11,14 +11,13 @@
|
|||||||
* or implied.
|
* or implied.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
package com.antgroup.reasoner.session
|
package com.antgroup.openspg.reasoner.session
|
||||||
|
|
||||||
import com.antgroup.openspg.reasoner.lube.catalog.Catalog
|
import com.antgroup.openspg.reasoner.lube.catalog.Catalog
|
||||||
import com.antgroup.openspg.reasoner.lube.logical.RepeatPathVar
|
import com.antgroup.openspg.reasoner.lube.logical.RepeatPathVar
|
||||||
import com.antgroup.openspg.reasoner.lube.parser.ParserInterface
|
import com.antgroup.openspg.reasoner.lube.parser.ParserInterface
|
||||||
import com.antgroup.openspg.reasoner.lube.physical.PropertyGraph
|
import com.antgroup.openspg.reasoner.lube.physical.PropertyGraph
|
||||||
import com.antgroup.openspg.reasoner.warehouse.common.config.GraphLoaderConfig
|
import com.antgroup.openspg.reasoner.warehouse.common.config.GraphLoaderConfig
|
||||||
import com.antgroup.openspg.reasoner.session.KGReasonerSession
|
|
||||||
|
|
||||||
class EmptyPropertyGraph extends PropertyGraph[EmptyRDG] {
|
class EmptyPropertyGraph extends PropertyGraph[EmptyRDG] {
|
||||||
|
|
||||||
@ -11,7 +11,7 @@
|
|||||||
* or implied.
|
* or implied.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
package com.antgroup.reasoner.session
|
package com.antgroup.openspg.reasoner.session
|
||||||
|
|
||||||
import com.antgroup.openspg.reasoner.common.graph.edge.Direction
|
import com.antgroup.openspg.reasoner.common.graph.edge.Direction
|
||||||
import com.antgroup.openspg.reasoner.lube.common.pattern.{
|
import com.antgroup.openspg.reasoner.lube.common.pattern.{
|
||||||
@ -11,7 +11,7 @@
|
|||||||
* or implied.
|
* or implied.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
package com.antgroup.reasoner.session
|
package com.antgroup.openspg.reasoner.session
|
||||||
|
|
||||||
import com.antgroup.openspg.reasoner.lube.catalog.impl.PropertyGraphCatalog
|
import com.antgroup.openspg.reasoner.lube.catalog.impl.PropertyGraphCatalog
|
||||||
import com.antgroup.openspg.reasoner.lube.physical.util.PhysicalOperatorUtil
|
import com.antgroup.openspg.reasoner.lube.physical.util.PhysicalOperatorUtil
|
||||||
@ -11,7 +11,7 @@
|
|||||||
* or implied.
|
* or implied.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
package com.antgroup.reasoner.session
|
package com.antgroup.openspg.reasoner.session
|
||||||
|
|
||||||
import scala.collection.mutable.ListBuffer
|
import scala.collection.mutable.ListBuffer
|
||||||
|
|
||||||
Loading…
x
Reference in New Issue
Block a user