Class CollectorNodemanagerProtocolPBClientImpl
java.lang.Object
org.apache.hadoop.yarn.server.api.impl.pb.client.CollectorNodemanagerProtocolPBClientImpl
- All Implemented Interfaces:
Closeable,AutoCloseable,CollectorNodemanagerProtocol
public class CollectorNodemanagerProtocolPBClientImpl
extends Object
implements CollectorNodemanagerProtocol, Closeable
-
Constructor Summary
ConstructorsConstructorDescriptionCollectorNodemanagerProtocolPBClientImpl(long clientVersion, InetSocketAddress addr, org.apache.hadoop.conf.Configuration conf) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()The collector needs to get the context information including user, flow and flow run ID to associate with every incoming put-entity requests.TheTimelineCollectorManagerprovides a list of mapping between application and collector's address inReportNewCollectorInfoRequestto aNodeManagerto register collector's info, include: applicationId and REST URI to access collector.
-
Constructor Details
-
CollectorNodemanagerProtocolPBClientImpl
@Private public CollectorNodemanagerProtocolPBClientImpl(long clientVersion, InetSocketAddress addr, org.apache.hadoop.conf.Configuration conf) throws IOException - Throws:
IOException
-
-
Method Details
-
reportNewCollectorInfo
public ReportNewCollectorInfoResponse reportNewCollectorInfo(ReportNewCollectorInfoRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException Description copied from interface:CollectorNodemanagerProtocolThe
TimelineCollectorManagerprovides a list of mapping between application and collector's address inReportNewCollectorInfoRequestto aNodeManagerto register collector's info, include: applicationId and REST URI to access collector. NodeManager will add them into registered collectors and register them intoResourceManagerafterwards.- Specified by:
reportNewCollectorInfoin interfaceCollectorNodemanagerProtocol- Parameters:
request- the request of registering a new collector or a list of collectors- Returns:
- the response for registering the new collector
- Throws:
org.apache.hadoop.yarn.exceptions.YarnException- if the request is invalidIOException- if there are I/O errors
-
getTimelineCollectorContext
public GetTimelineCollectorContextResponse getTimelineCollectorContext(GetTimelineCollectorContextRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException Description copied from interface:CollectorNodemanagerProtocolThe collector needs to get the context information including user, flow and flow run ID to associate with every incoming put-entity requests.
- Specified by:
getTimelineCollectorContextin interfaceCollectorNodemanagerProtocol- Parameters:
request- the request of getting the aggregator context information of the given application- Returns:
- the response for registering the new collector
- Throws:
org.apache.hadoop.yarn.exceptions.YarnException- if the request is invalidIOException- if there are I/O errors
-
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable
-