org.apache.hawq.pxf.service.rest

Class ClusterNodesResource

java.lang.Object

org.apache.hawq.pxf.service.rest.ClusterNodesResource

public class ClusterNodesResource
extends java.lang.Object

Class enhances the API of the HBASE rest server. Example for querying API getClusterNodesInfo from a web client curl "http://localhost:51200/pxf/{version}/HadoopCluster/getNodesInfo" /pxf/ is made part of the path when there is a webapp by that name in tcServer.

Constructor Summary

Constructors

Constructor and Description
ClusterNodesResource()

Method Summary

Modifier and Type	Method and Description
javax.ws.rs.core.Response	read() Function queries the Hadoop namenode with the getDataNodeStats API It gets the host's IP and REST port of every HDFS data node in the cluster.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterNodesResource

public ClusterNodesResource()

Method Detail

read

public javax.ws.rs.core.Response read()
                               throws java.lang.Exception

Function queries the Hadoop namenode with the getDataNodeStats API It gets the host's IP and REST port of every HDFS data node in the cluster. Then, it packs the results in JSON format and writes to the HTTP response stream. Response Examples:

1. When there are no datanodes - getDataNodeStats returns an empty array {"regions":[]}
2. When there are datanodes {"regions":[{"host":"1.2.3.1","port":50075},{"host":"1.2.3.2","port" :50075}]}

Returns:

JSON response with nodes info

Throws:

java.lang.Exception - if failed to retrieve info