Skip to content

Commit 3d7c045

Browse files
author
E
committed
intial Commit
1 parent 8d92b84 commit 3d7c045

File tree

41 files changed

+11747
-0
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

41 files changed

+11747
-0
lines changed
Binary file not shown.
Lines changed: 52 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,52 @@
1+
package wx.streamsets.pub.jobRunner;
2+
3+
// -----( IS Java Code Template v1.2
4+
5+
import com.wm.data.*;
6+
import com.wm.util.Values;
7+
import com.wm.app.b2b.server.Service;
8+
import com.wm.app.b2b.server.ServiceException;
9+
// --- <<IS-START-IMPORTS>> ---
10+
// --- <<IS-END-IMPORTS>> ---
11+
12+
public final class utils
13+
14+
{
15+
// ---( internal utility methods )---
16+
17+
final static utils _instance = new utils();
18+
19+
static utils _newInstance() { return new utils(); }
20+
21+
static utils _cast(Object o) { return (utils)o; }
22+
23+
// ---( server methods )---
24+
25+
26+
27+
28+
public static final void sleep (IData pipeline)
29+
throws ServiceException
30+
{
31+
// --- <<IS-START(sleep)>> ---
32+
// @sigtype java 3.5
33+
IDataCursor idc = pipeline.getCursor();
34+
35+
36+
try{
37+
//do what you want to do before sleeping
38+
Thread.sleep(5000); //sleep for 1000 ms
39+
//do what you want to do after sleeptig
40+
}
41+
catch(InterruptedException ie){
42+
//If this thread was intrrupted by nother thread
43+
}
44+
45+
idc.destroy();
46+
47+
// --- <<IS-END>> ---
48+
49+
50+
}
51+
}
52+

manifest.v3

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
3+
<Values version="2.0">
4+
<value name="enabled">yes</value>
5+
<value name="system_package">no</value>
6+
<value name="version">1.0</value>
7+
<null name="startup_services"/>
8+
<null name="shutdown_services"/>
9+
<null name="replication_services"/>
10+
<null name="requires"/>
11+
<null name="listACL"/>
12+
<value name="webappLoad">yes</value>
13+
<value name="reloadWithDependentPackage">yes</value>
14+
</Values>

