NebulaGraph Java Client
release-3.8
|
Classes | |
class | ScanEdgeResultBuilder |
builder to build ScanEdgeResultIterator | |
Public Member Functions | |
ScanEdgeResult | next () throws Exception |
get the next edge set More... | |
Public Member Functions inherited from ScanResultIterator | |
boolean | hasNext () |
if iter has more vertex data More... | |
Additional Inherited Members | |
Protected Member Functions inherited from ScanResultIterator | |
ScanResultIterator (MetaManager metaManager, StorageConnPool pool, PartScanQueue partScanQueue, List< HostAddress > addresses, String spaceName, String labelName, boolean partSuccess, String user, String password) | |
void | freshLeader (String spaceName, int part, HostAddr leader) |
fresh leader for part More... | |
HostAddress | getLeader (HostAddr leader) |
void | handleNullResponse (PartScanInfo partInfo, List< Exception > exceptions) |
void | handleNullResult (PartScanInfo partInfo, List< Exception > exceptions) |
void | throwExceptions (List< Exception > exceptions) throws ExecuteFailedException |
boolean | isSuccessful (ScanResponse response) |
void | handleSucceedResult (AtomicInteger existSuccess, ScanResponse response, PartScanInfo partInfo) |
void | handleFailedResult (ScanResponse response, PartScanInfo partInfo, List< Exception > exceptions) |
Protected Attributes inherited from ScanResultIterator | |
boolean | hasNext = true |
final Map< Integer, byte[]> | partCursor |
final MetaManager | metaManager |
final StorageConnPool | pool |
final PartScanQueue | partScanQueue |
final List< HostAddress > | addresses |
final String | spaceName |
final String | labelName |
final boolean | partSuccess |
final String | user |
final String | password |
Definition at line 32 of file ScanEdgeResultIterator.java.
ScanEdgeResult next | ( | ) | throws Exception |
get the next edge set
in every next function, the client will send new scan request to storage server parallel, and the parallel num is the space's leader hosts.
Definition at line 62 of file ScanEdgeResultIterator.java.