xuemingqiang/mongo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

WT-2431 Add examples for join cursor statistics.

Browse Source
This commit is contained in:
Don Anderson
2016-02-28 17:26:53 -05:00
parent 5f131eaeb2
commit 5083d97a09
4 changed files with 84 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
examples/java/com/wiredtiger/examples/ex_schema.java
View File

@@ -76,7 +76,7 @@ public class ex_schema {
throws WiredTigerException
{
Connection conn;
Cursor cursor, cursor2, join_cursor;
Cursor cursor, cursor2, join_cursor, stat_cursor;
Session session;
String country;
long recno, population;
@@ -368,6 +368,13 @@ public class ex_schema {
", population " + population);
}
/*! [Join cursors] */
/*! [Statistics cursor join cursor] */
stat_cursor = session.open_cursor(
"statistics:join", join_cursor, null);
/*! [Statistics cursor join cursor] */
ret = stat_cursor.close();
ret = join_cursor.close();
ret = cursor2.close();
ret = cursor.close();

32
examples/java/com/wiredtiger/examples/ex_stat.java
View File

@@ -92,6 +92,33 @@ public class ex_stat {
}
int
print_join_cursor_stats(Session session)
throws WiredTigerException
{
Cursor idx_cursor, join_cursor, stat_cursor;
int ret;
ret = session.create("index:access:idx", "columns=(v)");
idx_cursor = session.open_cursor("index:access:idx", null, null);
ret = idx_cursor.next();
join_cursor = session.open_cursor("join:table:access", null, null);
ret = session.join(join_cursor, idx_cursor, "compare=gt");
ret = join_cursor.next();
/*! [statistics join cursor function] */
stat_cursor = session.open_cursor("statistics:join", join_cursor, null);
ret = print_cursor(stat_cursor);
ret = stat_cursor.close();
/*! [statistics join cursor function] */
ret = join_cursor.close();
ret = idx_cursor.close();
return (ret);
}
int
print_overflow_pages(Session session)
throws WiredTigerException
{
@@ -220,7 +247,8 @@ public class ex_stat {
conn = wiredtiger.open(home, "create,statistics=(all)");
session = conn.open_session(null);
ret = session.create("table:access", "key_format=S,value_format=S");
ret = session.create("table:access",
"key_format=S,value_format=S,columns=(k,v)");
cursor = session.open_cursor("table:access", null, null);
cursor.putKeyString("key");
@@ -234,6 +262,8 @@ public class ex_stat {
ret = print_file_stats(session);
ret = print_join_cursor_stats(session);
ret = print_overflow_pages(session);
ret = print_derived_stats(session);