ns/wx/node.idf

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
3+
<Values version="2.0">
4+
<value name="node_type">interface</value>
5+
<value name="node_subtype">unknown</value>
6+
<value name="node_nsName">wx</value>
7+
<value name="is_public">false</value>
8+
</Values>
Lines changed: 55 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,55 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
3+
<Values version="2.0">
4+
<record name="record" javaclass="com.wm.util.Values">
5+
<value name="node_type">record</value>
6+
<value name="node_subtype">unknown</value>
7+
<value name="node_nsName">wx.streamsets.impl.jobRunner.docTypes:issue</value>
8+
<value name="node_pkg">WxStreamSets</value>
9+
<value name="node_comment"></value>
10+
<value name="is_public">false</value>
11+
<value name="field_type">record</value>
12+
<value name="field_dim">0</value>
13+
<value name="wrapper_type">IData</value>
14+
<value name="nillable">true</value>
15+
<value name="form_qualified">false</value>
16+
<value name="is_global">false</value>
17+
<array name="rec_fields" type="record" depth="1">
18+
<record javaclass="com.wm.util.Values">
19+
<value name="node_type">field</value>
20+
<value name="node_subtype">unknown</value>
21+
<value name="node_comment"></value>
22+
<record name="node_hints" javaclass="com.wm.util.Values">
23+
<value name="field_usereditable">true</value>
24+
<value name="field_largerEditor">false</value>
25+
<value name="field_password">false</value>
26+
</record>
27+
<value name="is_public">false</value>
28+
<value name="field_name">code</value>
29+
<value name="field_type">string</value>
30+
<value name="field_is_jsonSchema">true</value>
31+
<value name="field_dim">0</value>
32+
<array name="field_options" type="value" depth="1">
33+
</array>
34+
</record>
35+
<record javaclass="com.wm.util.Values">
36+
<value name="node_type">field</value>
37+
<value name="node_subtype">unknown</value>
38+
<value name="node_comment"></value>
39+
<record name="node_hints" javaclass="com.wm.util.Values">
40+
<value name="field_usereditable">true</value>
41+
<value name="field_largerEditor">false</value>
42+
<value name="field_password">false</value>
43+
</record>
44+
<value name="is_public">false</value>
45+
<value name="field_name">message</value>
46+
<value name="field_type">string</value>
47+
<value name="field_is_jsonSchema">true</value>
48+
<value name="field_dim">0</value>
49+
<array name="field_options" type="value" depth="1">
50+
</array>
51+
</record>
52+
</array>
53+
<value name="modifiable">true</value>
54+
</record>
55+
</Values>
Lines changed: 97 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,97 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
3+
<Values version="2.0">
4+
<record name="record" javaclass="com.wm.util.Values">
5+
<value name="node_type">record</value>
6+
<value name="node_subtype">unknown</value>
7+
<value name="node_nsName">wx.streamsets.impl.jobRunner.docTypes:jobStartReq</value>
8+
<value name="node_pkg">WxStreamSets</value>
9+
<value name="node_comment"></value>
10+
<value name="is_public">false</value>
11+
<value name="field_type">record</value>
12+
<value name="field_dim">0</value>
13+
<value name="wrapper_type">IData</value>
14+
<value name="nillable">true</value>
15+
<value name="form_qualified">false</value>
16+
<value name="is_global">false</value>
17+
<array name="rec_fields" type="record" depth="1">
18+
<record javaclass="com.wm.util.Values">
19+
<value name="node_type">record</value>
20+
<value name="node_subtype">unknown</value>
21+
<value name="node_comment"></value>
22+
<record name="node_hints" javaclass="com.wm.util.Values">
23+
<value name="field_usereditable">true</value>
24+
<value name="field_largerEditor">false</value>
25+
<value name="field_password">false</value>
26+
</record>
27+
<value name="is_public">false</value>
28+
<value name="field_name">baseURL</value>
29+
<value name="field_type">string</value>
30+
<value name="field_dim">0</value>
31+
<array name="field_options" type="value" depth="1">
32+
</array>
33+
<value name="nillable">true</value>
34+
<value name="form_qualified">false</value>
35+
<value name="is_global">false</value>
36+
</record>
37+
<record javaclass="com.wm.util.Values">
38+
<value name="node_type">record</value>
39+
<value name="node_subtype">unknown</value>
40+
<value name="node_comment"></value>
41+
<record name="node_hints" javaclass="com.wm.util.Values">
42+
<value name="field_usereditable">true</value>
43+
<value name="field_largerEditor">false</value>
44+
<value name="field_password">false</value>
45+
</record>
46+
<value name="is_public">false</value>
47+
<value name="field_name">credentialID</value>
48+
<value name="field_type">string</value>
49+
<value name="field_dim">0</value>
50+
<array name="field_options" type="value" depth="1">
51+
</array>
52+
<value name="nillable">true</value>
53+
<value name="form_qualified">false</value>
54+
<value name="is_global">false</value>
55+
</record>
56+
<record javaclass="com.wm.util.Values">
57+
<value name="node_type">record</value>
58+
<value name="node_subtype">unknown</value>
59+
<value name="node_comment"></value>
60+
<record name="node_hints" javaclass="com.wm.util.Values">
61+
<value name="field_usereditable">true</value>
62+
<value name="field_largerEditor">false</value>
63+
<value name="field_password">false</value>
64+
</record>
65+
<value name="is_public">false</value>
66+
<value name="field_name">token</value>
67+
<value name="field_type">string</value>
68+
<value name="field_dim">0</value>
69+
<array name="field_options" type="value" depth="1">
70+
</array>
71+
<value name="nillable">true</value>
72+
<value name="form_qualified">false</value>
73+
<value name="is_global">false</value>
74+
</record>
75+
<record javaclass="com.wm.util.Values">
76+
<value name="node_type">record</value>
77+
<value name="node_subtype">unknown</value>
78+
<value name="node_comment"></value>
79+
<record name="node_hints" javaclass="com.wm.util.Values">
80+
<value name="field_usereditable">true</value>
81+
<value name="field_largerEditor">false</value>
82+
<value name="field_password">false</value>
83+
</record>
84+
<value name="is_public">false</value>
85+
<value name="field_name">jobID</value>
86+
<value name="field_type">string</value>
87+
<value name="field_dim">0</value>
88+
<array name="field_options" type="value" depth="1">
89+
</array>
90+
<value name="nillable">true</value>
91+
<value name="form_qualified">false</value>
92+
<value name="is_global">false</value>
93+
</record>
94+
</array>
95+
<value name="modifiable">true</value>
96+
</record>
97+
</Values>
Lines changed: 81 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,81 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
3+
<Values version="2.0">
4+
<record name="record" javaclass="com.wm.util.Values">
5+
<value name="node_type">record</value>
6+
<value name="node_subtype">unknown</value>
7+
<value name="node_nsName">wx.streamsets.impl.jobRunner.docTypes:jobStartResp</value>
8+
<value name="node_pkg">WxStreamSets</value>
9+
<value name="node_comment"></value>
10+
<value name="is_public">false</value>
11+
<value name="field_type">record</value>
12+
<value name="field_dim">0</value>
13+
<value name="wrapper_type">IData</value>
14+
<value name="nillable">true</value>
15+
<value name="form_qualified">false</value>
16+
<value name="is_global">false</value>
17+
<array name="rec_fields" type="record" depth="1">
18+
<record javaclass="com.wm.util.Values">
19+
<value name="node_type">record</value>
20+
<value name="node_subtype">unknown</value>
21+
<value name="node_comment"></value>
22+
<record name="node_hints" javaclass="com.wm.util.Values">
23+
<value name="field_largerEditor">false</value>
24+
<value name="field_password">false</value>
25+
</record>
26+
<value name="is_public">false</value>
27+
<value name="field_name">ISSUES</value>
28+
<value name="field_type">recref</value>
29+
<value name="field_dim">1</value>
30+
<value name="wrapper_type">IData</value>
31+
<value name="nillable">true</value>
32+
<value name="form_qualified">false</value>
33+
<value name="is_global">false</value>
34+
<value name="is_soap_array_encoding_used">false</value>
35+
<value name="rec_closed">true</value>
36+
<value name="modifiable">true</value>
37+
<value name="rec_ref">wx.streamsets.impl.jobRunner.docTypes:issue</value>
38+
</record>
39+
<record javaclass="com.wm.util.Values">
40+
<value name="node_type">record</value>
41+
<value name="node_subtype">unknown</value>
42+
<value name="node_comment"></value>
43+
<record name="node_hints" javaclass="com.wm.util.Values">
44+
<value name="field_largerEditor">false</value>
45+
<value name="field_password">false</value>
46+
</record>
47+
<value name="is_public">false</value>
48+
<value name="field_name">jobStatus</value>
49+
<value name="field_type">recref</value>
50+
<value name="field_dim">0</value>
51+
<value name="wrapper_type">IData</value>
52+
<value name="nillable">true</value>
53+
<value name="form_qualified">false</value>
54+
<value name="is_global">false</value>
55+
<value name="rec_closed">true</value>
56+
<value name="modifiable">true</value>
57+
<value name="rec_ref">wx.streamsets.impl.jobRunner.docTypes:jobStatus</value>
58+
</record>
59+
<record javaclass="com.wm.util.Values">
60+
<value name="node_type">record</value>
61+
<value name="node_subtype">unknown</value>
62+
<value name="node_comment"></value>
63+
<record name="node_hints" javaclass="com.wm.util.Values">
64+
<value name="field_usereditable">true</value>
65+
<value name="field_largerEditor">false</value>
66+
<value name="field_password">false</value>
67+
</record>
68+
<value name="is_public">false</value>
69+
<value name="field_name">responseCode</value>
70+
<value name="field_type">string</value>
71+
<value name="field_dim">0</value>
72+
<array name="field_options" type="value" depth="1">
73+
</array>
74+
<value name="nillable">true</value>
75+
<value name="form_qualified">false</value>
76+
<value name="is_global">false</value>
77+
</record>
78+
</array>
79+
<value name="modifiable">true</value>
80+
</record>
81+
</Values>

0 commit comments

Comments
 (0)