VMware GemFire Java API Reference
Class CreateRegionFunction
- java.lang.Object
-
- org.apache.geode.modules.util.CreateRegionFunction
-
- All Implemented Interfaces:
Serializable,Declarable,Function,DataSerializable,Identifiable
public class CreateRegionFunction extends Object implements Function, Declarable, DataSerializable
- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.geode.DataSerializable
DataSerializable.Replaceable
-
-
Constructor Summary
Constructors Constructor Description CreateRegionFunction()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidexecute(FunctionContext context)The method which contains the logic to be executed.voidfromData(DataInput in)Reads the state of this object as primitive data from the givenDataInput.StringgetId()Return a unique function identifier, used to register the function withFunctionServiceCollection<ResourcePermission>getRequiredPermissions(String regionName)Returns the list of ResourcePermission this function requires.booleanhasResult()Specifies whether the function sends results while executing.booleanisHA()Specifies whether the function is eligible for re-execution (in case of failure).booleanoptimizeForWrite()Return true to indicate to GemFire the method requires optimization for writing the targetedFunctionService.onRegion(org.apache.geode.cache.Region)and any associated routing objects.voidtoData(DataOutput out)Writes the state of this object as primitive data to the givenDataOutput.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.geode.cache.Declarable
init, initialize
-
Methods inherited from interface org.apache.geode.cache.execute.Function
getRequiredPermissions
-
-
-
-
Field Detail
-
ID
public static final String ID
- See Also:
- Constant Field Values
-
-
Method Detail
-
execute
public void execute(FunctionContext context)
Description copied from interface:FunctionThe method which contains the logic to be executed. This method should be thread safe and may be invoked more than once on a given member for a singleExecution. The context provided to this function is the one which was built using Execution. The contexts can be data dependent or data-independent so user should check to see if the context provided in parameter is instance ofRegionFunctionContext.
-
getRequiredPermissions
public Collection<ResourcePermission> getRequiredPermissions(String regionName)
Description copied from interface:FunctionReturns the list of ResourcePermission this function requires.By default, functions require DATA:WRITE permission. If your function requires other permissions, you will need to override this method.
Please be as specific as possible when you set the required permissions for your function e.g. if your function reads from a region, it would be good to include the region name in your permission. It's better to return "DATA:READ:regionName" as the required permission other than "DATA:READ", because the latter means only users with read permission on ALL regions can execute your function.
All the permissions returned from this method will be ANDed together.
- Specified by:
getRequiredPermissionsin interfaceFunction- Parameters:
regionName- the region this function will be executed on. The regionName is optional and will only be present when the function is executed by an onRegion() executor. In other cases, it will be null. This method returns permissions appropriate to the context, independent of the presence of the regionName parameter.- Returns:
- a collection of
ResourcePermissions indicating the permissions required to execute the function.
-
getId
public String getId()
Description copied from interface:FunctionReturn a unique function identifier, used to register the function withFunctionService- Specified by:
getIdin interfaceFunction- Specified by:
getIdin interfaceIdentifiable- Returns:
- string identifying this function
-
optimizeForWrite
public boolean optimizeForWrite()
Description copied from interface:FunctionReturn true to indicate to GemFire the method requires optimization for writing the targeted
FunctionService.onRegion(org.apache.geode.cache.Region)and any associated routing objects.Returning false will optimize for read behavior on the targeted
FunctionService.onRegion(org.apache.geode.cache.Region)and any associated routing objects.This method is only consulted when Region passed to FunctionService#onRegion(org.apache.geode.cache.Region) is a partitioned region
- Specified by:
optimizeForWritein interfaceFunction- Returns:
- false if the function is read only, otherwise returns true
- See Also:
FunctionService
-
isHA
public boolean isHA()
Description copied from interface:FunctionSpecifies whether the function is eligible for re-execution (in case of failure).- Specified by:
isHAin interfaceFunction- Returns:
- whether the function is eligible for re-execution.
- See Also:
FunctionContext.isPossibleDuplicate()
-
hasResult
public boolean hasResult()
Description copied from interface:FunctionSpecifies whether the function sends results while executing. The method returns false if no result is expected.
If this method returns false,
ResultCollector.getResult()throwsFunctionException.If this method returns true,
ResultCollector.getResult()blocks and waits for the result of function execution
-
toData
public void toData(DataOutput out)
Description copied from interface:DataSerializableWrites the state of this object as primitive data to the givenDataOutput.Since 5.7 it is possible for any method call to the specified
DataOutputto throwGemFireRethrowable. It should not be caught by user code. If it is it must be rethrown.- Specified by:
toDatain interfaceDataSerializable- Parameters:
out- theDataOutputto write to
-
fromData
public void fromData(DataInput in)
Description copied from interface:DataSerializableReads the state of this object as primitive data from the givenDataInput.- Specified by:
fromDatain interfaceDataSerializable- Parameters:
in- theDataInputto read from
-
-