Package alluxio.proxy

Class StreamsRestServiceHandler

java.lang.Object

alluxio.proxy.StreamsRestServiceHandler

@NotThreadSafe
@Path("streams")
@Produces("application/json")
@Consumes("application/json")
public final class StreamsRestServiceHandler
extends java.lang.Object

This class is a REST handler for stream resources.

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	CLOSE
static java.lang.String	ID_PARAM
static java.lang.String	READ
static java.lang.String	SERVICE_PREFIX
static java.lang.String	WRITE

Constructor Summary

Constructors

Constructor	Description
StreamsRestServiceHandler(javax.servlet.ServletContext context)	Constructs a new StreamsRestServiceHandler.

Method Summary

Modifier and Type	Method	Description
javax.ws.rs.core.Response	close(java.lang.Integer id)
javax.ws.rs.core.Response	read(java.lang.Integer id)
javax.ws.rs.core.Response	write(java.lang.Integer id, java.io.InputStream is)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SERVICE_PREFIX

public static final java.lang.String SERVICE_PREFIX

See Also:

Constant Field Values

ID_PARAM

public static final java.lang.String ID_PARAM

See Also:

Constant Field Values

CLOSE

public static final java.lang.String CLOSE

See Also:

Constant Field Values

READ

public static final java.lang.String READ

See Also:

Constant Field Values

WRITE

public static final java.lang.String WRITE

See Also:

Constant Field Values

Constructor Detail

StreamsRestServiceHandler

public StreamsRestServiceHandler(@Context
                                 javax.servlet.ServletContext context)

Constructs a new StreamsRestServiceHandler.

Parameters:

context - context for the servlet

Method Detail

close

@POST
@Path("{id}/close")
public javax.ws.rs.core.Response close(@PathParam("id")
                                       java.lang.Integer id)

read

@POST
@Path("{id}/read")
@Produces("application/octet-stream")
public javax.ws.rs.core.Response read(@PathParam("id")
                                      java.lang.Integer id)

write

@POST
@Path("{id}/write")
@Consumes("application/octet-stream")
public javax.ws.rs.core.Response write(@PathParam("id")
                                       java.lang.Integer id,
                                       java.io.InputStream is)