Package uk.org.ogsadai.client.toolkit.activities.sql

Examples of uk.org.ogsadai.client.toolkit.activities.sql.SQLQuery.addExpression()

115
116
117
118
119
120
121
122
123
124
125
        ResourceID cacheID = createCache.nextResult();
       
        System.out.println("Created data cache with ID: " + cacheID);
       
        SQLQuery query = new SQLQuery();
        query.addExpression("SELECT name, address FROM littleblackbook WHERE id<10");
        query.setResourceID("MySQLResource");
        WriteToDataCache write = new WriteToDataCache();
        write.setResourceID(cacheID);
        write.connectDataInput(query.getDataOutput());
       
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
        }
        PipelineWorkflow workflow = new PipelineWorkflow();

        SQLQuery query = new SQLQuery();
        query.setResourceID(resource);
        query.addExpression("SELECT outlook, windy, temperature, humidity, weather.play FROM weather JOIN measurements ON weather.id = measurements.id");
        workflow.add(query);
       
        ListRandomSplit split = new ListRandomSplit();
        split.setNumberOfOutputs(count);
        split.connectDataInput(query.getDataOutput());
View Full Code Here
26
27
28
29
30
31
32
33
34
35
36
        {
            service = args[0];
        }
        SQLQuery query = new SQLQuery();
        query.setResourceID("MySQLResource");
        query.addExpression("SELECT temperature, humidity, outlook, windy, weather.play FROM weather JOIN measurements ON weather.id = measurements.id");
        SprintClassifier classifier = new SprintClassifier();
        classifier.addClassName("play");
        classifier.addClassValues(new String[] {"yes", "no"});
        classifier.connectDataInput(query.getDataOutput());
        Evaluate evaluate = new Evaluate();
View Full Code Here
34
35
36
37
38
39
40
41
42
43
44
            service = args[0];
            resource = args[1];
        }
        SQLQuery query = new SQLQuery();
        query.setResourceID(resource);
        query.addExpression("SELECT * FROM replace_values");
        CalculateMean mean = new CalculateMean();
        mean.connectDataInput(query.getDataOutput());
        ConditionalSplit split = new ConditionalSplit();
        split.addCondition("A>=3.0 AND A<3.5 OR A IS NULL");
        split.connectDataInput(query.getDataOutput());
View Full Code Here
27
28
29
30
31
32
33
34
35
36
37
            service = args[0];
            resource = args[1];
        }
        SQLQuery query1 = new SQLQuery();
        query1.setResourceID(resource);
        query1.addExpression("SELECT * FROM weather ORDER BY id");
        SQLQuery query2 = new SQLQuery();
        query2.setResourceID(resource);
        query2.addExpression("SELECT * FROM measurements ORDER BY id");
        TupleMergeJoin join = new TupleMergeJoin();
        join.addColumnIds1(0);
View Full Code Here
30
31
32
33
34
35
36
37
38
39
40
        SQLQuery query1 = new SQLQuery();
        query1.setResourceID(resource);
        query1.addExpression("SELECT * FROM weather ORDER BY id");
        SQLQuery query2 = new SQLQuery();
        query2.setResourceID(resource);
        query2.addExpression("SELECT * FROM measurements ORDER BY id");
        TupleMergeJoin join = new TupleMergeJoin();
        join.addColumnIds1(0);
        join.addColumnIds2(0);
        join.connectData1Input(query1.getDataOutput());
        join.connectData2Input(query2.getDataOutput());
View Full Code Here
37
38
39
40
41
42
43
44
45
46
47
        }
        PipelineWorkflow workflow = new PipelineWorkflow();

        SQLQuery query = new SQLQuery();
        query.setResourceID(resource);
        query.addExpression("SELECT temperature, humidity, outlook, windy, weather.play FROM weather JOIN measurements ON weather.id = measurements.id");
        workflow.add(query);
       
        ListRandomSplit split = new ListRandomSplit();
        split.setNumberOfOutputs(count);
        split.connectDataInput(query.getDataOutput());
View Full Code Here
118
119
120
121
122
123
124
125
126
127
128
        executeWorkflow(drer, workflow);
        ResourceID cacheID = createCache.nextResult();
       
        String sql = "SELECT name, address FROM littleblackbook WHERE id<100";
        SQLQuery query = new SQLQuery();
        query.addExpression(sql);
        query.setResourceID("MySQLResource");
        WriteToDataCache write = new WriteToDataCache();
        write.setResourceID(cacheID);
        write.connectDataInput(query.getDataOutput());
       
View Full Code Here
154
155
156
157
158
159
160
161
162
163
164
       
        System.out.println("DATA CACHE: " + (stop-start) + "ms");
       
        query = new SQLQuery();
        query.addExpression(sql);
        query.setResourceID("MySQLResource");
        tupleToWRS = new TupleToWebRowSetCharArrays();
        tupleToWRS.connectDataInput(query.getDataOutput());
        deliver = new DeliverToRequestStatus();
        deliver.connectInput(tupleToWRS.getResultOutput());
View Full Code Here
116
117
118
119
120
121
122
123
124
125
126
        executeWorkflow(drer, workflow);
        ResourceID cacheID = createCache.nextResult();
       
        String sql = "SELECT name, address FROM littleblackbook WHERE id=7958";
        SQLQuery query = new SQLQuery();
        query.addExpression(sql);
        query.setResourceID("MySQLResource");
        WriteToDataCache write = new WriteToDataCache();
        write.setResourceID(cacheID);
        write.connectDataInput(query.getDataOutput());
       
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.