Package org.apache.tika

Class TikaGrpc.TikaStub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractAsyncStub<TikaGrpc.TikaStub>
org.apache.tika.TikaGrpc.TikaStub
Enclosing class:
TikaGrpc
public static final class TikaGrpc.TikaStub extends io.grpc.stub.AbstractAsyncStub<TikaGrpc.TikaStub>
A stub to allow clients to do asynchronous rpc calls to service Tika. 
 The Tika Grpc Service definition

  • Method Details

    • build

      protected TikaGrpc.TikaStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<TikaGrpc.TikaStub>

    • saveFetcher

      public void saveFetcher(SaveFetcherRequest request, io.grpc.stub.StreamObserver<SaveFetcherReply> responseObserver)
       
Save a fetcher to the fetcher store.

    • getFetcher

      public void getFetcher(GetFetcherRequest request, io.grpc.stub.StreamObserver<GetFetcherReply> responseObserver)
       
Get a fetcher's data from the fetcher store.

    • listFetchers

      public void listFetchers(ListFetchersRequest request, io.grpc.stub.StreamObserver<ListFetchersReply> responseObserver)
       
List fetchers that are currently in the fetcher store.

    • deleteFetcher

      public void deleteFetcher(DeleteFetcherRequest request, io.grpc.stub.StreamObserver<DeleteFetcherReply> responseObserver)
       
Delete a fetcher from the fetcher store.

    • fetchAndParse

      public void fetchAndParse(FetchAndParseRequest request, io.grpc.stub.StreamObserver<FetchAndParseReply> responseObserver)
       
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.

    • fetchAndParseServerSideStreaming

      public void fetchAndParseServerSideStreaming(FetchAndParseRequest request, io.grpc.stub.StreamObserver<FetchAndParseReply> responseObserver)
      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 will stream the data from the server in response.

    • fetchAndParseBiDirectionalStreaming

      public io.grpc.stub.StreamObserver<FetchAndParseRequest> fetchAndParseBiDirectionalStreaming(io.grpc.stub.StreamObserver<FetchAndParseReply> responseObserver)
      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 serves a bi-directional stream of fetch inputs and
parsed outputs.

    • getFetcherConfigJsonSchema

      public void getFetcherConfigJsonSchema(GetFetcherConfigJsonSchemaRequest request, io.grpc.stub.StreamObserver<GetFetcherConfigJsonSchemaReply> responseObserver)
      Get the Fetcher Config schema for a given fetcher class.

    • savePipesIterator

      public void savePipesIterator(SavePipesIteratorRequest request, io.grpc.stub.StreamObserver<SavePipesIteratorReply> responseObserver)
       
Save a pipes iterator to the iterator store.

    • getPipesIterator

      public void getPipesIterator(GetPipesIteratorRequest request, io.grpc.stub.StreamObserver<GetPipesIteratorReply> responseObserver)
       
Get a pipes iterator's data from the iterator store.

    • deletePipesIterator

      public void deletePipesIterator(DeletePipesIteratorRequest request, io.grpc.stub.StreamObserver<DeletePipesIteratorReply> responseObserver)
       
Delete a pipes iterator from the iterator store.