Uses of Class
org.apache.tika.pipes.FetchEmitTuple
Package
Description
-
Uses of FetchEmitTuple in org.apache.tika.pipes
Modifier and TypeMethodDescriptionPipesParser.parse
(FetchEmitTuple t) protected org.apache.tika.pipes.PipesServer.MetadataListAndEmbeddedBytes
PipesServer.parseFromTuple
(FetchEmitTuple t, Fetcher fetcher) PipesClient.process
(FetchEmitTuple t) void
CompositePipesReporter.report
(FetchEmitTuple t, PipesResult result, long elapsed) void
LoggingPipesReporter.report
(FetchEmitTuple t, PipesResult result, long elapsed) abstract void
PipesReporter.report
(FetchEmitTuple t, PipesResult result, long elapsed) -
Uses of FetchEmitTuple in org.apache.tika.pipes.async
Modifier and TypeMethodDescriptionboolean
AsyncProcessor.offer
(List<FetchEmitTuple> newFetchEmitTuples, long offerMs) -
Uses of FetchEmitTuple in org.apache.tika.pipes.extractor
ModifierConstructorDescriptionEmittingEmbeddedDocumentBytesHandler
(FetchEmitTuple fetchEmitTuple, EmitterManager emitterManager) -
Uses of FetchEmitTuple in org.apache.tika.pipes.pipesiterator
ModifierConstructorDescriptionCallablePipesIterator
(PipesIterator pipesIterator, ArrayBlockingQueue<FetchEmitTuple> queue) This sets timeoutMillis to -1, meaning that this will block forever trying to add fetchemittuples to the queue.CallablePipesIterator
(PipesIterator pipesIterator, ArrayBlockingQueue<FetchEmitTuple> queue, long timeoutMillis) This sets the number ofPipesIterator.COMPLETED_SEMAPHORE
to 1.CallablePipesIterator
(PipesIterator pipesIterator, ArrayBlockingQueue<FetchEmitTuple> queue, long timeoutMillis, int numConsumers) -
Uses of FetchEmitTuple in org.apache.tika.pipes.reporters.fs
Modifier and TypeMethodDescriptionvoid
FileSystemStatusReporter.report
(FetchEmitTuple t, PipesResult result, long elapsed) -
Uses of FetchEmitTuple in org.apache.tika.pipes.reporters.jdbc
Modifier and TypeMethodDescriptionvoid
JDBCPipesReporter.report
(FetchEmitTuple t, PipesResult result, long elapsed) -
Uses of FetchEmitTuple in org.apache.tika.pipes.reporters.opensearch
Modifier and TypeMethodDescriptionvoid
OpenSearchPipesReporter.report
(FetchEmitTuple t, PipesResult result, long elapsed) -
Uses of FetchEmitTuple in org.apache.tika.serialization.pipes
Modifier and TypeMethodDescriptionstatic String
JsonFetchEmitTuple.toJson
(FetchEmitTuple t) static void
JsonFetchEmitTuple.toJson
(FetchEmitTuple t, Writer writer) Modifier and TypeMethodDescriptionstatic String
JsonFetchEmitTupleList.toJson
(List<FetchEmitTuple> list) static void
JsonFetchEmitTupleList.toJson
(List<FetchEmitTuple> list, Writer writer) -
Uses of FetchEmitTuple in org.apache.tika.server.client
-
Uses of FetchEmitTuple in org.apache.tika.server.core.resource
Modifier and TypeMethodDescriptionAsyncResource.getFetchEmitQueue
(int queueSize) AsyncRequest.getTuples()