Skip to content

Commit a8cc092

Browse files
author
kalpshekhar
committed
Initial commit.
1 parent 3d7c045 commit a8cc092

File tree

44 files changed

+15207
-5587
lines changed

Some content is hidden

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

44 files changed

+15207
-5587
lines changed
-994 Bytes
Binary file not shown.
911 Bytes
Binary file not shown.

code/source/wx/streamsets/pub/jobRunner/utils.java renamed to code/source/wx/streamsets/v1/utils.java

Lines changed: 6 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package wx.streamsets.pub.jobRunner;
1+
package wx.streamsets.v1;
22

33
// -----( IS Java Code Template v1.2
44

@@ -25,24 +25,17 @@ public final class utils
2525

2626

2727

28-
public static final void sleep (IData pipeline)
28+
public static final void sleepForFiveSeconds (IData pipeline)
2929
throws ServiceException
3030
{
31-
// --- <<IS-START(sleep)>> ---
31+
// --- <<IS-START(sleepForFiveSeconds)>> ---
3232
// @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
33+
try {
34+
Thread.sleep(5000); //sleep for 5 seconds
4035
}
4136
catch(InterruptedException ie){
42-
//If this thread was intrrupted by nother thread
37+
throw new ServiceException(ie.getMessage());
4338
}
44-
45-
idc.destroy();
4639

4740
// --- <<IS-END>> ---
4841

ns/wx/streamsets/impl/jobRunner/docTypes/issue/node.ndf

Lines changed: 0 additions & 55 deletions
This file was deleted.

ns/wx/streamsets/impl/jobRunner/docTypes/jobStatusReq/node.ndf

Lines changed: 0 additions & 97 deletions
This file was deleted.

ns/wx/streamsets/impl/jobRunner/docTypes/jobStatusResp/node.ndf

Lines changed: 0 additions & 80 deletions
This file was deleted.

ns/wx/streamsets/pub/jobRunner/docTypes/issue/node.ndf

Lines changed: 0 additions & 55 deletions
This file was deleted.

0 commit comments

Comments
 (0)