Package step.functions.execution

Class FunctionExecutionServiceImpl

java.lang.Object

step.functions.execution.FunctionExecutionServiceImpl

All Implemented Interfaces:

FunctionExecutionService

public class FunctionExecutionServiceImpl
extends java.lang.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(java.lang.String tokenHandleId, Function function, FunctionInput<IN> functionInput, java.lang.Class<OUT> outputClass)
protected java.util.Map<java.lang.String,java.lang.String>	fileVersionIdToMap(java.lang.String propertyName, step.grid.filemanager.FileVersionId fileVersionId)
step.grid.TokenWrapper	getLocalTokenHandle()
step.grid.TokenWrapper	getTokenHandle(java.util.Map<java.lang.String,java.lang.String> attributes, java.util.Map<java.lang.String,step.grid.tokenpool.Interest> interests, boolean createSession, step.grid.TokenWrapperOwner tokenWrapperOwner)
protected java.util.Map<java.lang.String,java.lang.String>	registerFile(java.io.File file, java.lang.String properyName)
void	returnTokenHandle(java.lang.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(java.util.Map<java.lang.String,java.lang.String> attributes,
                                             java.util.Map<java.lang.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(java.lang.String tokenHandleId)
                       throws FunctionExecutionServiceException

Specified by:

returnTokenHandle in interface FunctionExecutionService

Throws:

FunctionExecutionServiceException

callFunction

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

Specified by:

callFunction in interface FunctionExecutionService

registerFile

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

Throws:

step.grid.filemanager.FileManagerException

fileVersionIdToMap

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