| Constructor and Description | 
|---|
| AsyncProcessor(Path tikaConfigPath,
              PipesIterator pipesIterator) | 
| Modifier and Type | Method and Description | 
|---|---|
| static PipesIterator | PipesIterator. build(Path tikaConfigFile) | 
| Constructor and 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 of  COMPLETED_SEMAPHOREto 1. | 
| CallablePipesIterator(PipesIterator pipesIterator,
                     ArrayBlockingQueue<FetchEmitTuple> queue,
                     long timeoutMillis,
                     int numConsumers) | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | AZBlobPipesIterator | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | CSVPipesIteratorIterates through a UTF-8 CSV file. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | FileListPipesIteratorReads a list of file names/relative paths from a UTF-8 file. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | FileSystemPipesIterator | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | GCSPipesIterator | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | JDBCPipesIteratorIterates through a the results from a sql call via jdbc. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | KafkaPipesIterator | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | S3PipesIterator | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | SolrPipesIteratorIterates through results from a Solr query. | 
Copyright © 2007–2022 The Apache Software Foundation. All rights reserved.