public class MappingUpdatedAction extends TransportMasterNodeOperationAction<MappingUpdatedAction.MappingUpdatedRequest,MappingUpdatedAction.MappingUpdatedResponse>
Modifier and Type | Class and Description |
---|---|
static class |
MappingUpdatedAction.MappingUpdatedRequest |
static class |
MappingUpdatedAction.MappingUpdatedResponse |
static interface |
MappingUpdatedAction.MappingUpdateListener
A listener to be notified when the mappings were updated
|
Modifier and Type | Field and Description |
---|---|
static String |
ACTION_NAME |
static String |
INDICES_MAPPING_ADDITIONAL_MAPPING_CHANGE_TIME |
clusterService, transportService
actionName, threadPool
componentSettings, logger, settings
Constructor and Description |
---|
MappingUpdatedAction(Settings settings,
TransportService transportService,
ClusterService clusterService,
ThreadPool threadPool,
MetaDataMappingService metaDataMappingService,
NodeSettingsService nodeSettingsService,
ActionFilters actionFilters) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
checkBlock(MappingUpdatedAction.MappingUpdatedRequest request,
ClusterState state) |
protected String |
executor() |
protected void |
masterOperation(MappingUpdatedAction.MappingUpdatedRequest request,
ClusterState state,
ActionListener<MappingUpdatedAction.MappingUpdatedResponse> listener) |
protected MappingUpdatedAction.MappingUpdatedRequest |
newRequest() |
protected MappingUpdatedAction.MappingUpdatedResponse |
newResponse() |
void |
start() |
void |
stop() |
void |
updateMappingOnMaster(String index,
DocumentMapper documentMapper,
String indexUUID) |
void |
updateMappingOnMaster(String index,
DocumentMapper documentMapper,
String indexUUID,
MappingUpdatedAction.MappingUpdateListener listener) |
doExecute, forceThreadedListener, localExecute, processBeforeDelegationToMaster
execute, execute
nodeName
public static final String INDICES_MAPPING_ADDITIONAL_MAPPING_CHANGE_TIME
public static final String ACTION_NAME
@Inject public MappingUpdatedAction(Settings settings, TransportService transportService, ClusterService clusterService, ThreadPool threadPool, MetaDataMappingService metaDataMappingService, NodeSettingsService nodeSettingsService, ActionFilters actionFilters)
public void start()
public void stop()
public void updateMappingOnMaster(String index, DocumentMapper documentMapper, String indexUUID)
public void updateMappingOnMaster(String index, DocumentMapper documentMapper, String indexUUID, MappingUpdatedAction.MappingUpdateListener listener)
protected ClusterBlockException checkBlock(MappingUpdatedAction.MappingUpdatedRequest request, ClusterState state)
protected String executor()
protected MappingUpdatedAction.MappingUpdatedRequest newRequest()
protected MappingUpdatedAction.MappingUpdatedResponse newResponse()
protected void masterOperation(MappingUpdatedAction.MappingUpdatedRequest request, ClusterState state, ActionListener<MappingUpdatedAction.MappingUpdatedResponse> listener) throws ElasticsearchException
Copyright © 2009–2015. All rights reserved.