A B C D F G H I J K M P Q R S T U V W

A

acknowledge() - Method in class com.yahoo.bullet.rest.query.QueryHandler

Indicate that the query was received and accepted by the QUERY_PROCESSING system.

acknowledge() - Method in class com.yahoo.bullet.rest.query.WebSocketQueryHandler

addHandler(String, QueryHandler) - Method in class com.yahoo.bullet.rest.service.HandlerService

Adds the given QueryHandler for the given ID to this service.

AdminController - Class in com.yahoo.bullet.rest.controller

AdminController(QueryService, MetricPublisher) - Constructor for class com.yahoo.bullet.rest.controller.AdminController

The constructor that takes a QueryService and a MetricPublisher.

APIConfiguration - Class in com.yahoo.bullet.rest

APIConfiguration() - Constructor for class com.yahoo.bullet.rest.APIConfiguration

Application - Class in com.yahoo.bullet.rest

Application() - Constructor for class com.yahoo.bullet.rest.Application

AsyncConfiguration - Class in com.yahoo.bullet.rest

AsyncConfiguration() - Constructor for class com.yahoo.bullet.rest.AsyncConfiguration

AsyncConfiguration.ResponderClasses - Class in com.yahoo.bullet.rest

B

bqlConfig(String) - Method in class com.yahoo.bullet.rest.QueryConfiguration

Creates a BQLConfig for BQL.

BQLService - Class in com.yahoo.bullet.rest.service

BQLService(BulletQueryBuilder) - Constructor for class com.yahoo.bullet.rest.service.BQLService

Constructor that takes a BQL query builder.

bulletQueryBuilder(BulletConfig) - Method in class com.yahoo.bullet.rest.QueryConfiguration

Creates a query builder for BQL.

C

checkNotEmpty(Collection<T>) - Static method in class com.yahoo.bullet.rest.common.Utils

Check and throw an exception if the given collection is empty.

clear() - Method in class com.yahoo.bullet.rest.common.PublisherRandomPool

close() - Method in class com.yahoo.bullet.rest.common.PublisherRandomPool

close() - Method in class com.yahoo.bullet.rest.common.Reader

Interrupt the reader thread and close the Subscriber.

close() - Method in class com.yahoo.bullet.rest.service.HandlerService

Stop all service threads and clear pending handlers.

close() - Method in class com.yahoo.bullet.rest.service.QueryService

Stop all service threads and clear pending requests.

com.yahoo.bullet.rest - package com.yahoo.bullet.rest

com.yahoo.bullet.rest.common - package com.yahoo.bullet.rest.common

com.yahoo.bullet.rest.controller - package com.yahoo.bullet.rest.controller

com.yahoo.bullet.rest.model - package com.yahoo.bullet.rest.model

com.yahoo.bullet.rest.query - package com.yahoo.bullet.rest.query

com.yahoo.bullet.rest.service - package com.yahoo.bullet.rest.service

complete - Variable in class com.yahoo.bullet.rest.query.QueryHandler

complete() - Method in class com.yahoo.bullet.rest.query.QueryHandler

Completes the query and sets the complete flag.

complete() - Method in class com.yahoo.bullet.rest.query.SSEQueryHandler

complete() - Method in class com.yahoo.bullet.rest.query.WebSocketQueryHandler

configure(HttpSecurity) - Method in class com.yahoo.bullet.rest.APIConfiguration

configure(SpringApplicationBuilder) - Method in class com.yahoo.bullet.rest.Application

configureMessageBroker(MessageBrokerRegistry) - Method in class com.yahoo.bullet.rest.WebSocketConfiguration

configureWebSocketTransport(WebSocketTransportRegistration) - Method in class com.yahoo.bullet.rest.WebSocketConfiguration

corsConfigurer() - Method in class com.yahoo.bullet.rest.APIConfiguration

Enables CORS globally.

count() - Method in class com.yahoo.bullet.rest.service.HandlerService

Get the number of running handlers.

D

deleteAsyncQuery(String) - Method in class com.yahoo.bullet.rest.controller.HTTPQueryController

This method handles DELETEs for any asynchronous queries submitted to the API.

deleteSession(String) - Method in class com.yahoo.bullet.rest.service.WebSocketService

Deletes a session from the session id map.

F

fail(QueryError) - Method in class com.yahoo.bullet.rest.query.HTTPQueryHandler

