public class ChunkedRemoteBulkInsertOperation extends Object implements ILowLevelBulkInsertOperation
Constructor and Description |
---|
ChunkedRemoteBulkInsertOperation(BulkInsertOptions options,
ServerClient serverClient,
IDatabaseChanges changes) |
Modifier and Type | Method and Description |
---|---|
void |
abort() |
void |
close() |
UUID |
getOperationId() |
Action1<String> |
getReport() |
boolean |
isAborted() |
void |
setReport(Action1<String> report)
Report of the progress of operation
|
void |
write(String id,
RavenJObject metadata,
RavenJObject data) |
void |
write(String id,
RavenJObject metadata,
RavenJObject data,
Integer dataSize) |
public ChunkedRemoteBulkInsertOperation(BulkInsertOptions options, ServerClient serverClient, IDatabaseChanges changes)
public UUID getOperationId()
getOperationId
in interface ILowLevelBulkInsertOperation
public void write(String id, RavenJObject metadata, RavenJObject data) throws InterruptedException
write
in interface ILowLevelBulkInsertOperation
InterruptedException
public void write(String id, RavenJObject metadata, RavenJObject data, Integer dataSize) throws InterruptedException
write
in interface ILowLevelBulkInsertOperation
InterruptedException
public Action1<String> getReport()
getReport
in interface ILowLevelBulkInsertOperation
public void setReport(Action1<String> report)
ILowLevelBulkInsertOperation
setReport
in interface ILowLevelBulkInsertOperation
public void abort()
abort
in interface ILowLevelBulkInsertOperation
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in interface CleanCloseable
public boolean isAborted()
isAborted
in interface ILowLevelBulkInsertOperation
Copyright © 2016. All Rights Reserved.