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) |
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) |
Modifier and Type | Method and Description |
---|---|
TikaEmitterResult |
TikaClient.parse(FetchEmitTuple fetchEmit) |
Modifier and Type | Method and Description |
---|---|
TikaEmitterResult |
TikaClient.parseAsync(List<FetchEmitTuple> tuples) |
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–2021 The Apache Software Foundation. All rights reserved.