fail(QueryError) - Method in class com.yahoo.bullet.rest.query.QueryHandler

Fail the query.

fail() - Method in class com.yahoo.bullet.rest.query.QueryHandler

Convenience method that fails a query with a generic service unavailable error.

fail(QueryError) - Method in class com.yahoo.bullet.rest.query.SSEQueryHandler

fail(QueryError) - Method in class com.yahoo.bullet.rest.query.WebSocketQueryHandler

failAllHandlers() - Method in class com.yahoo.bullet.rest.service.HandlerService

Clears all pending handlers.

failHandler(String) - Method in class com.yahoo.bullet.rest.service.HandlerService

Fail a given handler, if it exists.

from(Schema.Field) - Static method in class com.yahoo.bullet.rest.model.JSONAPIField

Creates an instance from a Schema.Field.

G

get(String) - Method in class com.yahoo.bullet.rest.service.QueryService

Retrieves the stored PubSubMessage of a submitted query.

getHandler(String) - Method in class com.yahoo.bullet.rest.service.HandlerService

Retrieves the QueryHandler for the given ID, if it exists.

getJSONSchema() - Method in class com.yahoo.bullet.rest.controller.SchemaController

The GET endpoint that returns the JSON API schema.

getNewQueryID() - Static method in class com.yahoo.bullet.rest.common.Utils

Get a new unique query ID.

getQuery(HttpServletResponse) - Method in class com.yahoo.bullet.rest.controller.RESTPubSubController

The method that handles reading a query.

getQuery() - Method in class com.yahoo.bullet.rest.service.RESTPubSubService

Get the next query from the query queue.

getResult(HttpServletResponse) - Method in class com.yahoo.bullet.rest.controller.RESTPubSubController

The method that handles reading a result.

getResult() - Method in class com.yahoo.bullet.rest.query.HTTPQueryHandler

Get the single eventual result sent to this handler.

getResult() - Method in class com.yahoo.bullet.rest.service.RESTPubSubService

Get the next result from the result queue.

GSON - Static variable in class com.yahoo.bullet.rest.service.SchemaService

H

HandlerService - Class in com.yahoo.bullet.rest.service

This is used for synchronous sending and handling of queries.

HandlerService() - Constructor for class com.yahoo.bullet.rest.service.HandlerService

Constructor that creates a responder.

handleWebSocketDisconnectListener(SessionDisconnectEvent) - Method in class com.yahoo.bullet.rest.controller.WebSocketEventListener

This method is the handler when receiving WebSocket disconnect events.

hasHandler(String) - Method in class com.yahoo.bullet.rest.service.HandlerService

Checks to see if a given handler exists.

HTTPQueryController - Class in com.yahoo.bullet.rest.controller

HTTPQueryController(HandlerService, QueryService, BQLService, StatusService, MetricPublisher) - Constructor for class com.yahoo.bullet.rest.controller.HTTPQueryController

Constructor that takes various services.

HTTPQueryHandler - Class in com.yahoo.bullet.rest.query

Query handler that implements results for HTTP - one result per query.

HTTPQueryHandler() - Constructor for class com.yahoo.bullet.rest.query.HTTPQueryHandler

I

incrementMetric(String, Metric) - Method in class com.yahoo.bullet.rest.controller.MetricController

Increments the Metric with a given prefix to attach to it.

incrementMetric(String) - Method in class com.yahoo.bullet.rest.controller.MetricController

Increment the given metric.

INVALID_QUERY - Static variable in class com.yahoo.bullet.rest.query.QueryError

isDone(PubSubMessage) - Static method in class com.yahoo.bullet.rest.common.Utils

Check if this message signifies if a query is done or finished.

isHTTPStatusCode(Metric) - Static method in enum com.yahoo.bullet.rest.common.Metric

Returns if the given metric corresponds to a HTTP status.

J

JSONAPIDocument - Class in com.yahoo.bullet.rest.model

JSONAPIDocument() - Constructor for class com.yahoo.bullet.rest.model.JSONAPIDocument

JSONAPIField - Class in com.yahoo.bullet.rest.model

JSONAPIField() - Constructor for class com.yahoo.bullet.rest.model.JSONAPIField

K

kill(String) - Method in class com.yahoo.bullet.rest.service.QueryService

Submits a Metadata.Signal#KILL signal to Bullet for the given query ID and removes the query.

