一箫一剑平生意,负尽狂名十五年。这篇文章主要讲述elestaticsearch原生写法创建mapping相关的知识,希望能为你提供帮助。
public class TestMapping { private static String ES_HOST1 = "127.0.0.1"; //private static String ES_HOST2 = "192.168.10.254"; private static int ES_PORT = 9300; public static void main(String[] args) { Settings settings = Settings.builder().put("cluster.name", "my-application").build(); TransportClient client=null; try { client = new PreBuiltTransportClient(settings) .addTransportAddress(new TransportAddress(InetAddress.getByName(ES_HOST1), ES_PORT)); } catch (UnknownHostException e) { e.printStackTrace(); }try { createMapping(client); } catch (IOException e) { e.printStackTrace(); }}public static void createMapping(TransportClient client) throws IOException { //创建mapping-需要创建一个空 索引,如果没有索引,创建mapping时会报错 client.admin().indices().prepareCreate("film9").execute().actionGet(); //创建mapping约束字段 XContentBuilder mapping = XContentFactory.jsonBuilder() .startObject() .startObject("properties") .startObject("title") .field("type","text") .endObject() .startObject("publishDate") .field("type", "date") .endObject() .startObject("content") .field("type","text") .field("analyzer", "standard") .endObject() .startObject("director") .field("type", "keyword") .endObject() .startObject("price") .field("type", "float").endObject() .endObject() .endObject(); //添加mapping 绑定到 index PutMappingRequest putMappingRequest = Requests.putMappingRequest("film9").type("dongzuo").source(mapping); boolean result = client.admin().indices().putMapping(putMappingRequest).actionGet().isAcknowledged(); client.close(); System.out.println(result); }}
【elestaticsearch原生写法创建mapping】
推荐阅读
- Jenkins 使用Tfs 插件出现 MappingConflictException 错误问题解决
- 安卓移动端line-height垂直居中出现偏移的解决方法
- 按键精灵对APP自动化测试(上)
- Appium 基础API
- Appium定位
- Android ADB 5037端口被占用问题解决办法(改端口号)
- mui app组件化选择器选择多种语言
- WinXP升级到SP2后网卡取得不到IP怎样办?
- 如何处理WinXP玩英雄联盟时掉帧问题