merged changes for SGF-93. Updated documentation
This commit is contained in:
@@ -27,9 +27,9 @@ import com.gemstone.gemfire.cache.execute.ResultSender;
|
||||
* Sends collection results using a {@link ResultSender} in chunks determined by batchSize
|
||||
*
|
||||
* @author David Turanski
|
||||
*
|
||||
* @since 1.3.0
|
||||
*/
|
||||
public class BatchingResultSender {
|
||||
class BatchingResultSender {
|
||||
private final int batchSize;
|
||||
private ResultSender<Object> resultSender;
|
||||
|
||||
|
||||
@@ -16,9 +16,10 @@ import com.gemstone.gemfire.cache.execute.FunctionContext;
|
||||
|
||||
/**
|
||||
* @author David Turanski
|
||||
* @since 1.3.0
|
||||
*
|
||||
*/
|
||||
public class DefaultFunctionArgumentResolver implements FunctionArgumentResolver {
|
||||
class DefaultFunctionArgumentResolver implements FunctionArgumentResolver {
|
||||
|
||||
/* (non-Javadoc)
|
||||
* @see org.springframework.data.gemfire.function.FunctionArgumentResolver#resolveFunctionArguments(com.gemstone.gemfire.cache.execute.FunctionContext)
|
||||
|
||||
@@ -17,8 +17,9 @@ import com.gemstone.gemfire.cache.execute.FunctionContext;
|
||||
/**
|
||||
* Strategy Interface for resolving function invocation arguments, given a {@link FunctionContext}
|
||||
* @author David Turanski
|
||||
* @since 1.3.0
|
||||
*
|
||||
*/
|
||||
public interface FunctionArgumentResolver {
|
||||
public Object[] resolveFunctionArguments(FunctionContext functionContext);
|
||||
interface FunctionArgumentResolver {
|
||||
Object[] resolveFunctionArguments(FunctionContext functionContext);
|
||||
}
|
||||
|
||||
@@ -32,9 +32,10 @@ import com.gemstone.gemfire.cache.partition.PartitionRegionHelper;
|
||||
|
||||
/**
|
||||
* @author David Turanski
|
||||
* @since 1.3.0
|
||||
*
|
||||
*/
|
||||
public class FunctionContextInjectingArgumentResolver extends DefaultFunctionArgumentResolver {
|
||||
class FunctionContextInjectingArgumentResolver extends DefaultFunctionArgumentResolver {
|
||||
|
||||
private static Log logger = LogFactory.getLog(FunctionContextInjectingArgumentResolver.class);
|
||||
|
||||
|
||||
@@ -31,7 +31,7 @@ import org.springframework.util.StringUtils;
|
||||
* @author David Turanski
|
||||
*
|
||||
*/
|
||||
public class FunctionExecutionBeanDefinitionRegistrar implements ImportBeanDefinitionRegistrar {
|
||||
class FunctionExecutionBeanDefinitionRegistrar implements ImportBeanDefinitionRegistrar {
|
||||
|
||||
/* (non-Javadoc)
|
||||
* @see org.springframework.context.annotation.ImportBeanDefinitionRegistrar#registerBeanDefinitions(org.springframework.core.type.AnnotationMetadata, org.springframework.beans.factory.support.BeanDefinitionRegistry)
|
||||
|
||||
@@ -16,10 +16,11 @@ import com.gemstone.gemfire.cache.execute.Execution;
|
||||
import com.gemstone.gemfire.cache.execute.FunctionService;
|
||||
|
||||
/**
|
||||
* A FunctionExecution wrapper for onMembers execution
|
||||
* @author David Turanski
|
||||
*
|
||||
* @since 1.3.0
|
||||
*/
|
||||
public class AllMembersFunctionExecution extends AbstractFunctionExecution {
|
||||
class AllMembersFunctionExecution extends AbstractFunctionExecution {
|
||||
|
||||
@Override
|
||||
protected Execution getExecution() {
|
||||
|
||||
@@ -19,7 +19,7 @@ import com.gemstone.gemfire.cache.execute.FunctionService;
|
||||
* @author David Turanski
|
||||
*
|
||||
*/
|
||||
public class DefaultMemberFunctionExecution extends AbstractFunctionExecution {
|
||||
class DefaultMemberFunctionExecution extends AbstractFunctionExecution {
|
||||
|
||||
@Override
|
||||
protected Execution getExecution() {
|
||||
|
||||
@@ -22,7 +22,7 @@ import com.gemstone.gemfire.distributed.DistributedMember;
|
||||
* @author David Turanski
|
||||
*
|
||||
*/
|
||||
public class DistributedMemberFunctionExecution extends AbstractFunctionExecution {
|
||||
class DistributedMemberFunctionExecution extends AbstractFunctionExecution {
|
||||
|
||||
|
||||
private final DistributedMember distributedMember;
|
||||
|
||||
@@ -22,7 +22,7 @@ import com.gemstone.gemfire.distributed.DistributedMember;
|
||||
* @author David Turanski
|
||||
*
|
||||
*/
|
||||
public class DistributedMembersFunctionExecution extends AbstractFunctionExecution {
|
||||
class DistributedMembersFunctionExecution extends AbstractFunctionExecution {
|
||||
|
||||
private final Set<DistributedMember> distributedMembers;
|
||||
/**
|
||||
|
||||
@@ -21,7 +21,7 @@ import com.gemstone.gemfire.cache.execute.FunctionService;
|
||||
* @author David Turanski
|
||||
*
|
||||
*/
|
||||
public class GroupMemberFunctionExecution extends AbstractFunctionExecution {
|
||||
class GroupMemberFunctionExecution extends AbstractFunctionExecution {
|
||||
|
||||
private final String groups[];
|
||||
|
||||
|
||||
@@ -21,7 +21,7 @@ import com.gemstone.gemfire.cache.execute.FunctionService;
|
||||
* @author David Turanski
|
||||
*
|
||||
*/
|
||||
public class GroupMembersFunctionExecution extends AbstractFunctionExecution {
|
||||
class GroupMembersFunctionExecution extends AbstractFunctionExecution {
|
||||
|
||||
private final String groups[];
|
||||
|
||||
|
||||
@@ -25,7 +25,7 @@ import com.gemstone.gemfire.cache.execute.FunctionService;
|
||||
* @author David Turanski
|
||||
*
|
||||
*/
|
||||
public class PoolServerFunctionExecution extends AbstractFunctionExecution implements InitializingBean {
|
||||
class PoolServerFunctionExecution extends AbstractFunctionExecution implements InitializingBean {
|
||||
|
||||
|
||||
private Pool pool;
|
||||
|
||||
@@ -23,7 +23,7 @@ import com.gemstone.gemfire.cache.execute.FunctionService;
|
||||
* @author David Turanski
|
||||
*
|
||||
*/
|
||||
public class PoolServersFunctionExecution extends AbstractFunctionExecution {
|
||||
class PoolServersFunctionExecution extends AbstractFunctionExecution {
|
||||
|
||||
|
||||
private final Pool pool;
|
||||
|
||||
@@ -25,7 +25,7 @@ import com.gemstone.gemfire.cache.execute.FunctionService;
|
||||
* @author David Turanski
|
||||
*
|
||||
*/
|
||||
public class RegionFunctionExecution extends AbstractFunctionExecution {
|
||||
class RegionFunctionExecution extends AbstractFunctionExecution {
|
||||
|
||||
|
||||
private final Region<?, ?> region;
|
||||
|
||||
@@ -23,7 +23,7 @@ import com.gemstone.gemfire.cache.execute.FunctionService;
|
||||
* @author David Turanski
|
||||
*
|
||||
*/
|
||||
public class ServerFunctionExecution extends AbstractFunctionExecution {
|
||||
class ServerFunctionExecution extends AbstractFunctionExecution {
|
||||
|
||||
|
||||
private RegionService regionService;
|
||||
|
||||
@@ -23,7 +23,7 @@ import com.gemstone.gemfire.cache.execute.FunctionService;
|
||||
* @author David Turanski
|
||||
*
|
||||
*/
|
||||
public class ServersFunctionExecution extends AbstractFunctionExecution {
|
||||
class ServersFunctionExecution extends AbstractFunctionExecution {
|
||||
|
||||
|
||||
private final RegionService regionService;
|
||||
|
||||
Reference in New Issue
Block a user