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_SEMAPHORE to 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 |
CSVPipesIterator
Iterates through a UTF-8 CSV file.
|
Modifier and Type | Class and Description |
---|---|
class |
FileListPipesIterator
Reads 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 |
JDBCPipesIterator
Iterates 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 |
SolrPipesIterator
Iterates through results from a Solr query.
|
Copyright © 2007–2022 The Apache Software Foundation. All rights reserved.