/**
 * 方法调用之前 aop:before
 * 
 * @param join
 */
public void befor(JoinPoint point) {
	 log.info(String.format("begin func: %s ,param: %s", point.getSignature().getDeclaringTypeName() + 
                "." + point.getSignature().getName(),point.getArgs()));
}

/**
 * around 调用前后
 * o
 * @param point
 * @return
 * @throws Throwable
 */
public Object paramProcess(ProceedingJoinPoint point) throws Throwable {
	// 访问目标方法的参数处理
	Object[] args = point.getArgs();
	// 用改变后的参数执行目标方法
	Object returnValue = point.proceed(args);
	System.out.println("@Around：执行目标方法之后...");
	System.out.println("@Around：被织入的目标对象为：" + point.getTarget());
	return "原返回值：" + returnValue + "，这是返回结果的后缀";
}

/**
 * 方法调用之后处理
 */
public void end(JoinPoint point) {
	 log.info(String.format("end func: %s ,param: %s", point.getTarget(),point.getArgs()));
}

package com.xxx.test
public class TargetFun{
	public void getData1(){
		System.out.println("我是目标方法.....");
	}
}

<bean name="aopInter" class="com.xxx.aop.Interceptor" />
	<aop:config>
		<aop:aspect ref="aopInter">
			 <aop:around method="paramProcess" pointcut="execution(* com.xxx.test.*.getData*(..)) /> 
			<aop:before method="befor"
				pointcut="execution(* com.xxx.test.*.getData*(..))" />
			<aop:after-returning method="end"
				pointcut="execution(* com.xxx.test.*.getData*(..))"  /> 
		</aop:aspect>
	</aop:config>

ClassPathXmlApplicationContext context = null;
TargetFun targetFun = null;

@Before
public void init() {
	String[] configs = { "classpath:spring/spring-platform-xxx.xml" };
	context = new ClassPathXmlApplicationContext(configs);
	targetFun = (TargetFun) context.getBean("test");
}

	@Test
public void testAopParam() {
	targetFun. getData1();
}

000001	wxx	man	18	河北省廊坊市固安县
000002	sgx	man	28	北京市昌平区
000003	kfq	nv	30	青岛某小区
000004	ys	man	20	山东某小区

public class StudentHbaseTool {

	public static class StudentHbaseMapper extends Mapper<LongWritable, Text, Text, Text> {
		// Map<String, String> platformMap = null;
		String platformCode = "";
		final String SPLIT_CHAR_CODE = "\t";

		@Override
		protected void setup(Mapper<LongWritable, Text, Text, Text>.Context context) throws IOException, InterruptedException {
			platformCode = context.getConfiguration().get("platform.code");
			super.setup(context);
		}

