com.google.cloud.datastore

Class BaseDatastoreBatchWriter

java.lang.Object

com.google.cloud.datastore.BaseDatastoreBatchWriter

public abstract class BaseDatastoreBatchWriter
extends Object

Base class for DatastoreBatchWriter.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BaseDatastoreBatchWriter(String name)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	active() Returns true if still active (write operations were not sent to the Datastore).
List<Entity>	add(FullEntity<?>... entities) Datastore add operation.
Entity	add(FullEntity<?> entity) Datastore add operation.
void	addWithDeferredIdAllocation(FullEntity<?>... entities) Datastore add operation.
protected abstract Datastore	datastore()
protected void	deactivate()
void	delete(Key... keys) A datastore delete operation.
protected String	name()
protected DatastoreException	newInvalidRequest(String msg, Object... params)
void	put(Entity... entities) A Datastore put (a.k.a upsert) operation.
protected Map<Key,FullEntity<Key>>	toAdd()
protected List<FullEntity<IncompleteKey>>	toAddAutoId()
protected Set<Key>	toDelete()
protected List<com.google.datastore.v1beta3.Mutation>	toMutationPbList()
protected Map<Key,FullEntity<Key>>	toPut()
protected Map<Key,FullEntity<Key>>	toUpdate()
void	update(Entity... entities) A Datastore update operation.
protected void	validateActive()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BaseDatastoreBatchWriter

protected BaseDatastoreBatchWriter(String name)

Method Detail

addWithDeferredIdAllocation

public final void addWithDeferredIdAllocation(FullEntity<?>... entities)

Datastore add operation. This method will also allocate id for any entity with an incomplete key. As oppose to DatastoreWriter.add(FullEntity), this method will defer any necessary id allocation to submit time.

add

public final Entity add(FullEntity<?> entity)

Description copied from interface: DatastoreWriter

Datastore add operation. This method will automatically allocate an id if necessary.

Parameters:

entity - the entity to add

Returns:

an Entity with the same properties and a key that is either newly allocated or the same one if key is already complete

add

public final List<Entity> add(FullEntity<?>... entities)

Datastore add operation. This method will automatically allocate id for any entity with an incomplete key. For entities with complete keys that were marked for deletion in this writer the operation will be changed to put(com.google.cloud.datastore.Entity...).

Returns:

a list of Entity ordered by input with the same properties and a key that is either newly allocated or the same one if was already complete

See Also:

DatastoreWriter.add(FullEntity)

update

@SafeVarargs
public final void update(Entity... entities)

A Datastore update operation. The operation will fail if an entity with the same key does not already exist. This operation will be converted to put(com.google.cloud.datastore.Entity...) operation for entities that were already added or put in this writer

put

@SafeVarargs
public final void put(Entity... entities)

A Datastore put (a.k.a upsert) operation. The operation will add or modify the entities. This operation will also remove from this writer any prior writes for the same entities.

delete

public final void delete(Key... keys)

A datastore delete operation. It is OK request a deletion of a non-existing entity. This operation will also remove from this batch any prior writes for entities with the same keys

active

public boolean active()

Returns true if still active (write operations were not sent to the Datastore).

name

protected String name()

toAdd

protected Map<Key,FullEntity<Key>> toAdd()

toAddAutoId

protected List<FullEntity<IncompleteKey>> toAddAutoId()

toUpdate

protected Map<Key,FullEntity<Key>> toUpdate()

toPut

protected Map<Key,FullEntity<Key>> toPut()

toDelete

protected Set<Key> toDelete()

deactivate

protected void deactivate()

validateActive

protected void validateActive()

newInvalidRequest

protected DatastoreException newInvalidRequest(String msg,
                                   Object... params)

toMutationPbList

protected List<com.google.datastore.v1beta3.Mutation> toMutationPbList()

datastore

protected abstract Datastore datastore()