RetryingTarantoolSpace (Java driver for Picodata 2.0.0 API)

java.lang.Object
- io.picodata.driver.core.space.RetryingTarantoolSpace<T,R>

Type Parameters:

T - target tuple type

R - target tuple collection type

All Implemented Interfaces:

TarantoolSpaceOperations<T,R>
```
public class RetryingTarantoolSpace<T extends Packable,R extends Collection<T>>
extends Object
implements TarantoolSpaceOperations<T,R>
```
Wrapper for TarantoolSpaceOperations instances which adds request retry policy to each operation

Constructor Summary

Constructors
Constructor and Description
`RetryingTarantoolSpace(TarantoolSpaceOperations<T,R> spaceOperations, RequestRetryPolicyFactory retryPolicyFactory, Executor executor)` Basic constructor

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`TarantoolCursor<T>`	`cursor(Conditions conditions)` Same as `TarantoolSpaceOperations.cursor(Conditions, int)` but uses the default batch size.
`TarantoolCursor<T>`	`cursor(Conditions conditions, int batchSize)` Cursor is an iterator-like object that is able to scroll through results of a query.
`CompletableFuture<R>`	`delete(Conditions conditions)` Delete a tuple.
`CompletableFuture<R>`	`delete(Conditions conditions, DeleteOptions options)` Delete a tuple.
`TarantoolSpaceMetadata`	`getMetadata()` Get metadata associated with this space
`CompletableFuture<R>`	`insert(T tuple)` Inserts tuple into the space, if no tuple with same unique keys exists.
`CompletableFuture<R>`	`insert(T tuple, InsertOptions options)` Inserts tuple into the space, if no tuple with same unique keys exists.
`CompletableFuture<R>`	`insertMany(Collection<T> tuples)` Inserts several tuples into the space at once.
`CompletableFuture<R>`	`insertMany(Collection<T> tuples, InsertManyOptions options)` Inserts several tuples into the space at once.
`CompletableFuture<R>`	`replace(T tuple)` Insert a tuple into the space or replace an existing one.
`CompletableFuture<R>`	`replace(T tuple, ReplaceOptions options)` Insert a tuple into the space or replace an existing one.
`CompletableFuture<R>`	`replaceMany(Collection<T> tuples)` Insert or replace several tuples into the space at once.
`CompletableFuture<R>`	`replaceMany(Collection<T> tuples, ReplaceManyOptions options)` Insert or replace several tuples into the space at once.
`CompletableFuture<R>`	`select(Conditions conditions)` Select tuples matching the specified query with options.
`CompletableFuture<R>`	`select(Conditions conditions, SelectOptions options)` Select tuples matching the specified query with specified conditions and options.
`CompletableFuture<Void>`	`truncate()` Truncate space if space would be found.
`CompletableFuture<R>`	`update(Conditions conditions, T tuple)` Update a tuple.
`CompletableFuture<R>`	`update(Conditions conditions, T tuple, UpdateOptions options)` Update a tuple.
`CompletableFuture<R>`	`update(Conditions conditions, TupleOperations operations)` Update a tuple.
`CompletableFuture<R>`	`update(Conditions conditions, TupleOperations operations, UpdateOptions options)` Update a tuple.
`CompletableFuture<R>`	`upsert(Conditions conditions, T tuple, TupleOperations operations)` Update tuple if it would be found elsewhere try to insert tuple.
`CompletableFuture<R>`	`upsert(Conditions conditions, T tuple, TupleOperations operations, UpsertOptions options)` Update tuple if it would be found elsewhere try to insert tuple.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - RetryingTarantoolSpace
```
public RetryingTarantoolSpace(TarantoolSpaceOperations<T,R> spaceOperations,
                              RequestRetryPolicyFactory retryPolicyFactory,
                              Executor executor)
```
    Basic constructor
    
    Parameters:
    
    spaceOperations - TarantoolSpaceOperations instance which operations will be wrapped
    
    retryPolicyFactory - request retrying policy factory
    
    executor - executor service for retry callbacks
- Method Detail
  - delete
```
public CompletableFuture<R> delete(Conditions conditions)
                            throws TarantoolClientException
```
    Description copied from interface: TarantoolSpaceOperations
    
    Delete a tuple. Only a single primary index value condition is supported.
    
    Specified by:
    
    delete in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    conditions - query with options
    
    Returns:
    
    a future that will contain removed tuple once completed
    
    Throws:
    
    TarantoolClientException - in case if the request failed
  - delete
```
public CompletableFuture<R> delete(Conditions conditions,
                                   DeleteOptions options)
                            throws TarantoolClientException
```
    Description copied from interface: TarantoolSpaceOperations
    
    Delete a tuple. Only a single primary index value condition is supported.
    
    Specified by:
    
    delete in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    conditions - query with options
    
    options - operation options
    
    Returns:
    
    a future that will contain removed tuple once completed
    
    Throws:
    
    TarantoolClientException - in case if the request failed
  - insert
