package com.linkedpipes.etl.convert.uv.configuration;

import com.linkedpipes.etl.convert.uv.pipeline.LpPipeline;
import com.thoughtworks.xstream.annotations.XStreamAlias;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 *
 * @author Petr Škoda
 */
@XStreamAlias("eu.unifiedviews.plugins.trandformer.sparqlselect.SparqlSelectConfig")
class SparqlSelectConfig implements Configuration {

    private static final Logger LOG
            = LoggerFactory.getLogger(SparqlSelectConfig.class);

    private String targetPath = "/out.csv";

    private String query = "SELECT ?s ?p ?o WHERE { ?s ?p ?o }";

    @Override
    public void update(LpPipeline pipeline, LpPipeline.Component component) {

        // @DataUnit.AsInput(name = "input")
        // @DataUnit.AsOutput(name = "output")

        // @Component.InputPort(id = "InputRdf")
        // @Component.OutputPort(id = "OutputFiles")

        // http://plugins.linkedpipes.com/ontology/t-sparqlSelect#
        // query
        // fileName

        LOG.error("{} : Removed.", component);
        pipeline.removeComponent(component);
    }

}

package com.linkedpipes.etl.convert.uv.configuration;

import com.linkedpipes.etl.convert.uv.pipeline.LpPipeline;
import com.thoughtworks.xstream.annotations.XStreamAlias;
import java.util.ArrayList;
import java.util.List;
import org.openrdf.model.IRI;
import org.openrdf.model.Statement;
import org.openrdf.model.ValueFactory;
import org.openrdf.model.impl.SimpleValueFactory;
import org.openrdf.model.vocabulary.RDF;

/**
 *
 * @author Petr Škoda
 */
@XStreamAlias("eu.unifiedviews.plugins.trandformer.sparqlselect.SparqlSelectConfig")
class SparqlSelectConfig implements Configuration {

    private String targetPath = "/out.csv";

    private String query = "SELECT ?s ?p ?o WHERE { ?s ?p ?o }";

    @Override
    public void update(LpPipeline pipeline, LpPipeline.Component component) {

        pipeline.renameInPort(component, "input", "InputRdf");
        pipeline.renameOutPort(component, "output", "OutputFiles");

        component.setTemplate(LpPipeline.BASE_IRI + "resources/components/t-sparqlSelect");

        final ValueFactory vf = SimpleValueFactory.getInstance();
        final List<Statement> st = new ArrayList<>();
        final IRI configuration = vf.createIRI("http://localhost/resources/configuration/t-sparqlSelect");

        st.add(vf.createStatement(configuration,
                RDF.TYPE,
                vf.createIRI("http://plugins.linkedpipes.com/ontology/t-sparqlSelect#Configuration")));

        st.add(vf.createStatement(configuration,
                vf.createIRI("http://plugins.linkedpipes.com/ontology/t-sparqlSelect#query"),
                vf.createLiteral(this.query)));

        st.add(vf.createStatement(configuration,
                vf.createIRI("http://plugins.linkedpipes.com/ontology/t-sparqlSelect#fileName"),
                vf.createLiteral(this.targetPath)));

        component.setLpConfiguration(st);
    }

}

Add support for SparqlSelect