Package org.apache.tika

Class TikaGrpc.TikaBlockingV2Stub

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

  • Method Details

    • build

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

    • saveFetcher

      public SaveFetcherReply saveFetcher(SaveFetcherRequest request) throws io.grpc.StatusException
       
Save a fetcher to the fetcher store.
      Throws:
      io.grpc.StatusException

    • getFetcher

      public GetFetcherReply getFetcher(GetFetcherRequest request) throws io.grpc.StatusException
       
Get a fetcher's data from the fetcher store.
      Throws:
      io.grpc.StatusException

    • listFetchers

      public ListFetchersReply listFetchers(ListFetchersRequest request) throws io.grpc.StatusException
       
List fetchers that are currently in the fetcher store.
      Throws:
      io.grpc.StatusException

    • deleteFetcher

      public DeleteFetcherReply deleteFetcher(DeleteFetcherRequest request) throws io.grpc.StatusException
       
Delete a fetcher from the fetcher store.
      Throws:
      io.grpc.StatusException

    • fetchAndParse

      public FetchAndParseReply fetchAndParse(FetchAndParseRequest request) throws io.grpc.StatusException
       
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.
      Throws:
      io.grpc.StatusException

    • fetchAndParseServerSideStreaming

      @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918") public io.grpc.stub.BlockingClientCall<?,FetchAndParseReply> fetchAndParseServerSideStreaming(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 will stream the data from the server in response.

    • fetchAndParseBiDirectionalStreaming

      @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918") public io.grpc.stub.BlockingClientCall<FetchAndParseRequest,FetchAndParseReply> fetchAndParseBiDirectionalStreaming()
      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 GetFetcherConfigJsonSchemaReply getFetcherConfigJsonSchema(GetFetcherConfigJsonSchemaRequest request) throws io.grpc.StatusException
      Get the Fetcher Config schema for a given fetcher class.
      Throws:
      io.grpc.StatusException

    • savePipesIterator

      public SavePipesIteratorReply savePipesIterator(SavePipesIteratorRequest request) throws io.grpc.StatusException
       
Save a pipes iterator to the iterator store.
      Throws:
      io.grpc.StatusException

    • getPipesIterator

      public GetPipesIteratorReply getPipesIterator(GetPipesIteratorRequest request) throws io.grpc.StatusException
       
Get a pipes iterator's data from the iterator store.
      Throws:
      io.grpc.StatusException

    • deletePipesIterator

      public DeletePipesIteratorReply deletePipesIterator(DeletePipesIteratorRequest request) throws io.grpc.StatusException
       
Delete a pipes iterator from the iterator store.
      Throws:
      io.grpc.StatusException