```
public CompletableFuture<R> insert(T tuple)
                            throws TarantoolClientException
```
    Description copied from interface: TarantoolSpaceOperations
    
    Inserts tuple into the space, if no tuple with same unique keys exists. Otherwise throw duplicate key error.
    
    Specified by:
    
    insert in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    tuple - new data
    
    Returns:
    
    a future that will contain all corresponding tuples once completed
    
    Throws:
    
    TarantoolClientException - in case if request failed
  - insert
```
public CompletableFuture<R> insert(T tuple,
                                   InsertOptions options)
                            throws TarantoolClientException
```
    Description copied from interface: TarantoolSpaceOperations
    
    Inserts tuple into the space, if no tuple with same unique keys exists. Otherwise throw duplicate key error.
    
    Specified by:
    
    insert in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    tuple - new data
    
    options - operation options
    
    Returns:
    
    a future that will contain all corresponding tuples once completed
    
    Throws:
    
    TarantoolClientException - in case if request failed
  - insertMany
```
public CompletableFuture<R> insertMany(Collection<T> tuples)
                                throws TarantoolClientException
```
    Description copied from interface: TarantoolSpaceOperations
    
    Inserts several tuples into the space at once. If writing of any tuple fails, all tuples will not be saved.
    
    Specified by:
    
    insertMany in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    tuples - new data
    
    Returns:
    
    a future that will contain all corresponding tuples once completed
    
    Throws:
    
    TarantoolClientException - in case if request failed
  - insertMany
```
public CompletableFuture<R> insertMany(Collection<T> tuples,
                                       InsertManyOptions options)
                                throws TarantoolClientException
```
    Description copied from interface: TarantoolSpaceOperations
    
    Inserts several tuples into the space at once. If writing of any tuple fails, all tuples will not be saved.
    
    Specified by:
    
    insertMany in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    tuples - new data
    
    options - operation options
    
    Returns:
    
    a future that will contain all corresponding tuples once completed
    
    Throws:
    
    TarantoolClientException - in case if request failed
  - replace
```
public CompletableFuture<R> replace(T tuple)
                             throws TarantoolClientException
```
    Description copied from interface: TarantoolSpaceOperations
    
    Insert a tuple into the space or replace an existing one.
    
    Specified by:
    
    replace in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    tuple - new data
    
    Returns:
    
    a future that will contain all corresponding tuples once completed
    
    Throws:
    
    TarantoolClientException - in case if request failed
  - replace
```
public CompletableFuture<R> replace(T tuple,
                                    ReplaceOptions options)
                             throws TarantoolClientException
```
    Description copied from interface: TarantoolSpaceOperations
    
    Insert a tuple into the space or replace an existing one.
    
    Specified by:
    
    replace in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    tuple - new data
    
    options - operation options
    
    Returns:
    
    a future that will contain all corresponding tuples once completed
    
    Throws:
    
    TarantoolClientException - in case if request failed
  - replaceMany
```
public CompletableFuture<R> replaceMany(Collection<T> tuples)
                                 throws TarantoolClientException
```
    Description copied from interface: TarantoolSpaceOperations
    
    Insert or replace several tuples into the space at once. If writing of any tuple fails, all tuples will not be saved.
    
    Specified by:
    
    replaceMany in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    tuples - new data
    
    Returns:
    
    a future that will contain all corresponding tuples once completed
    
    Throws:
    
    TarantoolClientException - in case if request failed
  - replaceMany
```
public CompletableFuture<R> replaceMany(Collection<T> tuples,
                                        ReplaceManyOptions options)
                                 throws TarantoolClientException
```
    Description copied from interface: TarantoolSpaceOperations
    
    Insert or replace several tuples into the space at once. If writing of any tuple fails, all tuples will not be saved, but this behavior can be changed with the options.
    
    Specified by:
    
    replaceMany in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    tuples - new data
    
    options - operation options
    
    Returns:
    
    a future that will contain all corresponding tuples once completed
    
    Throws:
    
    TarantoolClientException - in case if request failed
  - select
```
public CompletableFuture<R> select(Conditions conditions)
                            throws TarantoolClientException
```
    Description copied from interface: TarantoolSpaceOperations
    
    Select tuples matching the specified query with options.
    
    Specified by:
    
    select in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    conditions - query with options
    
    Returns:
    
    a future that will contain all corresponding tuples once completed
    
    Throws:
    
    TarantoolClientException - in case if the request failed
  - select
```
public CompletableFuture<R> select(Conditions conditions,
                                   SelectOptions options)
                            throws TarantoolClientException
```
    Description copied from interface: TarantoolSpaceOperations
    
    Select tuples matching the specified query with specified conditions and options.
    
    Specified by:
    
    select in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    conditions - specified conditions
    
    options - operation options
    
    Returns:
    
    a future that will contain all corresponding tuples once completed
    
    Throws:
    
    TarantoolClientException - in case if the request failed
  - update
