Package step.functions.execution

Class FunctionExecutionServiceImpl

java.lang.Object

step.functions.execution.FunctionExecutionServiceImpl

All Implemented Interfaces:

FunctionExecutionService

public class FunctionExecutionServiceImpl
extends Object
implements FunctionExecutionService

Constructor Summary

Constructors

Constructor	Description
FunctionExecutionServiceImpl(step.grid.client.GridClient gridClient, FunctionTypeRegistry functionTypeRegistry, DynamicBeanResolver dynamicBeanResolver)

Method Summary

Modifier and Type	Method	Description
<IN,OUT> step.functions.io.Output<OUT>	callFunction(String tokenHandleId, Function function, FunctionInput<IN> functionInput, Class<OUT> outputClass)
protected Map<String,String>	fileVersionIdToMap(String propertyName, step.grid.filemanager.FileVersionId fileVersionId)
step.grid.TokenWrapper	getLocalTokenHandle()
step.grid.TokenWrapper	getTokenHandle(Map<String,String> attributes, Map<String,step.grid.tokenpool.Interest> interests, boolean createSession, step.grid.TokenWrapperOwner tokenWrapperOwner)
protected Map<String,String>	registerFile(File file, String properyName)
void	returnTokenHandle(String tokenHandleId)

Methods inherited from class java.lang.Object

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

Constructor Detail

FunctionExecutionServiceImpl

public FunctionExecutionServiceImpl(step.grid.client.GridClient gridClient,
                                    FunctionTypeRegistry functionTypeRegistry,
                                    DynamicBeanResolver dynamicBeanResolver)
                             throws FunctionExecutionServiceException

Throws:

FunctionExecutionServiceException

Method Detail

getLocalTokenHandle

public step.grid.TokenWrapper getLocalTokenHandle()

Specified by:

getLocalTokenHandle in interface FunctionExecutionService

getTokenHandle

public step.grid.TokenWrapper getTokenHandle(Map<String,String> attributes,
                                             Map<String,step.grid.tokenpool.Interest> interests,
                                             boolean createSession,
                                             step.grid.TokenWrapperOwner tokenWrapperOwner)
                                      throws FunctionExecutionServiceException

Specified by:

getTokenHandle in interface FunctionExecutionService

Throws:

FunctionExecutionServiceException

returnTokenHandle

public void returnTokenHandle(String tokenHandleId)
                       throws FunctionExecutionServiceException

Specified by:

returnTokenHandle in interface FunctionExecutionService

Throws:

FunctionExecutionServiceException

callFunction

public <IN,OUT> step.functions.io.Output<OUT> callFunction(String tokenHandleId,
                                                                 Function function,
                                                                 FunctionInput<IN> functionInput,
                                                                 Class<OUT> outputClass)

Specified by:

callFunction in interface FunctionExecutionService

registerFile

protected Map<String,String> registerFile(File file,
                                                String properyName)
                                         throws step.grid.filemanager.FileManagerException

Throws:

step.grid.filemanager.FileManagerException

fileVersionIdToMap

protected Map<String,String> fileVersionIdToMap(String propertyName,
                                                      step.grid.filemanager.FileVersionId fileVersionId)