truncate clazz

derrickoswald · Aug 18, 2016 · f30cfd3 · f30cfd3
1 parent 195d506
commit f30cfd3
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/src/main/R/sample_Jahn_optimized.R b/src/main/R/sample_Jahn_optimized.R
@@ -22,7 +22,7 @@ sqlContext = sparkRSQL.init (sc)
 # hdfs://[email protected]:9000/data/dump_ews.xml
 # hdfs:/user/root/dump_ews.xml
 # hdfs:/data/NIS_CIM_Export_NS_INITIAL_FILL.rdf
-elements = sql (sqlContext, "create temporary table elements using ch.ninecode.cim options (path 'hdfs:/data/NIS_CIM_Export_NS_INITIAL_FILL.rdf')")
+elements = sql (sqlContext, "create temporary table elements using ch.ninecode.cim options (path 'hdfs:/data/20160817-12_NIS_CIM_Export_b4_Brügg.rdf')")
 head (sql (sqlContext, "select * from elements"))
 edges = sql (sqlContext, "select * from edges")
 redges = SparkR::collect (edges, stringsAsFactors=FALSE) # redges = SparkR::as.data.frame (edges)

diff --git a/src/main/scala/ch/ninecode/cim/CIMEdges.scala b/src/main/scala/ch/ninecode/cim/CIMEdges.scala
@@ -66,6 +66,7 @@ class CIMEdges (val sqlContext: SQLContext) extends Serializable
 
                         val bucket = Bucket ()
                         bucket.clazz = e.getClass ().getName ()
+                        bucket.clazz = bucket.clazz.substring (bucket.clazz.lastIndexOf (".") + 1)
                         def do_identified (identified: IdentifiedObject)
                         {
                             bucket.name = identified.name