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... | |
![]() | |
boolean | hasNext () |
if iter has more vertex data More... | |
Additional Inherited Members | |
![]() | |
ScanResultIterator (MetaManager metaManager, StorageConnPool pool, PartScanQueue partScanQueue, List< HostAddress > addresses, String spaceName, String labelName, boolean partSuccess, String user, String password, Map< String, String > storageAddrMapping) | |
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) |
![]() | |
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 |
final Map< HostAddr, HostAddr > | storageAddressMapping = new ConcurrentHashMap<>() |
Definition at line 33 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 64 of file ScanEdgeResultIterator.java.