Examples of org.apache.bookkeeper.metastore.MetastoreCursor.readEntries()

Class org.apache.bookkeeper.metastore.MetastoreCursor

Examples of org.apache.bookkeeper.metastore.MetastoreCursor.readEntries()

org.apache.bookkeeper.metastore.MetastoreCursor.readEntries()
Read entries from the cursor, up to the specified numEntries. The returned list can be smaller. @param numEntries maximum number of entries to read @return the iterator of returned entries. @throws MSException when failed to read entries from the cursor.

                    if (!cursor.hasMoreEntries()) {
                        return false;
                    }


                    try {
                        itemIter = cursor.readEntries(cfg.getMetastoreMaxEntriesPerScan());
                    } catch (MSException mse) {
                        logger.warn("Interrupted when iterating the topics list : ", mse);
                        return false;
                    }
                }

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.