org.thales.punch.applications.gateway.services

Class PunchlineExecuteService

java.lang.Object

org.thales.punch.applications.gateway.services.PunchlineExecuteService

@Service
 @ConditionalOnProperty(value="punchline.enabled",
                       havingValue="true")
public class PunchlineExecuteService
extends Object

Method Summary

Modifier and Type	Method and Description
String	analyticsScan() Launch analytics scan and return shell response
org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBody	execute(String tenant, org.springframework.web.multipart.MultipartFile file, String runtime) Execute a one-shot Punchline
org.thales.punch.settings.api.ISettingsList	getAllExecutions(String tenant, String pmlId) Get executions of all Punchline for a tenant
String	getExecutionOutputById(String executionId) Get execution output of a Punchline
org.thales.punch.settings.api.ISettingsList	getExecutionsEventById(String executionId) Get execution events of a Punchline
String[]	getPunchlineClientArgs(String tenant, String runtime, File file)
String	scanPyspark() Launch pyspark scan and return shell response
void	startPunchlineClientAsync(String tenant, File file, String runtimeId, String runtime, String punchlineDescription)
org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBody	startPunchlineForeground(String tenant, String runtime, File file)
String	stormScan() Launch storm scan and return shell response
org.thales.punch.settings.api.ISettingsMap	trigger(String args, String tenant)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

analyticsScan

public String analyticsScan()
                     throws InterruptedException

Launch analytics scan and return shell response

Returns:

analytics scan response

Throws:

InterruptedException - if subprocess is interrupted

stormScan

public String stormScan()
                 throws InterruptedException

Launch storm scan and return shell response

Returns:

storm scan response

Throws:

InterruptedException - if subprocess is interrupted

scanPyspark

public String scanPyspark()
                   throws InterruptedException

Launch pyspark scan and return shell response

Returns:

pyspark scan response

Throws:

InterruptedException - Subprocess interrupted

execute

public org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBody execute(String tenant,
                                                                                           org.springframework.web.multipart.MultipartFile file,
                                                                                           String runtime)
                                                                                    throws IOException,
                                                                                           InterruptedException

Execute a one-shot Punchline

Parameters:

tenant - Tenant name

file - Punchline file

runtime - Execution environment (storm | spark | pyspark)

Returns:

The result of the punchline execution

Throws:

IOException - Error when storing given file in the filesystem

InterruptedException

getPunchlineClientArgs

public String[] getPunchlineClientArgs(String tenant,
                                       String runtime,
                                       File file)

startPunchlineForeground

public org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBody startPunchlineForeground(String tenant,
                                                                                                            String runtime,
                                                                                                            File file)

startPunchlineClientAsync

public void startPunchlineClientAsync(String tenant,
                                      File file,
                                      String runtimeId,
                                      String runtime,
                                      String punchlineDescription)

getExecutionsEventById

public org.thales.punch.settings.api.ISettingsList getExecutionsEventById(String executionId)
                                                                   throws IOException

Get execution events of a Punchline

Parameters:

executionId - ID of the execution

Returns:

List of execution (message + timestamp)

Throws:

IOException - Error when getting executions from ES

getExecutionOutputById

public String getExecutionOutputById(String executionId)
                              throws IOException

Get execution output of a Punchline

Parameters:

executionId - ID of the execution

Returns:

Output of the execution

Throws:

IOException - Error when getting executions from ES

getAllExecutions

public org.thales.punch.settings.api.ISettingsList getAllExecutions(String tenant,
                                                                    String pmlId)
                                                             throws IOException

Get executions of all Punchline for a tenant

Parameters:

tenant - Tenant name

Returns:

List of executions

Throws:

IOException - Error when getting data from ES

trigger

public org.thales.punch.settings.api.ISettingsMap trigger(String args,
                                                          String tenant)