import org.apache.clerezza.rdf.core.serializedform.Serializer; //导入依赖的package包/类
/**
 * Starts the transformer server.
 *
 * @param arguments contains the port on which the server will listen
 * @throws Exception
 */
private static void start(Arguments arguments) throws Exception {
    TransformerServer server = new TransformerServer(arguments.getPort(), arguments.enableCors());

    // create the singleton instance of Serializer
    Serializer.getInstance();
    // create the singleton instance of Parser
    Parser.getInstance();

    server.start(
            new TransformerFactory() {
                @Override
                public Transformer getTransformer(HttpServletRequest request) {
                    switch (request.getMethod()) {
                        case "GET":
                            return new DictionaryMatcherTransformer();
                        case "POST":
                            return new DictionaryMatcherTransformer(request.getQueryString());
                        default:
                            throw new TransformerException(HttpServletResponse.SC_METHOD_NOT_ALLOWED, "ERROR: Method \"" + request.getMethod() + "\" is not allowed!");
                    }
                }
            });

    server.join();
}
 

import org.apache.clerezza.rdf.core.serializedform.Serializer; //导入依赖的package包/类
public SkosifierRootResource(@Context ServletContext context) {
    // bind the job manager by looking it up from the servlet request context
    //jobManager = ContextHelper.getServiceFromContext(EnhancementJobManager.class, context);
	//skosifier = ContextHelper.getServiceFromContext(Skosifier.class, context);
	//skosifierFactory = ContextHelper.getServiceFromContext(SkosifierFactory.class, context);
    tcManager = ContextHelper.getServiceFromContext(TcManager.class, context);
    serializer = ContextHelper.getServiceFromContext(Serializer.class, context);
    parser = ContextHelper.getServiceFromContext(Parser.class, context);
    //broadcast = ContextHelper.getServiceFromContext(Broadcaster.class, context);
}
 

import org.apache.clerezza.rdf.core.serializedform.Serializer; //导入依赖的package包/类
/**
 * The client RDF data is always used as the source data source, of type file, for the comparisons with a target data source. 
 * The target data source can be of type file or a SPARQL endpoint. If the target data source in the Silk config file
 * is set to be of type file then the same client data will be used and the task is a deduplication task (Silk works only with local files). 
 * The updated configuration file and the input RDF data and the output files are stored in the /tmp/ folder.
 * @param inputRdf
 * @return
 * @throws IOException
 */
protected TripleCollection findSameEntities(InputStream inputRdf, String rdfFormat, InputStream configIn) throws IOException {    	
	// Default silk config file
	File configFile = null;
	if(configIn != null){
		configFile = FileUtil.inputStreamToFile(configIn, "silk-config-", ".xml");
	}
	else {
		configFile = FileUtil.inputStreamToFile(getClass().getResourceAsStream("silk-config-file.xml"), "silk-config-", ".xml");
	}
	
    // file with original data serialized in N-TRIPLE format
    File ntFile = File.createTempFile("input-rdf", ".nt");
    // file containing the equivalences
    File outFile = File.createTempFile("output-", ".nt");
    
    // update the config file with the paths of the source datasource and output files and the format
    // if the type of target datasource is "file" update the path (deduplication) 
    SilkConfigFileParser silkParser = new SilkConfigFileParser(configFile.getAbsolutePath());
    silkParser.updateOutputFile(outFile.getAbsolutePath());
    silkParser.updateSourceDataSourceFile(ntFile.getAbsolutePath(), "N-TRIPLE");
    if (silkParser.getTargetDataSourcetype().equals("file")) {
        silkParser.updateTargetDataSourceFile(ntFile.getAbsolutePath(), "N-TRIPLE"); //deduplication
    }
    silkParser.saveChanges();
    
    // change the format into N-TRIPLE
    Parser parser = Parser.getInstance();
    TripleCollection origGraph =  parser.parse(inputRdf, rdfFormat);
    Serializer serializer = Serializer.getInstance();
    serializer.serialize(new FileOutputStream(ntFile), origGraph, SupportedFormat.N_TRIPLE);

    // interlink entities
    Silk.executeFile(configFile, null, 1, true);
    log.info("Interlinking task completed."); 
    TripleCollection equivalences = parseResult(outFile); 
    
    // add the equivalence set to the input rdf data to be sent back to the client
    TripleCollection resultGraph = new SimpleMGraph();
    resultGraph.addAll(origGraph);
    resultGraph.addAll(equivalences);
    
    // remove all temporary files
    configFile.delete();        
    ntFile.delete();
    outFile.delete();

    // returns the result to the client
    return resultGraph;
}
 

import org.apache.clerezza.rdf.core.serializedform.Serializer; //导入依赖的package包/类
public SkosifierRootResource(@Context ServletContext context) {
    tcManager = ContextHelper.getServiceFromContext(TcManager.class, context);
    serializer = ContextHelper.getServiceFromContext(Serializer.class, context);
    parser = ContextHelper.getServiceFromContext(Parser.class, context);
}