Class FileSystemPipesIterator
java.lang.Object
org.apache.tika.plugins.AbstractTikaExtension
org.apache.tika.pipes.pipesiterator.PipesIteratorBase
org.apache.tika.pipes.iterator.fs.FileSystemPipesIterator
- All Implemented Interfaces:
Closeable,AutoCloseable,Iterable<FetchEmitTuple>,Callable<Integer>,PipesIterator,TotalCounter,TikaExtension
-
Field Summary
Fields inherited from class org.apache.tika.pipes.pipesiterator.PipesIteratorBase
DEFAULT_MAX_WAIT_MS, DEFAULT_QUEUE_SIZEFields inherited from class org.apache.tika.plugins.AbstractTikaExtension
pluginConfigFields inherited from interface org.apache.tika.pipes.api.pipesiterator.PipesIterator
COMPLETED_SEMAPHORE -
Method Summary
Modifier and TypeMethodDescriptionstatic FileSystemPipesIteratorbuild(ExtensionConfig pluginConfig) voidvoidclose()protected voidenqueue()Returns the total count so far.voidMethods inherited from class org.apache.tika.pipes.pipesiterator.PipesIteratorBase
call, iterator, tryToAddMethods inherited from class org.apache.tika.plugins.AbstractTikaExtension
getExtensionConfigMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface java.lang.Iterable
forEach, spliteratorMethods inherited from interface org.apache.tika.plugins.TikaExtension
getExtensionConfig
-
Method Details
-
build
public static FileSystemPipesIterator build(ExtensionConfig pluginConfig) throws TikaConfigException, IOException - Throws:
TikaConfigExceptionIOException
-
enqueue
- Specified by:
enqueuein classPipesIteratorBase- Throws:
InterruptedExceptionIOExceptionTimeoutException
-
checkConfig
- Throws:
TikaConfigException
-
startTotalCount
public void startTotalCount()- Specified by:
startTotalCountin interfaceTotalCounter
-
getTotalCount
Description copied from interface:TotalCounterReturns the total count so far. Check theTotalCountResult.getStatus()to figure out if the count has completed yet, if it is unsupported or if there was an exception during the counting.- Specified by:
getTotalCountin interfaceTotalCounter- Returns:
-
close
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Throws:
IOException
-