Modifier and Type | Interface and Description |
---|---|
static class |
Context.Signal |
Modifier and Type | Field and Description |
---|---|
static String |
ANNOTATED_QUERY |
static String |
ASYNC |
static String |
AUTHZ_CONTEXT |
static String |
COLLECTION_PROPERTY |
static String |
DEBUG |
static String |
Echo |
static String |
EchoMaxCount |
static String |
EndOfBatchSignal |
static String |
EVENT_TYPES |
static String |
EVENTS_COLLECTION |
static String |
EVENTS_PIPELINE |
static String |
EXCLUDE_EXTENSIONS |
static String |
EXPERIMENT_COLLECTION_FOR_SIGNALS |
static String |
EXPERIMENT_ID |
static String |
EXPERIMENT_VARIANT |
static String |
HTTP_METHOD |
static String |
INNER_PIPELINE |
static String |
JobId |
static String |
PipelineId |
static String |
PipeLineInstanceId |
static String |
REQUEST_CONTENT_TYPE |
static String |
REQUEST_HANDLER |
static String |
REQUEST_PARAMS |
static String |
RESPONSE_TRANSFORMER |
static String |
Signal |
static String |
Simulate |
static String |
SIMULATE |
static String |
SolrCommitSignal |
static String |
SolrDeleteByIdSignal |
static String |
SolrDeleteByQuerySignal |
static String |
STAGE_INDEX |
static String |
Stats |
static String |
ThrowOnError |
Modifier and Type | Method and Description |
---|---|
void |
clearSignal() |
Context |
copyOf() |
Map<String,Object> |
flatten() |
Optional<Context> |
getParentContext()
Return this context's immediate parent
|
Optional<Context.Signal> |
getSignal() |
<M> StageCallback<M> |
getStageCallback() |
boolean |
isSignal() |
boolean |
isSignal(String signal) |
Context |
newChildContext() |
Context |
newChildContext(StageCallback<?> callback) |
Context |
set(String key,
Object value) |
Context |
setShared(String key,
Object value) |
void |
setSignal(String signal,
String value) |
void |
setStageCallback(StageCallback<?> stageCallback) |
clear, compute, computeIfAbsent, computeIfPresent, containsKey, containsValue, entrySet, equals, forEach, get, getOrDefault, hashCode, isEmpty, keySet, merge, put, putAll, putIfAbsent, remove, remove, replace, replace, replaceAll, size, values
static final String PipelineId
static final String PipeLineInstanceId
static final String JobId
static final String Simulate
static final String Signal
static final String ThrowOnError
static final String Echo
static final String EchoMaxCount
static final String Stats
static final String COLLECTION_PROPERTY
static final String HTTP_METHOD
static final String ASYNC
static final String REQUEST_HANDLER
static final String EXCLUDE_EXTENSIONS
static final String SIMULATE
static final String STAGE_INDEX
static final String REQUEST_PARAMS
static final String RESPONSE_TRANSFORMER
static final String EVENTS_PIPELINE
static final String EVENTS_COLLECTION
static final String EVENT_TYPES
static final String AUTHZ_CONTEXT
static final String DEBUG
static final String INNER_PIPELINE
static final String REQUEST_CONTENT_TYPE
static final String EndOfBatchSignal
static final String SolrCommitSignal
static final String SolrDeleteByIdSignal
static final String SolrDeleteByQuerySignal
static final String EXPERIMENT_ID
static final String EXPERIMENT_VARIANT
static final String EXPERIMENT_COLLECTION_FOR_SIGNALS
static final String ANNOTATED_QUERY
Context copyOf()
Context newChildContext()
Context newChildContext(StageCallback<?> callback)
Optional<Context> getParentContext()
boolean isSignal()
boolean isSignal(String signal)
Optional<Context.Signal> getSignal()
void clearSignal()
<M> StageCallback<M> getStageCallback()
void setStageCallback(StageCallback<?> stageCallback)