Modifier and Type | Method and Description |
---|---|
BulkHandler |
BulkHandler.add(org.elasticsearch.action.ActionRequest request,
InteractiveChannel channel) |
BulkHandler |
BulkHandler.add(org.elasticsearch.action.delete.DeleteRequest request,
InteractiveChannel channel)
Adds an
DeleteRequest to the list of actions to execute. |
BulkHandler |
BulkHandler.add(org.elasticsearch.action.index.IndexRequest request,
InteractiveChannel channel)
Adds an
IndexRequest to the list of actions to execute. |
void |
BulkHandler.flush(InteractiveChannel channel)
Flushes open bulk actions
|
void |
BulkIndexAction.handleRequest(InteractiveRequest request,
InteractiveChannel channel) |
void |
BulkHandler.handleRequest(InteractiveRequest request,
InteractiveChannel channel) |
void |
BulkFlushAction.handleRequest(InteractiveRequest request,
InteractiveChannel channel) |
void |
BulkDeleteAction.handleRequest(InteractiveRequest request,
InteractiveChannel channel) |
Modifier and Type | Method and Description |
---|---|
void |
Checkpointer.deleteBulk(org.elasticsearch.action.delete.DeleteRequest request,
InteractiveChannel channel)
Perform bulk delete
|
void |
Checkpointer.flushBulk(InteractiveChannel channel)
Flush bulk
|
void |
UnsubscribeAction.handleRequest(InteractiveRequest request,
InteractiveChannel channel) |
void |
SubscribeAction.handleRequest(InteractiveRequest request,
InteractiveChannel channel) |
void |
PublishAction.handleRequest(InteractiveRequest request,
InteractiveChannel channel) |
void |
ForwardAction.handleRequest(InteractiveRequest request,
InteractiveChannel channel) |
void |
Checkpointer.indexBulk(org.elasticsearch.action.index.IndexRequest request,
InteractiveChannel channel)
Perform bulk indexing
|
Modifier and Type | Class and Description |
---|---|
class |
NettyInteractiveChannel
Netty implementation for an interactive channel
|
Modifier and Type | Method and Description |
---|---|
void |
InteractiveHandler.handleRequest(InteractiveRequest request,
InteractiveChannel channel) |
Copyright © 2012–2014. All rights reserved.