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