killQuery(String, String) - Method in class com.yahoo.bullet.rest.service.WebSocketService

Kills the query and cleans up.

M

main(String[]) - Static method in class com.yahoo.bullet.rest.Application

Main.

Metric - Enum in com.yahoo.bullet.rest.common

This enum encapsulates the various metrics and statuses that various endpoints served by the API can have.

MetricConfiguration - Class in com.yahoo.bullet.rest

MetricConfiguration() - Constructor for class com.yahoo.bullet.rest.MetricConfiguration

MetricController - Class in com.yahoo.bullet.rest.controller

MetricController(MetricPublisher, MetricCollector) - Constructor for class com.yahoo.bullet.rest.controller.MetricController

Creates a controller that reports to the given MetricPublisher the various metrics collected in the given MetricCollector.

metricPublisher(boolean, String) - Method in class com.yahoo.bullet.rest.MetricConfiguration

Creates a MetricPublisher instance from a provided config.

MISSING_KEY - Static variable in class com.yahoo.bullet.rest.query.QueryError

P

postQuery(String) - Method in class com.yahoo.bullet.rest.controller.RESTPubSubController

The method that handles adding queries to the query queue.

postQuery(String) - Method in class com.yahoo.bullet.rest.service.RESTPubSubService

Add a query to the query queue.

postResult(String) - Method in class com.yahoo.bullet.rest.controller.RESTPubSubController

The method that handles adding results to the result queue.

postResult(String) - Method in class com.yahoo.bullet.rest.service.RESTPubSubService

Add a result to the result queue.

PublisherRandomPool - Class in com.yahoo.bullet.rest.common

PublisherRandomPool(List<Publisher>) - Constructor for class com.yahoo.bullet.rest.common.PublisherRandomPool

Constructor for the RandomPool that takes a list of items.

publishers(PubSub, int) - Method in class com.yahoo.bullet.rest.PubSubConfiguration

Creates the specified number of Publisher instances from the given PubSub.

publishMetrics() - Method in class com.yahoo.bullet.rest.controller.MetricController

Fires and forgets the metrics using the publisher.

pubSub(BulletConfig) - Method in class com.yahoo.bullet.rest.PubSubConfiguration

Creates a PubSub instance from a provided config.

pubSubConfig(String) - Method in class com.yahoo.bullet.rest.PubSubConfiguration

Creates a BulletConfig from a file path.

PubSubConfiguration - Class in com.yahoo.bullet.rest

PubSubConfiguration() - Constructor for class com.yahoo.bullet.rest.PubSubConfiguration

pubSubMessageSendSerDe(BulletConfig) - Method in class com.yahoo.bullet.rest.PubSubConfiguration

Creates a PubSubMessageSerDe from a given BulletConfig to use for sending messages to the PubSub.

Q

QueryConfiguration - Class in com.yahoo.bullet.rest

QueryConfiguration() - Constructor for class com.yahoo.bullet.rest.QueryConfiguration

QueryError - Class in com.yahoo.bullet.rest.query

QueryError(String, String) - Constructor for class com.yahoo.bullet.rest.query.QueryError

Constructor that takes an error message and resolution for it.

QueryError(List<BulletError>) - Constructor for class com.yahoo.bullet.rest.query.QueryError

Constructor that takes a List of BulletError.

QueryHandler - Class in com.yahoo.bullet.rest.query

QueryHandler() - Constructor for class com.yahoo.bullet.rest.query.QueryHandler

queryLimitReached() - Method in class com.yahoo.bullet.rest.service.StatusService

This checks if the configured max concurrent queries limit has been exceeded.

QueryResponse - Class in com.yahoo.bullet.rest.model

QueryResponse() - Constructor for class com.yahoo.bullet.rest.model.QueryResponse

queryService(StorageManager<PubSubMessage>, HandlerService, AsyncConfiguration.ResponderClasses, List<Publisher>, List<Subscriber>, PubSubMessageSerDe, int) - Method in class com.yahoo.bullet.rest.PubSubConfiguration

Creates a QueryService instance from various necessary components.

QueryService - Class in com.yahoo.bullet.rest.service

QueryService(StorageManager<PubSubMessage>, List<PubSubResponder>, List<Publisher>, List<Subscriber>, PubSubMessageSerDe, int) - Constructor for class com.yahoo.bullet.rest.service.QueryService

Constructor that takes various necessary components.

