| 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 |
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.