public class BulkInsertOperation extends Object implements CleanCloseable
Modifier and Type | Class and Description |
---|---|
static interface |
BulkInsertOperation.BeforeEntityInsert |
Modifier and Type | Field and Description |
---|---|
protected ILowLevelBulkInsertOperation |
operation |
Constructor and Description |
---|
BulkInsertOperation(String database,
IDocumentStore documentStore,
DocumentSessionListeners listeners,
BulkInsertOptions options,
IDatabaseChanges changes) |
Modifier and Type | Method and Description |
---|---|
void |
abort() |
void |
addOnBeforeEntityInsert(BulkInsertOperation.BeforeEntityInsert action) |
void |
close() |
protected ILowLevelBulkInsertOperation |
getBulkInsertOperation(BulkInsertOptions options,
IDatabaseCommands commands,
IDatabaseChanges changes) |
IDatabaseCommands |
getDatabaseCommands() |
String |
getId(Object entity) |
UUID |
getOperationId() |
Action1<String> |
getReport() |
boolean |
isAborted() |
void |
removeOnBeforeEntityInsert(BulkInsertOperation.BeforeEntityInsert action) |
void |
setReport(Action1<String> report) |
String |
store(Object entity) |
void |
store(Object entity,
String id) |
void |
store(RavenJObject document,
RavenJObject metadata,
String id) |
void |
store(RavenJObject document,
RavenJObject metadata,
String id,
Integer dataSize) |
protected ILowLevelBulkInsertOperation operation
public BulkInsertOperation(String database, IDocumentStore documentStore, DocumentSessionListeners listeners, BulkInsertOptions options, IDatabaseChanges changes)
public boolean isAborted()
public void abort()
public void addOnBeforeEntityInsert(BulkInsertOperation.BeforeEntityInsert action)
public void removeOnBeforeEntityInsert(BulkInsertOperation.BeforeEntityInsert action)
public IDatabaseCommands getDatabaseCommands()
public UUID getOperationId()
protected ILowLevelBulkInsertOperation getBulkInsertOperation(BulkInsertOptions options, IDatabaseCommands commands, IDatabaseChanges changes)
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in interface CleanCloseable
public String store(Object entity) throws InterruptedException
InterruptedException
public void store(Object entity, String id) throws InterruptedException
InterruptedException
public void store(RavenJObject document, RavenJObject metadata, String id) throws InterruptedException
InterruptedException
public void store(RavenJObject document, RavenJObject metadata, String id, Integer dataSize) throws InterruptedException
InterruptedException
Copyright © 2016. All Rights Reserved.