Uses of Class
org.apache.tika.pipes.FetchEmitTuple
-
-
Uses of FetchEmitTuple in org.apache.tika.metadata.serialization
Methods in org.apache.tika.metadata.serialization that return FetchEmitTuple Modifier and Type Method Description static FetchEmitTuple
JsonFetchEmitTuple. fromJson(Reader reader)
Methods in org.apache.tika.metadata.serialization that return types with arguments of type FetchEmitTuple Modifier and Type Method Description static List<FetchEmitTuple>
JsonFetchEmitTupleList. fromJson(Reader reader)
Methods in org.apache.tika.metadata.serialization with parameters of type FetchEmitTuple Modifier and Type Method Description static String
JsonFetchEmitTuple. toJson(FetchEmitTuple t)
static void
JsonFetchEmitTuple. toJson(FetchEmitTuple t, Writer writer)
Method parameters in org.apache.tika.metadata.serialization with type arguments of type FetchEmitTuple Modifier and Type Method Description static String
JsonFetchEmitTupleList. toJson(List<FetchEmitTuple> list)
static void
JsonFetchEmitTupleList. toJson(List<FetchEmitTuple> list, Writer writer)
-
Uses of FetchEmitTuple in org.apache.tika.pipes
Methods in org.apache.tika.pipes with parameters of type FetchEmitTuple Modifier and Type Method Description PipesResult
PipesParser. parse(FetchEmitTuple t)
protected List<Metadata>
PipesServer. parseIt(FetchEmitTuple t, Fetcher fetcher)
PipesResult
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
Methods in org.apache.tika.pipes.async with parameters of type FetchEmitTuple Modifier and Type Method Description boolean
AsyncProcessor. offer(FetchEmitTuple t, long offerMs)
Method parameters in org.apache.tika.pipes.async with type arguments of type FetchEmitTuple Modifier and Type Method Description boolean
AsyncProcessor. offer(List<FetchEmitTuple> newFetchEmitTuples, long offerMs)
-
Uses of FetchEmitTuple in org.apache.tika.pipes.pipesiterator
Fields in org.apache.tika.pipes.pipesiterator declared as FetchEmitTuple Modifier and Type Field Description static FetchEmitTuple
PipesIterator. COMPLETED_SEMAPHORE
Methods in org.apache.tika.pipes.pipesiterator that return types with arguments of type FetchEmitTuple Modifier and Type Method Description Iterator<FetchEmitTuple>
PipesIterator. iterator()
Methods in org.apache.tika.pipes.pipesiterator with parameters of type FetchEmitTuple Modifier and Type Method Description protected void
PipesIterator. tryToAdd(FetchEmitTuple p)
Constructor parameters in org.apache.tika.pipes.pipesiterator with type arguments of type FetchEmitTuple Constructor Description CallablePipesIterator(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
Methods in org.apache.tika.pipes.reporters.fs with parameters of type FetchEmitTuple Modifier and Type Method Description void
FileSystemStatusReporter. report(FetchEmitTuple t, PipesResult result, long elapsed)
-
Uses of FetchEmitTuple in org.apache.tika.pipes.reporters.jdbc
Methods in org.apache.tika.pipes.reporters.jdbc with parameters of type FetchEmitTuple Modifier and Type Method Description void
JDBCPipesReporter. report(FetchEmitTuple t, PipesResult result, long elapsed)
-
Uses of FetchEmitTuple in org.apache.tika.pipes.reporters.opensearch
Methods in org.apache.tika.pipes.reporters.opensearch with parameters of type FetchEmitTuple Modifier and Type Method Description void
OpenSearchPipesReporter. report(FetchEmitTuple t, PipesResult result, long elapsed)
-
Uses of FetchEmitTuple in org.apache.tika.server.client
Methods in org.apache.tika.server.client with parameters of type FetchEmitTuple Modifier and Type Method Description TikaEmitterResult
TikaClient. parse(FetchEmitTuple fetchEmit)
-
Uses of FetchEmitTuple in org.apache.tika.server.core.resource
Methods in org.apache.tika.server.core.resource that return types with arguments of type FetchEmitTuple Modifier and Type Method Description ArrayBlockingQueue<FetchEmitTuple>
AsyncResource. getFetchEmitQueue(int queueSize)
List<FetchEmitTuple>
AsyncRequest. getTuples()
Constructor parameters in org.apache.tika.server.core.resource with type arguments of type FetchEmitTuple Constructor Description AsyncRequest(List<FetchEmitTuple> tuples)
-