org.rvpf.base.util

Class PointValuesLoader

Object

PointValuesLoader

All Implemented Interfaces:

Callable<Integer>

@ThreadSafe
public final class PointValuesLoader
extends Object
implements Callable<Integer>

Point values loader.

Helper class for scripts: on call(), it sends the PointValues obtained from an PointValuesLoader.Input to a store via a StoreSessionProxy.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	PointValuesLoader.Input Input.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_BATCH_LIMIT Default batch limit.

Constructor Summary

Constructors

Constructor and Description
PointValuesLoader(StoreSessionProxy storeSessionProxy, PointValuesLoader.Input input) Constructs an instance.

Method Summary

Modifier and Type	Method and Description
Integer	call()
int	getBatchLimit() Gets the batch limit.
void	setBatchLimit(int batchLimit) Sets the batch limit.

Methods inherited from class Object

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

Field Detail

DEFAULT_BATCH_LIMIT

public static final int DEFAULT_BATCH_LIMIT

Default batch limit.

See Also:

Constant Field Values

Constructor Detail

PointValuesLoader

public PointValuesLoader(@Nonnull
                         StoreSessionProxy storeSessionProxy,
                         @Nonnull
                         PointValuesLoader.Input input)

Constructs an instance.

Parameters:

storeSessionProxy - A store session proxy.

input - An input.

Method Detail

call

public Integer call()
             throws Exception

Specified by:

call in interface Callable<Integer>

Returns:

The number of point values loaded.

Throws:

Exception

getBatchLimit

@CheckReturnValue
public int getBatchLimit()

Gets the batch limit.

Returns:

The batch limit.

setBatchLimit

public void setBatchLimit(int batchLimit)

Sets the batch limit.

Parameters:

batchLimit - The batch limit.