lambda-kafka-function/src/main/java/com/amazonaws/hbase/lambda/KafkaHandler.java [147:157]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	private String getMasterIntanceGroupId(AmazonElasticMapReduce emr, String clusterid) {
		ListInstanceGroupsRequest listInstanceGroupsRequest = new ListInstanceGroupsRequest();
		listInstanceGroupsRequest.setClusterId(clusterid);
		List<InstanceGroup> instanceGroups = emr.listInstanceGroups(listInstanceGroupsRequest).getInstanceGroups();
		for (InstanceGroup instanceGroup: instanceGroups) {
			if (instanceGroup.getInstanceGroupType().contentEquals(InstanceGroupType.MASTER.toString())) {
				return instanceGroup.getId();
			}
		}
		return null;
	}
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



lambda-kinesis-function/src/main/java/com/amazonaws/hbase/lambda/KinesisHandler.java [144:154]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	private String getMasterIntanceGroupId(AmazonElasticMapReduce emr, String clusterid) {
		ListInstanceGroupsRequest listInstanceGroupsRequest = new ListInstanceGroupsRequest();
		listInstanceGroupsRequest.setClusterId(clusterid);
		List<InstanceGroup> instanceGroups = emr.listInstanceGroups(listInstanceGroupsRequest).getInstanceGroups();
		for (InstanceGroup instanceGroup: instanceGroups) {
			if (instanceGroup.getInstanceGroupType().contentEquals(InstanceGroupType.MASTER.toString())) {
				return instanceGroup.getId();
			}
		}
		return null;
	}
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -