Modifier and Type | Method and Description |
---|---|
static FetchEmitTuple |
JsonFetchEmitTuple.fromJson(Reader reader) |
Modifier and Type | Method and Description |
---|---|
static List<FetchEmitTuple> |
JsonFetchEmitTupleList.fromJson(Reader reader) |
Modifier and Type | Method and Description |
---|---|
static String |
JsonFetchEmitTuple.toJson(FetchEmitTuple t) |
static void |
JsonFetchEmitTuple.toJson(FetchEmitTuple t,
Writer writer) |
Modifier and Type | Method and Description |
---|---|
static String |
JsonFetchEmitTupleList.toJson(List<FetchEmitTuple> list) |
static void |
JsonFetchEmitTupleList.toJson(List<FetchEmitTuple> list,
Writer writer) |
Modifier and Type | Method and Description |
---|---|
PipesResult |
PipesParser.parse(FetchEmitTuple t) |
PipesResult |
PipesClient.process(FetchEmitTuple t) |
void |
CompositePipesReporter.report(FetchEmitTuple t,
PipesResult result,
long elapsed) |
abstract void |
PipesReporter.report(FetchEmitTuple t,
PipesResult result,
long elapsed) |
Modifier and Type | Method and Description |
---|---|
boolean |
AsyncProcessor.offer(FetchEmitTuple t,
long offerMs) |
Modifier and Type | Method and Description |
---|---|
boolean |
AsyncProcessor.offer(List<FetchEmitTuple> newFetchEmitTuples,
long offerMs) |
Modifier and Type | Field and Description |
---|---|
static FetchEmitTuple |
PipesIterator.COMPLETED_SEMAPHORE |
Modifier and Type | Method and Description |
---|---|
Iterator<FetchEmitTuple> |
PipesIterator.iterator() |
Modifier and Type | Method and Description |
---|---|
protected void |
PipesIterator.tryToAdd(FetchEmitTuple p) |
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
PipesIterator.COMPLETED_SEMAPHORE to 1. |
CallablePipesIterator(PipesIterator pipesIterator,
ArrayBlockingQueue<FetchEmitTuple> queue,
long timeoutMillis,
int numConsumers) |
Modifier and Type | Method and Description |
---|---|
void |
FileSystemStatusReporter.report(FetchEmitTuple t,
PipesResult result,
long elapsed) |
Modifier and Type | Method and Description |
---|---|
void |
OpenSearchPipesReporter.report(FetchEmitTuple t,
PipesResult result,
long elapsed) |
Modifier and Type | Method and Description |
---|---|
TikaEmitterResult |
TikaClient.parse(FetchEmitTuple fetchEmit) |
Modifier and Type | Method and Description |
---|---|
ArrayBlockingQueue<FetchEmitTuple> |
AsyncResource.getFetchEmitQueue(int queueSize) |
List<FetchEmitTuple> |
AsyncRequest.getTuples() |
Constructor and Description |
---|
AsyncRequest(List<FetchEmitTuple> tuples) |
Copyright © 2007–2022 The Apache Software Foundation. All rights reserved.