```
public CompletableFuture<R> update(Conditions conditions,
                                   T tuple)
```
    Description copied from interface: TarantoolSpaceOperations
    
    Update a tuple. Only a single primary index value condition is supported.
    
    Specified by:
    
    update in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    conditions - query with options
    
    tuple - tuple with new field values
    
    Returns:
    
    a future that will contain corresponding tuple once completed
  - update
```
public CompletableFuture<R> update(Conditions conditions,
                                   T tuple,
                                   UpdateOptions options)
```
    Description copied from interface: TarantoolSpaceOperations
    
    Update a tuple. Only a single primary index value condition is supported.
    
    Specified by:
    
    update in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    conditions - query with options
    
    tuple - tuple with new field values
    
    options - operation options
    
    Returns:
    
    a future that will contain corresponding tuple once completed
  - update
```
public CompletableFuture<R> update(Conditions conditions,
                                   TupleOperations operations)
```
    Description copied from interface: TarantoolSpaceOperations
    
    Update a tuple. Only a single primary index value condition is supported.
    
    Specified by:
    
    update in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    conditions - query with options
    
    operations - the list update operations
    
    Returns:
    
    a future that will contain corresponding tuple once completed
  - update
```
public CompletableFuture<R> update(Conditions conditions,
                                   TupleOperations operations,
                                   UpdateOptions options)
```
    Description copied from interface: TarantoolSpaceOperations
    
    Update a tuple. Only a single primary index value condition is supported.
    
    Specified by:
    
    update in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    conditions - query with options
    
    operations - the list update operations
    
    options - operation options
    
    Returns:
    
    a future that will contain corresponding tuple once completed
  - upsert
```
public CompletableFuture<R> upsert(Conditions conditions,
                                   T tuple,
                                   TupleOperations operations)
```
    Description copied from interface: TarantoolSpaceOperations
    
    Update tuple if it would be found elsewhere try to insert tuple. Only a single primary index value condition is supported.
    
    Specified by:
    
    upsert in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    conditions - query with options
    
    tuple - new data that will be insert if tuple will be not found
    
    operations - the list of update operations to be performed if the tuple exists
    
    Returns:
    
    a future that will empty list
  - upsert
```
public CompletableFuture<R> upsert(Conditions conditions,
                                   T tuple,
                                   TupleOperations operations,
                                   UpsertOptions options)
```
    Description copied from interface: TarantoolSpaceOperations
    
    Update tuple if it would be found elsewhere try to insert tuple. Only a single primary index value condition is supported.
    
    Specified by:
    
    upsert in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    conditions - query with options
    
    tuple - new data that will be insert if tuple will be not found
    
    operations - the list of update operations to be performed if the tuple exists
    
    options - operation options
    
    Returns:
    
    a future that will empty list
  - truncate
```
public CompletableFuture<Void> truncate()
                                 throws TarantoolClientException
```
    Description copied from interface: TarantoolSpaceOperations
    
    Truncate space if space would be found. Otherwise, throw space not found error.
    
    Specified by:
    
    truncate in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Returns:
    
    a future that will contain void.
    
    Throws:
    
    TarantoolClientException - in case if request failed
  - getMetadata
```
public TarantoolSpaceMetadata getMetadata()
```
    Description copied from interface: TarantoolSpaceOperations
    
    Get metadata associated with this space
    
    Specified by:
    
    getMetadata in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Returns:
    
    space metadata
  - cursor
```
public TarantoolCursor<T> cursor(Conditions conditions,
                                 int batchSize)
```
    Description copied from interface: TarantoolSpaceOperations
    
    Cursor is an iterator-like object that is able to scroll through results of a query. Unlike a single cursor loads new tuples dynamically issuing requests to server.
    Select will fetch tuples matching the specified query. Each request to server will fetch no more than 'batch size' tuples.
    
    Specified by:
    
    cursor in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    conditions - query with options
    
    batchSize - size of a batch of single client request
    
    Returns:
    
    cursor that can iterate through all corresponding tuples
  - cursor
```
public TarantoolCursor<T> cursor(Conditions conditions)
```
    Description copied from interface: TarantoolSpaceOperations
    
    Same as TarantoolSpaceOperations.cursor(Conditions, int) but uses the default batch size.
    
    Specified by:
    
    cursor in interface TarantoolSpaceOperations<T extends Packable,R extends Collection<T>>
    
    Parameters:
    
    conditions - query with options
    
    Returns:
    
    cursor that can iterate through all corresponding tuples

Class RetryingTarantoolSpace<T extends Packable,R extends Collection<T>>

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

RetryingTarantoolSpace

Method Detail

delete

delete

insert

insert

insertMany

insertMany

replace

replace

replaceMany

replaceMany

select

select

update

update

update

update

upsert

upsert

truncate

getMetadata

cursor

cursor