Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- Elasticsearch client is not connected to any Elasticsearch nodes!
- docker run --rm -d -p 9200:9200 -p 9300:9300 -p 5601:5601 --name es-kibana nshou/elasticsearch-kibana
- List<InetSocketAddress> transports = new ArrayList<>();
- transports.add(new InetSocketAddress(InetAddress.getByName("0.0.0.0"), 9300));
- tweets.addSink(new ElasticsearchSink<Tuple2<String, Integer>>(
- config,
- transports,
- new ESSink()));
- curl --request PUT --url http://localhost:9200/twitter-bd
- curl --request PUT
- --url http://localhost:9200/twitter-bd/_mapping/twitter-wordcount
- --header 'content-type: application/json'
- --data '{
- "twitter-wordcount": {
- "properties": {
- "word": {"type": "string"},
- "cnt": {"type": "integer"}
- }
- }
- }'
Add Comment
Please, Sign In to add comment