Examples of registerProcessingElement()

Examples of eu.admire.dispel.engine.InMemoryAdmireRegistry.registerProcessingElement()

272
273
274
275
276
277
278
279
280
281
282
   
    public void testFunctionCreatingPE() throws Exception
    {
        DISPELCompiler compiler = new DISPELCompiler();
        InMemoryAdmireRegistry registry = new InMemoryAdmireRegistry();
        registry.registerProcessingElement("eu.admire.Results");
        registry.registerProcessingElement("uk.org.ogsadai.Echo");
        DISPELGraphBuilder builder =
            new DISPELGraphBuilder(registry, new SimpleDispelOptimiser());
        compiler.setRequestBuilder(builder);
        compiler.parse(new FileReader(DISPEL_PATH + "FunctionCreatingPE.dispel"));
View Full Code Here

Examples of eu.admire.dispel.engine.InMemoryAdmireRegistry.registerProcessingElement()

273
274
275
276
277
278
279
280
281
282
283
    public void testFunctionCreatingPE() throws Exception
    {
        DISPELCompiler compiler = new DISPELCompiler();
        InMemoryAdmireRegistry registry = new InMemoryAdmireRegistry();
        registry.registerProcessingElement("eu.admire.Results");
        registry.registerProcessingElement("uk.org.ogsadai.Echo");
        DISPELGraphBuilder builder =
            new DISPELGraphBuilder(registry, new SimpleDispelOptimiser());
        compiler.setRequestBuilder(builder);
        compiler.parse(new FileReader(DISPEL_PATH + "FunctionCreatingPE.dispel"));
        assertTrue(!builder.getSubmittedGraphs().isEmpty());
View Full Code Here

Examples of eu.admire.dispel.engine.InMemoryAdmireRegistry.registerProcessingElement()

30
31
32
33
34
35
36
37
38
39
40
    @Test
    public void testSimple() throws Exception
    {
        InsertCompositeProcessingElements insert = new InsertCompositeProcessingElements();
        InMemoryAdmireRegistry registry = new InMemoryAdmireRegistry();
        registry.registerProcessingElement("eu.admire.A");
        registry.registerProcessingElement("eu.admire.C");
        registry.registerProcessingElement("eu.admire.D");
        registry.registerProcessingElement("eu.admire.E");
        ProcessingElementDescriptor desc =
            new SimpleProcessingElementDescriptor(
View Full Code Here

Examples of eu.admire.dispel.engine.InMemoryAdmireRegistry.registerProcessingElement()

31
32
33
34
35
36
37
38
39
40
41
    public void testSimple() throws Exception
    {
        InsertCompositeProcessingElements insert = new InsertCompositeProcessingElements();
        InMemoryAdmireRegistry registry = new InMemoryAdmireRegistry();
        registry.registerProcessingElement("eu.admire.A");
        registry.registerProcessingElement("eu.admire.C");
        registry.registerProcessingElement("eu.admire.D");
        registry.registerProcessingElement("eu.admire.E");
        ProcessingElementDescriptor desc =
            new SimpleProcessingElementDescriptor(
                    "B",
View Full Code Here

Examples of eu.admire.dispel.engine.InMemoryAdmireRegistry.registerProcessingElement()

32
33
34
35
36
37
38
39
40
41
42
    {
        InsertCompositeProcessingElements insert = new InsertCompositeProcessingElements();
        InMemoryAdmireRegistry registry = new InMemoryAdmireRegistry();
        registry.registerProcessingElement("eu.admire.A");
        registry.registerProcessingElement("eu.admire.C");
        registry.registerProcessingElement("eu.admire.D");
        registry.registerProcessingElement("eu.admire.E");
        ProcessingElementDescriptor desc =
            new SimpleProcessingElementDescriptor(
                    "B",
                    Collections.<ProcessingElementInputDescriptor>emptyList(),
View Full Code Here

Examples of eu.admire.dispel.engine.InMemoryAdmireRegistry.registerProcessingElement()

33
34
35
36
37
38
39
40
41
42
43
        InsertCompositeProcessingElements insert = new InsertCompositeProcessingElements();
        InMemoryAdmireRegistry registry = new InMemoryAdmireRegistry();
        registry.registerProcessingElement("eu.admire.A");
        registry.registerProcessingElement("eu.admire.C");
        registry.registerProcessingElement("eu.admire.D");
        registry.registerProcessingElement("eu.admire.E");
        ProcessingElementDescriptor desc =
            new SimpleProcessingElementDescriptor(
                    "B",
                    Collections.<ProcessingElementInputDescriptor>emptyList(),
                    Collections.<ProcessingElementOutputDescriptor>emptyList());
View Full Code Here

Examples of eu.admire.dispel.engine.InMemoryAdmireRegistry.registerProcessingElement()

42
43
44
45
46
47
48
49
50
51
52
                    Collections.<ProcessingElementInputDescriptor>emptyList(),
                    Collections.<ProcessingElementOutputDescriptor>emptyList());
        String implementation = "use eu.admire.D; use eu.admire.E; D d = new D; E e = new E; d.out => e.in; " +
            "PE(<Connection in> => <Connection out>) B = PE(<Connection in=d.in> => <Connection out=e.out>);" +
            "register B;";
        registry.registerProcessingElement(desc, implementation);
        insert.setAdmireRegistry(registry);
        insert.setDispelOptimiser(new SimpleDispelOptimiser());
        RequestContext context = new MockRequestContext();
        Graph graph = new Graph();
        ProcessingElementNode a = new ProcessingElementNode("eu.admire.A");
View Full Code Here

Examples of eu.admire.dispel.engine.InMemoryAdmireRegistry.registerProcessingElement()

535
536
537
538
539
540
541
542
543
544
545
    }
   
    public void testDuplicateConnection() throws Exception
    {
        InMemoryAdmireRegistry registry = new InMemoryAdmireRegistry();
        registry.registerProcessingElement("a.A");
        registry.registerProcessingElement("eu.admire.Results");
        DISPELCompiler compiler = new DISPELCompiler();
        DISPELGraphBuilder builder =
            new DISPELGraphBuilder(registry, new SimpleDispelOptimiser());
        compiler.setRequestBuilder(builder);
View Full Code Here

Examples of eu.admire.dispel.engine.InMemoryAdmireRegistry.registerProcessingElement()

536
537
538
539
540
541
542
543
544
545
546
   
    public void testDuplicateConnection() throws Exception
    {
        InMemoryAdmireRegistry registry = new InMemoryAdmireRegistry();
        registry.registerProcessingElement("a.A");
        registry.registerProcessingElement("eu.admire.Results");
        DISPELCompiler compiler = new DISPELCompiler();
        DISPELGraphBuilder builder =
            new DISPELGraphBuilder(registry, new SimpleDispelOptimiser());
        compiler.setRequestBuilder(builder);
        compiler.addErrorListener(new ErrorListener()
View Full Code Here

Examples of eu.admire.registry.pe.rdf.SimpleRDFProcessingElementRegistry.registerProcessingElement()

62
63
64
65
66
67
68
69
70
71
72
                object = new DispelObject(name, register.getValue().getObject());
                ProcessingElementDescriptor pe = registry.getPEDescriptor(name, object);
                HashMap<String, String> map = new HashMap<String, String>();
                map.put("@version", "1781112");
                pe.setMetadata(map);
                simpleRdfRegistry.registerProcessingElement(pe, "PE");
                System.out.println("PE : "  + name + " registered");
            }
            catch (RegistrationFailedException e)
            {
              e.printStackTrace();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.