public class AsyncProcessor extends Object implements Closeable
Constructor and Description |
---|
AsyncProcessor(Path tikaConfigPath) |
Modifier and Type | Method and Description |
---|---|
boolean |
checkActive() |
void |
close() |
void |
finished() |
int |
getCapacity() |
long |
getTotalProcessed() |
boolean |
offer(FetchEmitTuple t,
long offerMs) |
boolean |
offer(List<FetchEmitTuple> newFetchEmitTuples,
long offerMs) |
public AsyncProcessor(Path tikaConfigPath) throws TikaException, IOException
TikaException
IOException
public boolean offer(List<FetchEmitTuple> newFetchEmitTuples, long offerMs) throws PipesException, InterruptedException
PipesException
InterruptedException
public int getCapacity()
public boolean offer(FetchEmitTuple t, long offerMs) throws PipesException, InterruptedException
PipesException
InterruptedException
public void finished() throws InterruptedException
InterruptedException
public boolean checkActive() throws InterruptedException
InterruptedException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public long getTotalProcessed()
Copyright © 2007–2022 The Apache Software Foundation. All rights reserved.