the Operation object describing the current state of the long-running operation
Throws
IOException
when service throws exception
public
abstract
Schema
getSchema()
Gets the Schema defined within the connected data source.
Each data source may have at most one schema defined within it. This method extracts the
schema definition to use with the current connector's data repository.
public
abstract
ListenableFuture<Operation>
unreserve(String queue)
Unreserves previously polled Item entries in a specific queue.
When a connector issues a poll(PollItemsRequest) of the indexing queue, the
returned Item entries are marked internally as reserved so that they are
unavailable for a future poll(PollItemsRequest) request. This prevents two possibly
different threads from processing the same Item. This method allows the connector to
reset the queue to make all of its entries available again.
Parameters
queue
the queue to unreserve, (null for default queue)
Returns
ListenableFuture that the caller uses to obtain the result of an unreserve
operation (using get())
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Missing the information I need","missingTheInformationINeed","thumb-down"],["Too complicated / too many steps","tooComplicatedTooManySteps","thumb-down"],["Out of date","outOfDate","thumb-down"],["Samples / code issue","samplesCodeIssue","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2024-09-03 UTC."],[[["`IndexingService` provides an access point for connector developers to interact with the indexing service API backend for Google Cloud Search."],["It offers methods to manage items, including indexing, deleting, getting, and listing them, along with functionalities for schema retrieval and queue operations."],["The service utilizes `ListenableFuture` for asynchronous operations like deleting, indexing, and unreserving items, allowing developers to track and manage their progress."],["`RequestMode` and `ContentFormat` enums further refine indexing and deletion requests, providing granular control over how items and their content are handled."],["Developers can leverage methods like `poll` and `pollAll` to retrieve items from the indexing queue for processing, ensuring efficient data synchronization."]]],[]]