		public void map(LongWritable key, Text line, Context context) throws IOException, InterruptedException {
			String[] strs = line.toString().split(SPLIT_CHAR_CODE);
			try {
				if (strs.length == 5) {
					String rowkey = strs[0];
					context.write(new Text(rowkey), line);
				}
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}

	public static class StudentHbaseReducer extends TableReducer<Text, Text, ImmutableBytesWritable> {
		List<String> columns = null;
		final String SPLIT_CHAR_CODE = "\t";
		 String log_date=null;
		@Override
		protected void setup(Reducer<Text, Text, ImmutableBytesWritable, Mutation>.Context context) throws IOException, InterruptedException {
			super.setup(context);
			columns = Arrays.asList(context.getConfiguration().get("table.columns").split(","));
			log_date=context.getConfiguration().get("log_date");
		}

		@Override
		protected void reduce(Text rowkey, Iterable<Text> value, Reducer<Text, Text, ImmutableBytesWritable, Mutation>.Context context)
				throws IOException, InterruptedException {
			String k = rowkey.toString();
			String family = "data";
			while (value.iterator().hasNext()) {
				Text textVal = value.iterator().next();
				try {
					String[] row = textVal.toString().split(SPLIT_CHAR_CODE);
					for (int i = 0; i < row.length; i++) {
						String qualifier = columns.get(i);
						String val = row[i];
						Put put = new Put(k.getBytes());
					   if("age".equals(qualifier)){
							put.add(Bytes.toBytes(family), Bytes.toBytes(qualifier), Bytes.toBytes(Integer.valueOf(val)));
						}else{
							put.add(Bytes.toBytes(family), Bytes.toBytes(qualifier), Bytes.toBytes(val));
						}
						
						context.write(new ImmutableBytesWritable(k.getBytes()), put);
					}
					Put put = new Put(k.getBytes());
					context.write(new ImmutableBytesWritable(k.getBytes()), put);					
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
			
		}

	}

	public static void main(String[] args) {

		if (args == null || args.length != 1) {
			System.err.println("Usage: hadoop -jar xxx.jar <platform> <log_date>  <inputfile>");
			System.exit(2);
		}
		
		HdfsUtils hdfsUtils = new HdfsUtils();
		String defultPath = hdfsUtils.getDefultPath();
		String filePath = defultPath + args[0];
		try {
			String tableName = "basic_data:user_info";
			Configuration config = HBaseConfiguration.create();
			config.set("table.columns", "user_id,user_name,sex,age,address");
			@SuppressWarnings("deprecation")
			Job job = new Job(config, tableName);
			job.setMapperClass(StudentHbaseMapper.class);
			TableMapReduceUtil.initTableReducerJob(tableName, StudentHbaseReducer.class, job);
			job.setMapOutputKeyClass(Text.class);
			job.setMapOutputValueClass(Text.class);
			FileInputFormat.addInputPath(job, new Path(filePath));
			job.setJarByClass(StudentHbaseTool.class);
			job.setInputFormatClass(LzoTextInputFormat.class);

			boolean b = job.waitForCompletion(true);
			if (!b) {
				throw new IOException("error with job!");
			}
		} catch (Exception e) {
			e.printStackTrace();
			System.exit(2);
		}
	}

}

get "basic_data:user_info" "000001"

##创建名称为basicdata 的空间，类似于库的概念
create_namespace 'basic_data'
##basic_data库中创建user_info表，指定列族名称为data，只留一个版本，采用lzo压缩，并开启同步功能。
create 'basic_data:user_info',{NAME => 'data', VERSIONS => 1,COMPRESSION => 'lzo',REPLICATION_SCOPE => 1}

solrctl instancedir --generate ~/weixingxin/basic_data:user_info

<field name="user_id" type="string" indexed="true" stored="true" required="true" multiValued="false" />
<field name="user_name" type="string" indexed="true" stored="true" required="false" multiValued="false" />
<field name="sex" type="string" indexed="true" stored="true" required="false" multiValued="false" />
<field name="age" type="long" indexed="true" stored="true" required="false" multiValued="false" />

solrctl instancedir --create basic_data_user_info ~/weixingxin/basic_data:user_info

solrctl collection --create basic_data_user_info -s 4

##查看已经创建好的所有集合
solrctl instancedir --list
##删除创建好的solr索引
solrctl collection --delete basic_data_user_info
##删除集合配置
solrctl instancedir --delete basic_data_user_info

SOLR_LOCATOR : {
# Name of solr collection
collection : basic_data_user_info
# ZooKeeper ensemble
zkHost : "$ZK_HOST"
}
morphlines : [
{
	id : basic_data_user_info_Map
	importCommands : ["org.kitesdk.**", "com.ngdata.**"]
	commands : [
		{
			extractHBaseCells {
				mappings : [
				{
				inputColumn : "data:user_id"
				outputField : "user_id"
				type : string
				source : value
				},
				{
				inputColumn : "data:user_name"
				outputField : "user_name"
				type : long
				source : value
				},
				{
				inputColumn : "data:sex"
				outputField : "sex"
				type : long
				source : value
				},
				{
				inputColumn : "data:age"
				outputField : "age"
				type : string
				source : value
				}]
			}
		}
		{ logDebug { format : "output record: {}", args : ["@{}"] } }
	]
}]

<?xml version="1.0"?>
 <!-- table：需要索引的HBase表名称-->
 <!-- mapper：用来实现和读取指定的Morphline配置文件类，固定为MorphlineResultToSolrMapper-->
<indexer table="basic_data:user_info" read-row="never"  mapper="com.ngdata.hbaseindexer.morphline.MorphlineResultToSolrMapper">
   <!--param中的name参数用来指定当前配置为morphlineFile文件 -->
   <!--value用来指定morphlines.conf文件的路径，绝对或者相对路径用来指定本地路径，如果是使用Cloudera Manager来管理morphlines.conf就直接写入值morphlines.conf"-->
   <param name="morphlineFile" value="morphlines.conf"/>
      <!-- The optional morphlineId identifies a morphline if there are multiple morphlines in morphlines.conf -->
   <param name="morphlineId" value="basic_data_user_info_Map"/>
</indexer>

hbase-indexer add-indexer \
 --name cloudIndexer \
 --indexer-conf \
~/weixingxin/solr_config/morphline-hbase-mapper.xml \
 --connection-param solr.zk=hadoops15:2181/solr \
 --connection-param solr.collection=basic_data_user_info \
 --zookeeper hadoops15:2181