Modifier and Type | Method and Description |
---|---|
static void |
JsonEmitData.toJson(EmitData emitData,
Writer writer) |
Modifier and Type | Method and Description |
---|---|
EmitData |
PipesResult.getEmitData() |
Constructor and Description |
---|
PipesResult(EmitData emitData)
This assumes parse success with no parse exception
|
PipesResult(EmitData emitData,
String message)
This assumes that the message is a stack trace (container
parse exception).
|
Constructor and Description |
---|
AsyncEmitter(AsyncConfig asyncConfig,
ArrayBlockingQueue<EmitData> emitData,
EmitterManager emitterManager) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractEmitter.emit(List<? extends EmitData> emitData)
The default behavior is to call
Emitter.emit(String, List) on each item. |
void |
Emitter.emit(List<? extends EmitData> emitData) |
void |
EmptyEmitter.emit(List<? extends EmitData> emitData) |
Modifier and Type | Method and Description |
---|---|
void |
OpenSearchEmitter.emit(List<? extends EmitData> emitData) |
void |
OpenSearchClient.emitDocuments(List<? extends EmitData> emitData) |
Modifier and Type | Method and Description |
---|---|
void |
SolrEmitter.emit(List<? extends EmitData> batch) |
Modifier and Type | Method and Description |
---|---|
ArrayBlockingQueue<EmitData> |
AsyncResource.getEmitDataQueue(int size) |
Copyright © 2007–2022 The Apache Software Foundation. All rights reserved.