Modifier and Type | Method and Description |
---|---|
static PreResponse |
AsyncUtils.buildErrorPreResponse(Throwable throwable)
Builds the PreResponse that stores the error message.
|
Modifier and Type | Method and Description |
---|---|
rx.Observable<PreResponse> |
PreResponseStore.get(String ticket)
Returns an Observable over a PreResponse associated with a given ticket.
|
rx.Observable<PreResponse> |
NoOpPreResponseStore.get(String ticket) |
Modifier and Type | Method and Description |
---|---|
rx.Observable<String> |
PreResponseStore.save(String ticket,
PreResponse preResponse)
Saves the specified PreResponse in the store.
|
rx.Observable<String> |
NoOpPreResponseStore.save(String ticket,
PreResponse preResponse) |
Modifier and Type | Method and Description |
---|---|
rx.Observable<PreResponse> |
AsynchronousWorkflows.getSynchronousPayload()
Returns an Observable that emits the query results to send to the user.
|
Modifier and Type | Method and Description |
---|---|
AsynchronousWorkflows |
AsynchronousWorkflowsBuilder.buildAsynchronousWorkflows(rx.Observable<PreResponse> preResponseEmitter,
rx.Observable<Either<PreResponse,JobRow>> payloadEmitter,
JobRow jobMetadata,
Function<JobRow,String> jobMetadataSerializer)
Builds the asynchronous workflows.
|
AsynchronousWorkflows |
AsynchronousWorkflowsBuilder.buildAsynchronousWorkflows(rx.Observable<PreResponse> preResponseEmitter,
rx.Observable<Either<PreResponse,JobRow>> payloadEmitter,
JobRow jobMetadata,
Function<JobRow,String> jobMetadataSerializer)
Builds the asynchronous workflows.
|
AsynchronousWorkflows |
DefaultAsynchronousWorkflowsBuilder.buildAsynchronousWorkflows(rx.Observable<PreResponse> preResponseEmitter,
rx.Observable<Either<PreResponse,JobRow>> payloadEmitter,
JobRow jobMetadata,
Function<JobRow,String> jobMetadataSerializer) |
AsynchronousWorkflows |
DefaultAsynchronousWorkflowsBuilder.buildAsynchronousWorkflows(rx.Observable<PreResponse> preResponseEmitter,
rx.Observable<Either<PreResponse,JobRow>> payloadEmitter,
JobRow jobMetadata,
Function<JobRow,String> jobMetadataSerializer) |
Constructor and Description |
---|
AsynchronousWorkflows(rx.Observable<PreResponse> queryResultsPayload,
rx.Observable<String> jobMetadataPayload,
rx.Observable<String> preResponseReadyNotifications,
rx.Observable<JobRow> jobMarkedCompleteNotifications)
Builds a bean containing all the message flows that support asynchronous processing.
|
Modifier and Type | Method and Description |
---|---|
PreResponse |
PreResponseDeserializer.deserialize(String preResponse)
Deserialize the custom serialized PreResponse.
|
Modifier and Type | Method and Description |
---|---|
javax.ws.rs.core.Response |
HttpResponseMaker.buildResponse(PreResponse preResponse,
ApiRequest apiRequest)
Build complete response.
|
void |
HttpResponseChannel.onNext(PreResponse preResponse) |
Constructor and Description |
---|
PreResponseSerializationProxy(PreResponse preResponse,
com.fasterxml.jackson.databind.ObjectMapper responseContextMapper)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected rx.Observable<PreResponse> |
JobsServlet.getResults(String ticket,
long asyncAfter)
Get an Observable wrapping a PreResponse.
|
protected rx.Observable<PreResponse> |
JobsServlet.handlePreResponseWithError(PreResponse preResponse,
javax.ws.rs.core.UriInfo uriInfo,
Optional<PaginationParameters> paginationParameters)
Check whether the PreResponse contains an error and if it does, return an Observable wrapping the error else
return an Observable wrapping the PreResponse as is.
|
Modifier and Type | Method and Description |
---|---|
protected rx.Observable<PreResponse> |
JobsServlet.handlePreResponseWithError(PreResponse preResponse,
javax.ws.rs.core.UriInfo uriInfo,
Optional<PaginationParameters> paginationParameters)
Check whether the PreResponse contains an error and if it does, return an Observable wrapping the error else
return an Observable wrapping the PreResponse as is.
|
Modifier and Type | Method and Description |
---|---|
protected rx.Observable<javax.ws.rs.core.Response> |
JobsServlet.handlePreResponse(String ticket,
JobsApiRequestImpl apiRequest,
javax.ws.rs.container.AsyncResponse asyncResponse,
rx.Observable<PreResponse> preResponseObservable,
boolean isEmpty)
If isEmpty is true, call the method to send the job payload to the user else call the method to send the job
result to the user.
|
protected void |
JobsServlet.handleResultsResponse(rx.Observable<PreResponse> preResponseObservable,
javax.ws.rs.container.AsyncResponse asyncResponse,
ApiRequest apiRequest)
Process a request to get job results.
|
Modifier and Type | Field and Description |
---|---|
protected rx.subjects.Subject<PreResponse,PreResponse> |
ResultSetResponseProcessor.responseEmitter |
protected rx.subjects.Subject<PreResponse,PreResponse> |
ResultSetResponseProcessor.responseEmitter |
Modifier and Type | Method and Description |
---|---|
ResponseProcessor |
ResponseProcessorFactory.build(DataApiRequest apiRequest,
rx.subjects.Subject<PreResponse,PreResponse> responseEmitter,
DruidResponseParser druidResponseParser,
ObjectMappersSuite objectMappers,
HttpResponseMaker httpResponseMaker)
Constructs a custom ResponseProcessor.
|
ResponseProcessor |
ResponseProcessorFactory.build(DataApiRequest apiRequest,
rx.subjects.Subject<PreResponse,PreResponse> responseEmitter,
DruidResponseParser druidResponseParser,
ObjectMappersSuite objectMappers,
HttpResponseMaker httpResponseMaker)
Constructs a custom ResponseProcessor.
|
ResponseProcessor |
ResultSetResponseProcessorFactory.build(DataApiRequest apiRequest,
rx.subjects.Subject<PreResponse,PreResponse> responseEmitter,
DruidResponseParser druidResponseParser,
ObjectMappersSuite objectMappers,
HttpResponseMaker httpResponseMaker) |
ResponseProcessor |
ResultSetResponseProcessorFactory.build(DataApiRequest apiRequest,
rx.subjects.Subject<PreResponse,PreResponse> responseEmitter,
DruidResponseParser druidResponseParser,
ObjectMappersSuite objectMappers,
HttpResponseMaker httpResponseMaker) |
Constructor and Description |
---|
ResultSetResponseProcessor(DataApiRequest apiRequest,
rx.subjects.Subject<PreResponse,PreResponse> responseEmitter,
DruidResponseParser druidResponseParser,
ObjectMappersSuite objectMappers,
HttpResponseMaker httpResponseMaker)
Constructor.
|
ResultSetResponseProcessor(DataApiRequest apiRequest,
rx.subjects.Subject<PreResponse,PreResponse> responseEmitter,
DruidResponseParser druidResponseParser,
ObjectMappersSuite objectMappers,
HttpResponseMaker httpResponseMaker)
Constructor.
|
Copyright © 2016–2018 Yahoo! Inc.. All rights reserved.