Skip to content

Commit

Permalink
Moved java operators for jena to its own lightweight package
Browse files Browse the repository at this point in the history
  • Loading branch information
Aklakan committed Oct 8, 2021
1 parent 6b02736 commit ed1bf13
Show file tree
Hide file tree
Showing 23 changed files with 114 additions and 9 deletions.
7 changes: 7 additions & 0 deletions pom.xml
Expand Up @@ -116,6 +116,7 @@
<modules>
<module>sansa-hadoop-jena</module>
<module>sansa-kryo-jena</module>
<module>sansa-spark-jena-java</module>

<module>sansa-test-resources</module>
<module>sansa-resource-metadata</module>
Expand Down Expand Up @@ -172,6 +173,12 @@
<version>4.0.2</version>
</dependency>

<dependency>
<groupId>net.sansa-stack</groupId>
<artifactId>sansa-spark-jena-java_${scala.binary.version}</artifactId>
<version>${project.version}</version>
</dependency>

<dependency>
<groupId>net.sansa-stack</groupId>
<artifactId>sansa-test-resources_${scala.binary.version}</artifactId>
Expand Down
5 changes: 5 additions & 0 deletions sansa-rdf/sansa-rdf-spark/pom.xml
Expand Up @@ -11,6 +11,11 @@
</parent>

<dependencies>
<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>sansa-spark-jena-java_${scala.binary.version}</artifactId>
<!-- <classifier>${scala.classifier}</classifier> -->
</dependency>

<dependency>
<groupId>${project.groupId}</groupId>
Expand Down
98 changes: 98 additions & 0 deletions sansa-spark-jena-java/pom.xml
@@ -0,0 +1,98 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>

<parent>
<groupId>net.sansa-stack</groupId>
<artifactId>sansa-parent_2.12</artifactId>
<version>0.8.0-RC2-SNAPSHOT</version>
</parent>

<artifactId>sansa-spark-jena-java_2.12</artifactId>
<packaging>jar</packaging>

<build>
<plugins>
<plugin>
<groupId>org.scalastyle</groupId>
<artifactId>scalastyle-maven-plugin</artifactId>
</plugin>
<plugin>
<groupId>net.alchim31.maven</groupId>
<artifactId>scala-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
<!--
<properties>
<timestamp>${maven.build.timestamp}</timestamp>
<maven.build.timestamp.format>yyyy-MM-dd HH:mm</maven.build.timestamp.format>
</properties>
-->
<!--
<build>
<resources>
<resource>
<directory>src/main/resources</directory>
</resource>
<resource>
<directory>src/main/resources-filtered</directory>
<filtering>true</filtering>
</resource>
</resources>
</build>
-->

<dependencies>

<dependency>
<groupId>net.sansa-stack</groupId>
<artifactId>sansa-hadoop-jena</artifactId>
</dependency>

<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-core_${scala.binary.version}</artifactId>
<version>${spark.version}</version>
<!-- <scope>${spark.deps.scope}</scope> -->
</dependency>

<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-sql_${scala.binary.version}</artifactId>
</dependency>

<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<scope>test</scope>
</dependency>

<dependency>
<groupId>net.sansa-stack</groupId>
<artifactId>sansa-test-resources_2.12</artifactId>
<scope>test</scope>
</dependency>

<!--
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
</dependency>
<dependency>
<groupId>org.aksw.commons</groupId>
<artifactId>aksw-commons-util</artifactId>
</dependency>
<dependency>
<groupId>org.aksw.commons</groupId>
<artifactId>aksw-commons-io-utils</artifactId>
</dependency>
-->
</dependencies>

</project>

@@ -1,17 +1,14 @@
package net.sansa_stack.rdf.spark.rdd.op;

import org.aksw.jena_sparql_api.rx.DatasetFactoryEx;
import org.aksw.jena_sparql_api.rx.ModelFactoryEx;
import org.aksw.jena_sparql_api.utils.model.ResourceInDataset;
import org.aksw.jena_sparql_api.utils.model.ResourceInDatasetImpl;
import org.apache.jena.graph.Node;
import org.apache.jena.graph.NodeFactory;
import org.apache.jena.query.Dataset;
import org.apache.jena.query.DatasetFactory;
import org.apache.jena.rdf.model.Model;
import org.apache.jena.rdf.model.ModelFactory;
import org.apache.jena.rdf.model.Resource;
import org.apache.spark.HashPartitioner;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.api.java.JavaRDD;

Expand Down
@@ -1,14 +1,12 @@
package net.sansa_stack.rdf.spark.rdd.op;

import org.aksw.commons.lambda.serializable.SerializableBinaryOperator;
import org.apache.spark.HashPartitioner;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.function.Function2;

import java.util.Collections;
import java.util.function.BiConsumer;
import java.util.function.BinaryOperator;
import java.util.stream.Collector;

public class JavaRddOps {
Expand Down
@@ -1,4 +1,4 @@
package net.sansa_stack.rdf.spark.rdd.function;
package net.sansa_stack.spark.rdd.function;

import org.aksw.commons.lambda.serializable.SerializableFunction;
import org.apache.spark.api.java.JavaPairRDD;
Expand Down
@@ -1,4 +1,4 @@
package net.sansa_stack.rdf.spark.rdd.function;
package net.sansa_stack.spark.rdd.function;

import org.aksw.commons.lambda.serializable.SerializableFunction;
import org.apache.spark.api.java.JavaRDD;
Expand Down
@@ -1,4 +1,4 @@
package net.sansa_stack.rdf.spark.rdd.function;
package net.sansa_stack.spark.rdd.function;

import org.aksw.commons.lambda.serializable.SerializableFunction;
import org.apache.spark.api.java.JavaPairRDD;
Expand Down
@@ -1,4 +1,4 @@
package net.sansa_stack.rdf.spark.rdd.function;
package net.sansa_stack.spark.rdd.function;

import org.aksw.commons.lambda.serializable.SerializableFunction;
import org.apache.spark.api.java.JavaPairRDD;
Expand Down

0 comments on commit ed1bf13

Please sign in to comment.