栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

flink使用es写入时访问域名的方式

flink使用es写入时访问域名的方式

直接上代码

//ES地址https://cs-test.com/es
List httpHosts = new ArrayList<>();
httpHosts.add(HttpHost.create("https://cs-test.com/"));
ElasticsearchSink.Builder esSink = new ElasticsearchSink.Builder<>(httpHosts,new ESSinkFunction<>());
esSink.setRestClientFactory(new DevRestClientFactory());


//实现RestClientFactory接口
static class DevRestClientFactory implements RestClientFactory{
    @Override
    public void configureRestClientBuilder(RestClientBuilder restClientBuilder) {
        //域名后的地址
        restClientBuilder.setPathPrefix("es");
    }
}


转载请注明:文章转载自 www.mshxw.com
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号