queryStorageManager(String) - Method in class com.yahoo.bullet.rest.StorageConfiguration

Creates a StorageManager instance from a provided config.

R

Reader - Class in com.yahoo.bullet.rest.common

Reader(Subscriber, PubSubResponder, int) - Constructor for class com.yahoo.bullet.rest.common.Reader

Create a service with a Subscriber and a request queue.

registerStompEndpoints(StompEndpointRegistry) - Method in class com.yahoo.bullet.rest.WebSocketConfiguration

removeHandler(String) - Method in class com.yahoo.bullet.rest.service.HandlerService

Removes a QueryHandler for the given ID.

respond(String, PubSubMessage) - Method in class com.yahoo.bullet.rest.service.HandlerService

respond(String, PubSubMessage) - Method in class com.yahoo.bullet.rest.service.QueryService

Respond to a PubSubMessage.

responderClasses(String) - Method in class com.yahoo.bullet.rest.AsyncConfiguration

Creates an instance of the AsyncConfiguration.ResponderClasses.

ResponderClasses() - Constructor for class com.yahoo.bullet.rest.AsyncConfiguration.ResponderClasses

responderClasses() - Method in class com.yahoo.bullet.rest.PubSubConfiguration

RESTPubSubController - Class in com.yahoo.bullet.rest.controller

RESTPubSubController(RESTPubSubService) - Constructor for class com.yahoo.bullet.rest.controller.RESTPubSubController

Constructor.

RESTPubSubService - Class in com.yahoo.bullet.rest.service

RESTPubSubService() - Constructor for class com.yahoo.bullet.rest.service.RESTPubSubService

run() - Method in class com.yahoo.bullet.rest.common.Reader

Read responses from the PubSub and update requests.

run() - Method in class com.yahoo.bullet.rest.service.StatusService

S

SchemaController - Class in com.yahoo.bullet.rest.controller

SchemaController(SchemaService) - Constructor for class com.yahoo.bullet.rest.controller.SchemaController

Constructor.

SchemaService - Class in com.yahoo.bullet.rest.service

Manages access to and provides the schema for the fields.

SchemaService(String, String) - Constructor for class com.yahoo.bullet.rest.service.SchemaService

Constructor that takes in a a string file path and a version string and loads the contents of the file.

send(PubSubMessage) - Method in class com.yahoo.bullet.rest.query.HTTPQueryHandler

send(PubSubMessage) - Method in class com.yahoo.bullet.rest.query.QueryHandler

Send a PubSubMessage to the query handler.

send(PubSubMessage) - Method in class com.yahoo.bullet.rest.query.SSEQueryHandler

send(PubSubMessage) - Method in class com.yahoo.bullet.rest.query.WebSocketQueryHandler

send(String, Metadata.Signal) - Method in class com.yahoo.bullet.rest.service.QueryService

Sends a Metadata.Signal to Bullet without storing it.

send(PubSubMessage) - Method in class com.yahoo.bullet.rest.service.QueryService

Sends a PubSubMessage to Bullet without storing it.

sendReplay() - Method in class com.yahoo.bullet.rest.controller.AdminController

sendResponse(String, WebSocketResponse, SimpMessageHeaderAccessor) - Method in class com.yahoo.bullet.rest.service.WebSocketService

Sends a response to the client through WebSocket connection.

SERVICE_UNAVAILABLE - Static variable in class com.yahoo.bullet.rest.query.QueryError

SSEQueryHandler - Class in com.yahoo.bullet.rest.query

Query handler that implements results for SSE - multiple results per query.

SSEQueryHandler() - Constructor for class com.yahoo.bullet.rest.query.SSEQueryHandler

start() - Method in class com.yahoo.bullet.rest.common.Reader

Starts reading from the pubsub.

StatusService - Class in com.yahoo.bullet.rest.service

StatusService(QueryService, HandlerService, long, long, Boolean, int) - Constructor for class com.yahoo.bullet.rest.service.StatusService

Creates an instance with a tick period and number of retries.

StorageConfiguration - Class in com.yahoo.bullet.rest

StorageConfiguration() - Constructor for class com.yahoo.bullet.rest.StorageConfiguration

submit(String, Query, String) - Method in class com.yahoo.bullet.rest.service.QueryService

Submit a query to Bullet and store it in the storage.

submitAsyncQuery(String) - Method in class com.yahoo.bullet.rest.controller.HTTPQueryController

