AbstractApplicationResource
== [[AbstractApplicationResource]] AbstractApplicationResource
AbstractApplicationResource
is a spark-api-BaseAppResource.md[BaseAppResource] with a set of <
// start spark-shell
$ http http://localhost:4040/api/v1/applications
HTTP/1.1 200 OK
Content-Encoding: gzip
Content-Length: 257
Content-Type: application/json
Date: Tue, 05 Jun 2018 18:46:32 GMT
Server: Jetty(9.3.z-SNAPSHOT)
Vary: Accept-Encoding, User-Agent
[
{
"attempts": [
{
"appSparkVersion": "2.3.1-SNAPSHOT",
"completed": false,
"duration": 0,
"endTime": "1969-12-31T23:59:59.999GMT",
"endTimeEpoch": -1,
"lastUpdated": "2018-06-05T15:04:48.328GMT",
"lastUpdatedEpoch": 1528211088328,
"sparkUser": "jacek",
"startTime": "2018-06-05T15:04:48.328GMT",
"startTimeEpoch": 1528211088328
}
],
"id": "local-1528211089216",
"name": "Spark shell"
}
]
$ http http://localhost:4040/api/v1/applications/local-1528211089216/storage/rdd
HTTP/1.1 200 OK
Content-Length: 3
Content-Type: application/json
Date: Tue, 05 Jun 2018 18:48:00 GMT
Server: Jetty(9.3.z-SNAPSHOT)
Vary: Accept-Encoding, User-Agent
[]
// Execute the following query in spark-shell
spark.range(5).cache.count
$ http http://localhost:4040/api/v1/applications/local-1528211089216/storage/rdd
// output omitted for brevity
[[implementations]] .AbstractApplicationResources [cols="1,2",options="header",width="100%"] |=== | AbstractApplicationResource | Description
| spark-api-OneApplicationResource.md[OneApplicationResource] | [[OneApplicationResource]] Handles applications/appId
requests
| spark-api-OneApplicationAttemptResource.md[OneApplicationAttemptResource] | [[OneApplicationAttemptResource]] |===
[[paths]] .AbstractApplicationResource's Paths [cols="1,1,2",options="header",width="100%"] |=== | Path | HTTP Method | Description
| allexecutors
| GET | <
| environment
| GET | <
| executors
| GET | <
| jobs
| GET | <
| jobs/{jobId: \\d+}
| GET | <
| logs
| GET | <
stages |
---|
< |
| storage/rdd/{rddId: \\d+}
| GET | <
| [[storage_rdd]] storage/rdd
| GET | <
=== [[rddList]] rddList
Method
[source, scala]¶
rddList(): Seq[RDDStorageInfo]¶
rddList
...FIXME
NOTE: rddList
is used when...FIXME
=== [[environmentInfo]] environmentInfo
Method
[source, scala]¶
environmentInfo(): ApplicationEnvironmentInfo¶
environmentInfo
...FIXME
NOTE: environmentInfo
is used when...FIXME
=== [[rddData]] rddData
Method
[source, scala]¶
rddData(@PathParam("rddId") rddId: Int): RDDStorageInfo¶
rddData
...FIXME
NOTE: rddData
is used when...FIXME
=== [[allExecutorList]] allExecutorList
Method
[source, scala]¶
allExecutorList(): Seq[ExecutorSummary]¶
allExecutorList
...FIXME
NOTE: allExecutorList
is used when...FIXME
=== [[executorList]] executorList
Method
[source, scala]¶
executorList(): Seq[ExecutorSummary]¶
executorList
...FIXME
NOTE: executorList
is used when...FIXME
=== [[oneJob]] oneJob
Method
[source, scala]¶
oneJob(@PathParam("jobId") jobId: Int): JobData¶
oneJob
...FIXME
NOTE: oneJob
is used when...FIXME
=== [[jobsList]] jobsList
Method
[source, scala]¶
jobsList(@QueryParam("status") statuses: JList[JobExecutionStatus]): Seq[JobData]¶
jobsList
...FIXME
NOTE: jobsList
is used when...FIXME