Package com.conveyal.r5.analyst.cluster

Class Summary

Class	Description
AccessGridWriter	Random-access access grid writer - write arrays into offsets in an access grid format file (3-d array) * Access grids look like this: Header (ASCII text "ACCESSGR") (note that this header is eight bytes, so the full grid can be mapped into a Javascript typed array if desired) Version, 4-byte integer (4 byte int) Web mercator zoom level (4 byte int) west (x) edge of the grid, i.e.
AnalysisTask	Describes an analysis task to be performed.
AnalysisWorkerController	This class contains Spark HTTP request handler methods that are served up by Analysis workers.
AnalystWorker	This is a main class run by worker machines in our Analysis computation cluster.
BundleManifest	Originally transportation data "bundles" were a zip file of GTFS files and OSM files.
EC2Info	API data model class to hold information about the ec2 instance a worker is running on (if any).
GridResultAssembler	Deprecated
JobSimulator	Enqueues a bunch of messages to simulate an Analyst Cluster job $ aws s3 ls analyst-demo-graphs $ aws sqs list-queues
Origin	Utility class to read and write "origin" format.
PathWriter	Accumulates information about paths from a given origin to all destinations in a grid, then writes them out for use in a static site.
RegionalTask	Represents a task to be performed as part of a regional analysis.
RegionalWorkResult	This is the model class used to report accessibility indicators to the backend/broker We report accessibility for a particular travel time cutoff, with travel time defined as a particular percentile.
ScenarioCache	For single point requests, the full expanded JSON representation of the scenario is included in the request.
ThroughputTracker	Keep track of tasks throughput on worker, grouped by job.
TimeGrid	Grid for recording travel times, which can be written to flat binary output This is similar to com.conveyal.r5.analyst.Grid, but it uses ints for the pixel values, and allows multiple values per pixel.
TravelTimeComputerResult	This is a stopgap to allow reducers to return either travel times, or accessibility figures, or both.
TravelTimeSurfaceTask	Represents a single point, interactive task coming from the Analysis UI and returning a surface of travel times to each destination (several travel times to each destination are returned, representing the percentiles of travel time from the chosen origin to that destination.
WorkerStatus	This is an API data model object, used by workers to send information about themselves to the broker as JSON.

Enum Summary

Enum	Description
AnalysisTask.Type
TravelTimeSurfaceTask.Format

Exception Summary

Exception	Description
WorkerNotReadyException	This exception is thrown to indicate that a function cannot complete because it's still asynchronously loading data it needs to perform its calculations.