Package org.apache.tika
Class TikaGrpc.TikaFutureStub
java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractFutureStub<TikaGrpc.TikaFutureStub>
org.apache.tika.TikaGrpc.TikaFutureStub
- Enclosing class:
- TikaGrpc
public static final class TikaGrpc.TikaFutureStub
extends io.grpc.stub.AbstractFutureStub<TikaGrpc.TikaFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service Tika.
The Tika Grpc Service definition
-
Nested Class Summary
Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub
io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>> -
Method Summary
Modifier and TypeMethodDescriptionprotected TikaGrpc.TikaFutureStubbuild(io.grpc.Channel channel, io.grpc.CallOptions callOptions) com.google.common.util.concurrent.ListenableFuture<DeleteFetcherReply>deleteFetcher(DeleteFetcherRequest request) Delete a fetcher from the fetcher store.com.google.common.util.concurrent.ListenableFuture<DeletePipesIteratorReply>Delete a pipes iterator from the iterator store.com.google.common.util.concurrent.ListenableFuture<FetchAndParseReply>fetchAndParse(FetchAndParseRequest request) Using a Fetcher in the fetcher store, send a FetchAndParse request.com.google.common.util.concurrent.ListenableFuture<GetFetcherReply>getFetcher(GetFetcherRequest request) Get a fetcher's data from the fetcher store.com.google.common.util.concurrent.ListenableFuture<GetFetcherConfigJsonSchemaReply>Get the Fetcher Config schema for a given fetcher class.com.google.common.util.concurrent.ListenableFuture<GetPipesIteratorReply>getPipesIterator(GetPipesIteratorRequest request) Get a pipes iterator's data from the iterator store.com.google.common.util.concurrent.ListenableFuture<ListFetchersReply>listFetchers(ListFetchersRequest request) List fetchers that are currently in the fetcher store.com.google.common.util.concurrent.ListenableFuture<SaveFetcherReply>saveFetcher(SaveFetcherRequest request) Save a fetcher to the fetcher store.com.google.common.util.concurrent.ListenableFuture<SavePipesIteratorReply>Save a pipes iterator to the iterator store.Methods inherited from class io.grpc.stub.AbstractFutureStub
newStub, newStubMethods inherited from class io.grpc.stub.AbstractStub
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady
-
Method Details
-
build
- Specified by:
buildin classio.grpc.stub.AbstractStub<TikaGrpc.TikaFutureStub>
-
saveFetcher
public com.google.common.util.concurrent.ListenableFuture<SaveFetcherReply> saveFetcher(SaveFetcherRequest request) Save a fetcher to the fetcher store.
-
getFetcher
public com.google.common.util.concurrent.ListenableFuture<GetFetcherReply> getFetcher(GetFetcherRequest request) Get a fetcher's data from the fetcher store.
-
listFetchers
public com.google.common.util.concurrent.ListenableFuture<ListFetchersReply> listFetchers(ListFetchersRequest request) List fetchers that are currently in the fetcher store.
-
deleteFetcher
public com.google.common.util.concurrent.ListenableFuture<DeleteFetcherReply> deleteFetcher(DeleteFetcherRequest request) Delete a fetcher from the fetcher store.
-
fetchAndParse
public com.google.common.util.concurrent.ListenableFuture<FetchAndParseReply> fetchAndParse(FetchAndParseRequest request) Using a Fetcher in the fetcher store, send a FetchAndParse request. This will fetch, parse, and return the FetchParseTuple data output from Tika Pipes. This is a synchronous call that immediately returns 1 result.
-
getFetcherConfigJsonSchema
public com.google.common.util.concurrent.ListenableFuture<GetFetcherConfigJsonSchemaReply> getFetcherConfigJsonSchema(GetFetcherConfigJsonSchemaRequest request) Get the Fetcher Config schema for a given fetcher class.
-
savePipesIterator
public com.google.common.util.concurrent.ListenableFuture<SavePipesIteratorReply> savePipesIterator(SavePipesIteratorRequest request) Save a pipes iterator to the iterator store.
-
getPipesIterator
public com.google.common.util.concurrent.ListenableFuture<GetPipesIteratorReply> getPipesIterator(GetPipesIteratorRequest request) Get a pipes iterator's data from the iterator store.
-
deletePipesIterator
public com.google.common.util.concurrent.ListenableFuture<DeletePipesIteratorReply> deletePipesIterator(DeletePipesIteratorRequest request) Delete a pipes iterator from the iterator store.
-