public class RemoteBulkInsertOperation extends java.lang.Object implements ILowLevelBulkInsertOperation, IObserver<BulkInsertChangeNotification>
Constructor and Description |
---|
RemoteBulkInsertOperation(BulkInsertOptions options,
ServerClient client,
IDatabaseChanges changes) |
Modifier and Type | Method and Description |
---|---|
void |
abort() |
void |
close() |
java.util.UUID |
getOperationId() |
Action1<java.lang.String> |
getReport() |
boolean |
isAborted() |
void |
onCompleted() |
void |
onError(java.lang.Exception error) |
void |
onNext(BulkInsertChangeNotification value) |
void |
setReport(Action1<java.lang.String> report)
Report of the progress of operation
|
void |
write(java.lang.String id,
RavenJObject metadata,
RavenJObject data) |
void |
write(java.lang.String id,
RavenJObject metadata,
RavenJObject data,
java.lang.Integer dataSize) |
public RemoteBulkInsertOperation(BulkInsertOptions options, ServerClient client, IDatabaseChanges changes)
public java.util.UUID getOperationId()
getOperationId
in interface ILowLevelBulkInsertOperation
public Action1<java.lang.String> getReport()
getReport
in interface ILowLevelBulkInsertOperation
public void setReport(Action1<java.lang.String> report)
ILowLevelBulkInsertOperation
setReport
in interface ILowLevelBulkInsertOperation
public void write(java.lang.String id, RavenJObject metadata, RavenJObject data) throws java.lang.InterruptedException
write
in interface ILowLevelBulkInsertOperation
java.lang.InterruptedException
public void write(java.lang.String id, RavenJObject metadata, RavenJObject data, java.lang.Integer dataSize) throws java.lang.InterruptedException
write
in interface ILowLevelBulkInsertOperation
java.lang.InterruptedException
public void close() throws java.lang.InterruptedException
close
in interface java.lang.AutoCloseable
java.lang.InterruptedException
public void onNext(BulkInsertChangeNotification value)
onNext
in interface IObserver<BulkInsertChangeNotification>
public void onError(java.lang.Exception error)
onError
in interface IObserver<BulkInsertChangeNotification>
public void onCompleted()
onCompleted
in interface IObserver<BulkInsertChangeNotification>
public void abort()
abort
in interface ILowLevelBulkInsertOperation
public boolean isAborted()
isAborted
in interface ILowLevelBulkInsertOperation
Copyright © 2014. All Rights Reserved.