lambda-kafka-function/src/main/java/com/amazonaws/hbase/lambda/KafkaHandler.java [159:173]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	public String getMasterInstanceIpAddress(String clusterid, String region) {
		
		AmazonElasticMapReduce emr = AmazonElasticMapReduceClientBuilder.standard()
				.withCredentials(DefaultAWSCredentialsProviderChain.getInstance())
				.withRegion(Regions.fromName(region))
				.build();
		
		String masterInstanceGroupId = getMasterIntanceGroupId(emr,clusterid);
		ListInstancesRequest listInstancesRequest = new ListInstancesRequest();
		listInstancesRequest.setInstanceGroupId(masterInstanceGroupId);
		listInstancesRequest.setClusterId(clusterid);
		
		List<Instance> instances = emr.listInstances(listInstancesRequest).getInstances();
		return instances.get(0).getPrivateDnsName();
	}
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



lambda-kinesis-function/src/main/java/com/amazonaws/hbase/lambda/KinesisHandler.java [156:169]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	public String getMasterInstanceIpAddress(String clusterid, String region) {
		AmazonElasticMapReduce emr = AmazonElasticMapReduceClientBuilder.standard()
				.withCredentials(DefaultAWSCredentialsProviderChain.getInstance())
				.withRegion(Regions.fromName(region))
				.build();
		
		String masterInstanceGroupId = getMasterIntanceGroupId(emr,clusterid);
		ListInstancesRequest listInstancesRequest = new ListInstancesRequest();
		listInstancesRequest.setInstanceGroupId(masterInstanceGroupId);
		listInstancesRequest.setClusterId(clusterid);
		
		List<Instance> instances = emr.listInstances(listInstancesRequest).getInstances();
		return instances.get(0).getPrivateDnsName();
	}
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -