File tree Expand file tree Collapse file tree 2 files changed +7
-7
lines changed
src/test/java/org/nlpcn/es4sql Expand file tree Collapse file tree 2 files changed +7
-7
lines changed Original file line number Diff line number Diff line change 3
3
<modelVersion >4.0.0</modelVersion >
4
4
<groupId >org.nlpcn</groupId >
5
5
<artifactId >elasticsearch-sql</artifactId >
6
- <version >2.0.3 </version >
6
+ <version >2.1.0.2 </version >
7
7
<packaging >jar</packaging >
8
8
<description >Query elasticsearch using SQL</description >
9
9
<name >elasticsearch-sql</name >
57
57
<elasticsearch .plugin.name>sql</elasticsearch .plugin.name>
58
58
<elasticsearch .plugin.site>true</elasticsearch .plugin.site>
59
59
<elasticsearch .plugin.jvm>true</elasticsearch .plugin.jvm>
60
- <elasticsearch .version>2.0 .0</elasticsearch .version>
60
+ <elasticsearch .version>2.1 .0</elasticsearch .version>
61
61
<elasticsearch .plugin.classname>org.elasticsearch.plugin.nlpcn.SqlPlug</elasticsearch .plugin.classname>
62
62
63
63
</properties >
66
66
<dependency >
67
67
<groupId >org.elasticsearch</groupId >
68
68
<artifactId >elasticsearch</artifactId >
69
- <version >2.0 .0</version >
69
+ <version >2.1 .0</version >
70
70
<scope >provided</scope >
71
71
</dependency >
72
72
<dependency >
73
73
<groupId >org.elasticsearch.plugin</groupId >
74
74
<artifactId >delete-by-query</artifactId >
75
- <version >2.0 .0</version >
75
+ <version >2.1 .0</version >
76
76
<scope >provided</scope >
77
77
</dependency >
78
78
<dependency >
Original file line number Diff line number Diff line change @@ -49,10 +49,10 @@ public class MainTestSuite {
49
49
@ BeforeClass
50
50
public static void setUp () throws Exception {
51
51
52
- Settings settings = Settings .builder ().put ("plugin.types" , DeleteByQueryPlugin .class .getName ()).build ();
53
- client = TransportClient .builder ().settings (settings ).build ().addTransportAddress (getTransportAddress ());
52
+ client = TransportClient .builder ().addPlugin (DeleteByQueryPlugin .class ).build ().addTransportAddress (getTransportAddress ());
54
53
55
- NodesInfoResponse nodeInfos = client .admin ().cluster ().prepareNodesInfo ().get ();
54
+
55
+ NodesInfoResponse nodeInfos = client .admin ().cluster ().prepareNodesInfo ().get ();
56
56
String clusterName = nodeInfos .getClusterName ().value ();
57
57
System .out .println (String .format ("Found cluster... cluster name: %s" , clusterName ));
58
58
You can’t perform that action at this time.
0 commit comments