| Modifier and Type | Class and Description |
|---|---|
| private static class |
| Modifier and Type | Field and Description |
|---|---|
| private AggrCompletionHandler. | |
| private int |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public void | cancelled()
Implements org. The operation was cancelled. |
| public void | completed(final WriteResult<K, L> result)
Implements org. The operation was completed. |
| private void | |
| public void | failed(final Throwable throwable)
Implements org. The operation was failed. |
| public void | register(final CompletionHandler<WriteResult<K, L>> completionHandler, final int bytesWrittenToReport)
|
| public void | updated(WriteResult<K, L> result)
Implements org. The callback method may be called, when there is some progress in operation execution, but it is still not completed |
| completionHandlerRecords | back to summary |
|---|---|
| private AggrCompletionHandler. | |
| recordsCount | back to summary |
|---|---|
| private int recordsCount | |
| AggrCompletionHandler | back to summary |
|---|---|
| pack-priv AggrCompletionHandler() | |
| cancelled | back to summary |
|---|---|
| public void cancelled() Implements org. Doc from org. The operation was cancelled.
| |
| completed | back to summary |
|---|---|
| public void completed(final WriteResult<K, L> result) Implements org. Doc from org. The operation was completed.
| |
| ensureCapacity | back to summary |
|---|---|
| private void ensureCapacity() | |
| failed | back to summary |
|---|---|
| public void failed(final Throwable throwable) Implements org. Doc from org. The operation was failed.
| |
| register | back to summary |
|---|---|
| public void register(final CompletionHandler<WriteResult<K, L>> completionHandler, final int bytesWrittenToReport) | |
| updated | back to summary |
|---|---|
| public void updated(WriteResult<K, L> result) Implements org. Doc from org. The callback method may be called, when there is some progress in operation execution, but it is still not completed
| |
| Modifier and Type | Field and Description |
|---|---|
| private int | |
| private CompletionHandler |
| Access | Constructor and Description |
|---|---|
| pack-priv | Record(final CompletionHandler<WriteResult<K, L>> completionHandler, final int bytesWrittenToReport)
|
| Modifier and Type | Method and Description |
|---|---|
| pack-priv void | |
| pack-priv void |
| bytesWrittenToReport | back to summary |
|---|---|
| private int bytesWrittenToReport | |
| completionHandler | back to summary |
|---|---|
| private CompletionHandler<WriteResult<K, L>> completionHandler | |
| Record | back to summary |
|---|---|
| pack-priv Record(final CompletionHandler<WriteResult<K, L>> completionHandler, final int bytesWrittenToReport) | |
| reset | back to summary |
|---|---|
| pack-priv void reset() | |
| set | back to summary |
|---|---|
| pack-priv void set(final CompletionHandler<WriteResult<K, L>> completionHandler, final int bytesWrittenToReport) | |