| 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 | 
EmptyEmitter.emit(List<? extends EmitData> emitData)  | 
void | 
Emitter.emit(List<? extends EmitData> emitData)  | 
void | 
AbstractEmitter.emit(List<? extends EmitData> emitData)
The default behavior is to call  
Emitter.emit(String, List) on each item. | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
JDBCEmitter.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–2023 The Apache Software Foundation. All rights reserved.