public class RemoteBulkInsertOperation extends Object implements ILowLevelBulkInsertOperation, IObserver<BulkInsertChangeNotification>
Modifier and Type | Class and Description |
---|---|
class |
RemoteBulkInsertOperation.BulkInsertEntity |
Constructor and Description |
---|
RemoteBulkInsertOperation(BulkInsertOptions options,
ServerClient client,
IDatabaseChanges changes) |
RemoteBulkInsertOperation(BulkInsertOptions options,
ServerClient client,
IDatabaseChanges changes,
UUID existingOperationId) |
Modifier and Type | Method and Description |
---|---|
void |
abort() |
void |
close() |
UUID |
getOperationId() |
Action1<String> |
getReport() |
boolean |
isAborted() |
void |
onCompleted() |
void |
onError(Exception error) |
void |
onNext(BulkInsertChangeNotification value) |
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 RemoteBulkInsertOperation(BulkInsertOptions options, ServerClient client, IDatabaseChanges changes)
public RemoteBulkInsertOperation(BulkInsertOptions options, ServerClient client, IDatabaseChanges changes, UUID existingOperationId)
public UUID getOperationId()
getOperationId
in interface ILowLevelBulkInsertOperation
public Action1<String> getReport()
getReport
in interface ILowLevelBulkInsertOperation
public void setReport(Action1<String> report)
ILowLevelBulkInsertOperation
setReport
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 void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in interface CleanCloseable
public void onNext(BulkInsertChangeNotification value)
onNext
in interface IObserver<BulkInsertChangeNotification>
public void onError(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 © 2016. All Rights Reserved.