org.apache.hawq.pxf.service.rest

Class FragmenterResource

java.lang.Object

org.apache.hawq.pxf.service.rest.RestResource

org.apache.hawq.pxf.service.rest.FragmenterResource

public class FragmenterResource
extends RestResource

Class enhances the API of the WEBHDFS REST server. Returns the data fragments that a data resource is made of, enabling parallel processing of the data resource. Example for querying API FRAGMENTER from a web client curl -i "http://localhost:51200/pxf/{version}/Fragmenter/getFragments?path=/dir1/dir2/*txt" /pxf/ is made part of the path when there is a webapp by that name in tomcat.

Constructor Summary

Constructors

Constructor and Description
FragmenterResource()

Method Summary

Modifier and Type	Method and Description
javax.ws.rs.core.Response	getFragments(javax.servlet.ServletContext servletContext, javax.ws.rs.core.HttpHeaders headers, java.lang.String path) The function is called when http://nn:port/pxf/{version}/Fragmenter/getFragments?path=... is used.
javax.ws.rs.core.Response	getFragmentsStats(javax.servlet.ServletContext servletContext, javax.ws.rs.core.HttpHeaders headers, java.lang.String path) The function is called when http://nn:port/pxf/{version}/Fragmenter/getFragmentsStats?path=... is used.

Methods inherited from class org.apache.hawq.pxf.service.rest.RestResource

convertToCaseInsensitiveMap

Methods inherited from class java.lang.Object

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

Constructor Detail

FragmenterResource

public FragmenterResource()

Method Detail

getFragments

public javax.ws.rs.core.Response getFragments(@Context
                                              javax.servlet.ServletContext servletContext,
                                              @Context
                                              javax.ws.rs.core.HttpHeaders headers,
                                              java.lang.String path)
                                       throws java.lang.Exception

The function is called when http://nn:port/pxf/{version}/Fragmenter/getFragments?path=... is used.

Parameters:

servletContext - Servlet context contains attributes required by SecuredHDFS

headers - Holds HTTP headers from request

path - Holds URI path option used in this request

Returns:

response object with JSON serialized fragments metadata

Throws:

java.lang.Exception - if getting fragments info failed

getFragmentsStats

public javax.ws.rs.core.Response getFragmentsStats(@Context
                                                   javax.servlet.ServletContext servletContext,
                                                   @Context
                                                   javax.ws.rs.core.HttpHeaders headers,
                                                   java.lang.String path)
                                            throws java.lang.Exception

The function is called when http://nn:port/pxf/{version}/Fragmenter/getFragmentsStats?path=... is used.

Parameters:

servletContext - Servlet context contains attributes required by SecuredHDFS

headers - Holds HTTP headers from request

path - Holds URI path option used in this request

Returns:

response object with JSON serialized fragments statistics

Throws:

java.lang.Exception - if getting fragments info failed