Package | Description |
---|---|
org.apache.kudu.client |
Modifier and Type | Method and Description |
---|---|
OperationResponse |
KuduSession.apply(Operation operation)
Apply a given
Operation to Kudu as part of this session. |
Modifier and Type | Method and Description |
---|---|
com.stumbleupon.async.Deferred<OperationResponse> |
AsyncKuduSession.apply(Operation operation)
Apply the given operation.
|
List<OperationResponse> |
KuduSession.close()
Blocking call that flushes the buffers (see
KuduSession.flush() and closes the sessions. |
com.stumbleupon.async.Deferred<List<OperationResponse>> |
AsyncKuduSession.close()
Flushes the buffered operations and marks this session as closed.
|
List<OperationResponse> |
KuduSession.flush()
Blocking call that force flushes this session's buffers.
|
com.stumbleupon.async.Deferred<List<OperationResponse>> |
AsyncKuduSession.flush()
Flush buffered writes.
|
Modifier and Type | Method and Description |
---|---|
static List<RowError> |
OperationResponse.collectErrors(List<OperationResponse> responses)
Utility method that collects all the row errors from the given list of responses.
|
Copyright © 2018 The Apache Software Foundation. All rights reserved.