This method handles POSTs for asynchronous queries to the API.

submitHTTPQuery(String) - Method in class com.yahoo.bullet.rest.controller.HTTPQueryController

The method that handles POSTs to this endpoint.

submitQuery(String, String, Query, String, WebSocketQueryHandler) - Method in class com.yahoo.bullet.rest.service.WebSocketService

Submits a query by HandlerService.

submitSSEQuery(String) - Method in class com.yahoo.bullet.rest.controller.HTTPQueryController

The method that handles SSE POSTs to this endpoint.

submitWebsocketQuery(WebSocketRequest, SimpMessageHeaderAccessor) - Method in class com.yahoo.bullet.rest.controller.WebSocketController

The method that handles WebSocket messages to this endpoint.

subscribers(PubSub, int) - Method in class com.yahoo.bullet.rest.PubSubConfiguration

Creates the specified number of Subscriber instances from the given PubSub.

T

toHTTPStatus() - Method in enum com.yahoo.bullet.rest.common.Metric

The HttpStatus equivalent of this enum, if one exists.

toMetric(String, Metric...) - Static method in class com.yahoo.bullet.rest.controller.MetricController

Concatenates a String prefix to the given metrics.

TOO_MANY_QUERIES - Static variable in class com.yahoo.bullet.rest.query.QueryError

toQuery(String) - Method in class com.yahoo.bullet.rest.service.BQLService

Convert this BQL query to a valid Bullet Query or error out.

toString() - Method in enum com.yahoo.bullet.rest.common.Metric

toString() - Method in class com.yahoo.bullet.rest.query.QueryError

U

UNSUPPORTED_QUERY - Static variable in class com.yahoo.bullet.rest.query.QueryError

Utils - Class in com.yahoo.bullet.rest.common

Utils() - Constructor for class com.yahoo.bullet.rest.common.Utils

V

validateQuery(String) - Method in class com.yahoo.bullet.rest.controller.HTTPQueryController

The method that handles POSTed queries to this endpoint and validates them.

valueOf(String) - Static method in enum com.yahoo.bullet.rest.common.Metric

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.yahoo.bullet.rest.model.WebSocketRequest.Type

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.yahoo.bullet.rest.model.WebSocketResponse.Type

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.yahoo.bullet.rest.common.Metric

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.yahoo.bullet.rest.model.WebSocketRequest.Type

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.yahoo.bullet.rest.model.WebSocketResponse.Type

Returns an array containing the constants of this enum type, in the order they are declared.

VERSION_KEY - Static variable in class com.yahoo.bullet.rest.service.SchemaService

W

WebSocketConfiguration - Class in com.yahoo.bullet.rest

WebSocketConfiguration() - Constructor for class com.yahoo.bullet.rest.WebSocketConfiguration

WebSocketController - Class in com.yahoo.bullet.rest.controller

WebSocketController(WebSocketService, BQLService, StatusService, MetricPublisher) - Constructor for class com.yahoo.bullet.rest.controller.WebSocketController

Constructor that takes various services.

WebSocketEventListener - Class in com.yahoo.bullet.rest.controller

WebSocketEventListener(WebSocketService) - Constructor for class com.yahoo.bullet.rest.controller.WebSocketEventListener

Constructor.

WebSocketQueryHandler - Class in com.yahoo.bullet.rest.query

Query handler that implements results for WebSocket - multiple results per query.

WebSocketQueryHandler(WebSocketService, String, String) - Constructor for class com.yahoo.bullet.rest.query.WebSocketQueryHandler

Constructor method.

WebSocketRequest - Class in com.yahoo.bullet.rest.model

WebSocketRequest() - Constructor for class com.yahoo.bullet.rest.model.WebSocketRequest

WebSocketRequest.Type - Enum in com.yahoo.bullet.rest.model

WebSocketResponse - Class in com.yahoo.bullet.rest.model

WebSocketResponse() - Constructor for class com.yahoo.bullet.rest.model.WebSocketResponse

WebSocketResponse.Type - Enum in com.yahoo.bullet.rest.model

WebSocketService - Class in com.yahoo.bullet.rest.service

WebSocketService(QueryService, HandlerService, SimpMessagingTemplate, String) - Constructor for class com.yahoo.bullet.rest.service.WebSocketService

Constructor.

A B C D F G H I J K M P Q R S T U V W