alluxio.proxy

Class StreamsRestServiceHandler

java.lang.Object

alluxio.proxy.StreamsRestServiceHandler

@NotThreadSafe
 @Path(value="streams")
 @Produces(value="application/json")
 @Consumes(value="application/json")
public final class StreamsRestServiceHandler
extends Object

This class is a REST handler for stream resources.

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
javax.ws.rs.core.Response	close(Integer id)
javax.ws.rs.core.Response	read(Integer id)
javax.ws.rs.core.Response	write(Integer id, 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 String SERVICE_PREFIX

See Also:

Constant Field Values

ID_PARAM

public static final String ID_PARAM

See Also:

Constant Field Values

CLOSE

public static final String CLOSE

See Also:

Constant Field Values

READ

public static final String READ

See Also:

Constant Field Values

WRITE

public static final 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(value="{id}/close")
public javax.ws.rs.core.Response close(@PathParam(value="id")
                                                                        Integer id)

Parameters:

id - the stream id

Returns:

the response object

read

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

Parameters:

id - the stream id

Returns:

the response object

write

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

Parameters:

id - the stream id

is - the input stream

Returns:

the response object