KuduSession (Kudu 0.5.0 API)

java.lang.Object
- org.kududb.client.KuduSession

All Implemented Interfaces:

SessionConfiguration
```
@InterfaceAudience.Public
 @InterfaceStability.Evolving
public class KuduSession
extends Object
implements SessionConfiguration
```
Synchronous version of AsyncKuduSession. Offers the same API but with blocking methods. A major difference with AsyncKuduSession is that the time spent waiting on operations is defined by setTimeoutMillis(long) which defaults to getting it from KuduClient.getDefaultOperationTimeoutMs().

Nested Class Summary
- Nested classes/interfaces inherited from interface org.kududb.client.SessionConfiguration
  SessionConfiguration.FlushMode

Field Summary

Fields
Modifier and Type Field and Description

static org.slf4j.Logger LOG

Fields
Modifier and Type	Field and Description
`static org.slf4j.Logger`	`LOG`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`OperationResponse`	`apply(Operation operation)` Blocking call with a different behavior based on the flush mode.
`List<OperationResponse>`	`close()` Blocking call that flushes the buffers (see `flush()` and closes the sessions.
`List<OperationResponse>`	`flush()` Blocking call that force flushes this session's buffers.
`SessionConfiguration.FlushMode`	`getFlushMode()` Get the current flush mode.
`long`	`getTimeoutMillis()` Get the current timeout.
`boolean`	`hasPendingOperations()` Check if there are operations that haven't been completely applied.
`boolean`	`isClosed()` Returns true if this session has already been closed.
`boolean`	`isIgnoreAllDuplicateRows()` Tells if the session is currently ignoring row errors when the whole list returned by a tablet server is of the AlreadyPresent type.
`void`	`setExternalConsistencyMode(ExternalConsistencyMode consistencyMode)` Set the new external consistency mode for this session.
`void`	`setFlushInterval(int interval)` Set the flush interval, which will be used for the next scheduling decision.
`void`	`setFlushMode(SessionConfiguration.FlushMode flushMode)` Set the new flush mode for this session.
`void`	`setIgnoreAllDuplicateRows(boolean ignoreAllDuplicateRows)` Configures the option to ignore all the row errors if they are all of the AlreadyPresent type.
`void`	`setMutationBufferLowWatermark(float mutationBufferLowWatermarkPercentage)` Set the low watermark for this session.
`void`	`setMutationBufferSpace(int size)` Set the number of operations that can be buffered.
`void`	`setTimeoutMillis(long timeout)` Sets the timeout for the next applied operations.

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

- Field Detail
  - LOG
```
public static final org.slf4j.Logger LOG
```
- Method Detail
  - apply
```
public OperationResponse apply(Operation operation)
                        throws Exception
```
    Blocking call with a different behavior based on the flush mode. PleaseThrottleException is managed by this method and will not be thrown, unlike AsyncKuduSession.apply(org.kududb.client.Operation).
    - AUTO_FLUSH_SYNC: the call returns when the operation is persisted, else it throws an exception.
    - AUTO_FLUSH_BACKGROUND: the call returns when the operation has been added to the buffer. The operation's state is then unreachable, meaning that there's no way to know if the operation is persisted. This call should normally perform only fast in-memory operations but it may have to wait when the buffer is full and there's another buffer being flushed.
    - MANUAL_FLUSH: the call returns when the operation has been added to the buffer, else it throws an exception such as a NonRecoverableException if the buffer is full.
    Parameters:
    
    operation - operation to apply
    
    Returns:
    
    an OperationResponse for the applied Operation
    
    Throws:
    
    Exception - if anything went wrong
  - flush
```
public List<OperationResponse> flush()
                              throws Exception
```
    Blocking call that force flushes this session's buffers. Data is persisted when this call returns, else it will throw an exception.
    
    Returns:
    
    a list of OperationResponse, one per operation that was flushed
    
    Throws:
    
    Exception - if anything went wrong. If it's an issue with some or all batches, it will be of type DeferredGroupException.
  - close
```
public List<OperationResponse> close()
                              throws Exception
```
    Blocking call that flushes the buffers (see flush() and closes the sessions.
    
    Returns:
    
    List of OperationResponse, one per operation that was flushed
    
    Throws:
    
    Exception - if anything went wrong. If it's an issue with some or all batches, it will be of type DeferredGroupException.
  - getFlushMode
```
public SessionConfiguration.FlushMode getFlushMode()
```
    Description copied from interface: SessionConfiguration
    
    Get the current flush mode.
    
    Specified by:
    
    getFlushMode in interface SessionConfiguration
    
    Returns:
    
    flush mode, AUTO_FLUSH_SYNC by default
  - setFlushMode
```
public void setFlushMode(SessionConfiguration.FlushMode flushMode)
```
    Description copied from interface: SessionConfiguration
    
    Set the new flush mode for this session.
    
    Specified by:
    
    setFlushMode in interface SessionConfiguration
    
    Parameters:
    
    flushMode - new flush mode, can be the same as the previous one.
  - setMutationBufferSpace
```
public void setMutationBufferSpace(int size)
```
    Description copied from interface: SessionConfiguration
    
    Set the number of operations that can be buffered.
    
    Specified by:
    
    setMutationBufferSpace in interface SessionConfiguration
    
    Parameters:
    
    size - number of ops.
  - setMutationBufferLowWatermark
```
public void setMutationBufferLowWatermark(float mutationBufferLowWatermarkPercentage)
```
    Description copied from interface: SessionConfiguration
    
    Set the low watermark for this session. The default is set to half the mutation buffer space. For example, a buffer space of 1000 with a low watermark set to 50% (0.5) will start randomly sending PleaseRetryExceptions once there's an outstanding flush and the buffer is over 500. As the buffer gets fuller, it becomes likelier to hit the exception.
    
    Specified by:
    
    setMutationBufferLowWatermark in interface SessionConfiguration
    
    Parameters:
    
    mutationBufferLowWatermarkPercentage - a new low watermark as a percentage, has to be between 0 and 1 (inclusive). A value of 1 disables the low watermark since it's the same as the high one
  - setFlushInterval
```
public void setFlushInterval(int interval)
```
    Description copied from interface: SessionConfiguration
    
    Set the flush interval, which will be used for the next scheduling decision.
    
    Specified by:
    
    setFlushInterval in interface SessionConfiguration
    
    Parameters:
    
    interval - interval in milliseconds.
  - getTimeoutMillis
```
public long getTimeoutMillis()
```
    Description copied from interface: SessionConfiguration
    
    Get the current timeout.
    
    Specified by:
    
    getTimeoutMillis in interface SessionConfiguration
    
    Returns:
    
    operation timeout in milliseconds, 0 if none was configured.
  - setTimeoutMillis
```
public void setTimeoutMillis(long timeout)
```
    Description copied from interface: SessionConfiguration
    
    Sets the timeout for the next applied operations. The default timeout is 0, which disables the timeout functionality.
    
    Specified by:
    
    setTimeoutMillis in interface SessionConfiguration
    
    Parameters:
    
    timeout - Timeout in milliseconds.
  - isClosed
```
public boolean isClosed()
```
    Description copied from interface: SessionConfiguration
    
    Returns true if this session has already been closed.
    
    Specified by:
    
    isClosed in interface SessionConfiguration
  - hasPendingOperations
```
public boolean hasPendingOperations()
```
    Description copied from interface: SessionConfiguration
    
    Check if there are operations that haven't been completely applied.
    
    Specified by:
    
    hasPendingOperations in interface SessionConfiguration
    
    Returns:
    
    true if operations are pending, else false.
  - setExternalConsistencyMode
```
public void setExternalConsistencyMode(ExternalConsistencyMode consistencyMode)
```
    Description copied from interface: SessionConfiguration
    
    Set the new external consistency mode for this session.
    
    Specified by:
    
    setExternalConsistencyMode in interface SessionConfiguration
    
    Parameters:
    
    consistencyMode - new external consistency mode, can the same as the previous one.
  - isIgnoreAllDuplicateRows
```
public boolean isIgnoreAllDuplicateRows()
```
    Description copied from interface: SessionConfiguration
    
    Tells if the session is currently ignoring row errors when the whole list returned by a tablet server is of the AlreadyPresent type.
    
    Specified by:
    
    isIgnoreAllDuplicateRows in interface SessionConfiguration
    
    Returns:
    
    true if the session is enforcing this, else false
  - setIgnoreAllDuplicateRows
```
public void setIgnoreAllDuplicateRows(boolean ignoreAllDuplicateRows)
```
    Description copied from interface: SessionConfiguration
    
    Configures the option to ignore all the row errors if they are all of the AlreadyPresent type. This can be needed when facing KUDU-568. The effect of enabling this is that operation responses that match this pattern will be cleared of their row errors, meaning that we consider them successful. This is disabled by default.
    
    Specified by:
    
    setIgnoreAllDuplicateRows in interface SessionConfiguration
    
    Parameters:
    
    ignoreAllDuplicateRows - true if this session should enforce this, else false

Class KuduSession

Nested Class Summary

Nested classes/interfaces inherited from interface org.kududb.client.SessionConfiguration

Field Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

LOG

Method Detail

apply

flush

close

getFlushMode

setFlushMode

setMutationBufferSpace

setMutationBufferLowWatermark

setFlushInterval

getTimeoutMillis

setTimeoutMillis

isClosed

hasPendingOperations

setExternalConsistencyMode

isIgnoreAllDuplicateRows

setIgnoreAllDuplicateRows