# ---------------------------------- Cluster -----------------------------------
#配置集群名称
cluster.name: wwh_es_cluster
# ------------------------------------ Node ------------------------------------
#配置节点名称,不同节点名字需要不同
node.name: node-213
# ----------------------------------- Paths ------------------------------------
# Path to directory where to store the data (separate multiple locations by comma):
#
# path.data: /path/to/data
#
# Path to log files:
#
# path.logs: /path/to/logs
# ---------------------------------- Network -----------------------------------
# Set the bind address to a specific IP (IPv4 or IPv6):
network.host: 192.168.1.213
# Set a custom port for HTTP:
#
# http.port: 9200
#
# --------------------------------- Discovery ----------------------------------
#集群中可以作为master节点的初始列表,通过这些节点来自动发现新加入集群的节点
discovery.zen.ping.unicast.hosts: ["wwh213", "wwh214"]
#其他的根据需要来配置
if [ "x$ES_MIN_MEM" = "x" ]; then
ES_MIN_MEM=10g //最小内存,根据机器内存来定
fi
if [ "x$ES_MAX_MEM" = "x" ]; then
ES_MAX_MEM=36g //最大内存,根据机器内存来定,最好不要超过机器物理内存的50%
fi
H means 16:9 variant (of a normally 4:3 mode). 2x means pixel doubled (i.e. higher clock rate, with each pixel repeated twice) 4x means pixel quadrupled (i.e. higher clock rate, with each pixel repeated four times)
<!-- default bean id is 'hbaseConfiguration' that uses the existing 'hadoopCconfiguration' object --> <hdp:hbase-configuration configuration-ref="hadoopCconfiguration" />
配置连接
1 2 3 4 5
<!-- delete associated connections but do not stop the proxies --> <hdp:hbase-configuration stop-proxy="false" delete-connection="true"> foo=bar property=value </hdp:hbase-configuration>
// wire hbase configuration (using default name 'hbaseConfiguration') into the template <bean id="htemplate" class="org.springframework.data.hadoop.hbase.HbaseTemplate" p:configuration-ref="hbaseConfiguration"/>
使用例子
1 2 3 4 5 6 7 8 9 10
// writing to 'MyTable' template.execute("MyTable", new TableCallback<Object>() { @Override public Object doInTable(HTable table) throws Throwable { Put p = new Put(Bytes.toBytes("SomeRow")); p.add(Bytes.toBytes("SomeColumn"), Bytes.toBytes("SomeQualifier"), Bytes.toBytes("AValue")); table.put(p); return null; } });
1 2 3 4 5 6 7
// read each row from 'MyTable' List<String> rows = template.find("MyTable", "SomeColumn", new RowMapper<String>() { @Override public String mapRow(Result result, int rowNum) throws Exception { return result.toString(); } }));