BatchingIndexingServiceImpl

public class BatchingIndexingServiceImpl extends AbstractIdleService
implements BatchingIndexingService

Concrete class implementing BatchingIndexingService.

Nested Class Summary

class

BatchingIndexingServiceImpl.Builder

Builder for creating an instance of BatchingIndexingServiceImpl

Public Method Summary

ListenableFuture<Operation>	deleteItem(CloudSearch.Indexing.Datasources.Items.Delete deleteItem) Adds a delete item request to the batch.
static BatchingIndexingService	fromConfiguration(CloudSearch service, GoogleCredential credential)
ListenableFuture<Operation>	indexItem(CloudSearch.Indexing.Datasources.Items.Index indexItem) Adds an index item request to the batch.
ListenableFuture<Item>	pushItem(CloudSearch.Indexing.Datasources.Items.Push pushItem) Adds a push item request to the batch.
ListenableFuture<Operation>	unreserveItem(CloudSearch.Indexing.Datasources.Items.Unreserve unreserveItem) Adds an unreserve queue request to the batch.

Inherited Method Summary

From class com.google.common.util.concurrent.AbstractIdleService

final void	addListener(Service.Listener arg0, Executor arg1)
final void	awaitRunning()
final void	awaitRunning(long arg0, TimeUnit arg1)
final void	awaitTerminated(long arg0, TimeUnit arg1)
final void	awaitTerminated()
final Throwable	failureCause()
final boolean	isRunning()
final Service	startAsync()
final Service.State	state()
final Service	stopAsync()
String	toString()

From class java.lang.Object

boolean	equals(Object arg0)
final Class<?>	getClass()
int	hashCode()
final void	notify()
final void	notifyAll()
String	toString()
final void	wait(long arg0, int arg1)
final void	wait(long arg0)
final void	wait()

From interface com.google.common.util.concurrent.Service

abstract void	addListener(Service.Listener arg0, Executor arg1)
abstract void	awaitRunning()
abstract void	awaitRunning(long arg0, TimeUnit arg1)
abstract void	awaitTerminated(long arg0, TimeUnit arg1)
abstract void	awaitTerminated()
abstract Throwable	failureCause()
abstract boolean	isRunning()
abstract Service	startAsync()
abstract Service.State	state()
abstract Service	stopAsync()

From interface com.google.enterprise.cloudsearch.sdk.indexing.BatchingIndexingService

abstract ListenableFuture<Operation>	deleteItem(CloudSearch.Indexing.Datasources.Items.Delete deleteItem) Adds a delete item request to the batch.
abstract ListenableFuture<Operation>	indexItem(CloudSearch.Indexing.Datasources.Items.Index indexItem) Adds an index item request to the batch.
abstract ListenableFuture<Item>	pushItem(CloudSearch.Indexing.Datasources.Items.Push pushItem) Adds a push item request to the batch.
abstract ListenableFuture<Operation>	unreserveItem(CloudSearch.Indexing.Datasources.Items.Unreserve unreserveItem) Adds an unreserve queue request to the batch.

Public Methods

public ListenableFuture<Operation> deleteItem (CloudSearch.Indexing.Datasources.Items.Delete deleteItem)

Adds a delete item request to the batch.

Parameters

deleteItem

Throws

InterruptedException

public static BatchingIndexingService fromConfiguration (CloudSearch service, GoogleCredential credential)

Parameters

service
credential

public ListenableFuture<Operation> indexItem (CloudSearch.Indexing.Datasources.Items.Index indexItem)

Adds an index item request to the batch.

Parameters

indexItem

Throws

InterruptedException

public ListenableFuture<Item> pushItem (CloudSearch.Indexing.Datasources.Items.Push pushItem)

Adds a push item request to the batch.

Parameters

pushItem

Throws

InterruptedException

public ListenableFuture<Operation> unreserveItem (CloudSearch.Indexing.Datasources.Items.Unreserve unreserveItem)

Adds an unreserve queue request to the batch.

Parameters

unreserveItem

Throws

InterruptedException