Inheritance diagram for StorageClient:

Collaboration diagram for StorageClient:

Public Member Functions
	StorageClient (String ip, int port)
	Get a Nebula Storage client that executes the scan query to get NebulaGraph's data with one server host. More...

	StorageClient (List< HostAddress > addresses)
	Get a Nebula Storage client that executes the scan query to get NebulaGraph's data with multi servers' host. More...

	StorageClient (List< HostAddress > addresses, int timeout)
	Get a Nebula Storage client that executes the scan query to get NebulaGraph's data with multi servers' hosts and timeout. More...

	StorageClient (List< HostAddress > addresses, int timeout, int connectionRetry, int executionRetry, boolean enableSSL, SSLParam sslParam)
	Get a Nebula Storage client that executes the scan query to get NebulaGraph's data with multi servers' hosts, timeout and ssl config.

boolean	connect () throws Exception
	Connect to Nebula Storage server. More...

StorageClient	setUser (String user)

StorageClient	setPassword (String password)

void	setStorageAddressMapping (Map< String, String > storageAddressMapping)
	The storage address translation relationship is set to convert the storage address that cannot be obtained by requesting the meta service. More...

ScanVertexResultIterator	scanVertex (String spaceName, String tagName, List< String > returnCols)
	scan vertex of all parts with specific return cols, if returnCols is an empty list, then return all the columns of specific tagName. More...

ScanVertexResultIterator	scanVertex (String spaceName, int part, String tagName, List< String > returnCols)
	scan vertex of specific part with specific return cols, if returnCols is an empty list, then return all the columns of specific tagName. More...

ScanVertexResultIterator	scanVertex (String spaceName, String tagName)
	scan vertex of all parts with no return cols. More...

ScanVertexResultIterator	scanVertex (String spaceName, int part, String tagName)
	scan vertex of specific part with no return cols. More...

ScanVertexResultIterator	scanVertex (String spaceName, String tagName, List< String > returnCols, int limit)
	scan vertex of all parts with specific return cols and limit. More...

ScanVertexResultIterator	scanVertex (String spaceName, int part, String tagName, List< String > returnCols, int limit)
	scan vertex of specific part with specific return cols and limit. More...

ScanVertexResultIterator	scanVertex (String spaceName, String tagName, int limit)
	scan vertex of all parts with no return cols and limit. More...

ScanVertexResultIterator	scanVertex (String spaceName, int part, String tagName, int limit)
	scan vertex of specific part with no return cols and limit. More...

ScanVertexResultIterator	scanVertex (String spaceName, String tagName, List< String > returnCols, int limit, long startTime, long endTime)
	scan vertex of all parts with specific returnCols, limit, startTime and endTime. More...

ScanVertexResultIterator	scanVertex (String spaceName, int part, String tagName, List< String > returnCols, int limit, long startTime, long endTime)
	scan vertex of specific part with specific returnCols, limit, startTime and endTime. More...

ScanVertexResultIterator	scanVertex (String spaceName, String tagName, int limit, long startTime, long endTime)
	scan vertex of all parts with no returnCols, limit, startTime and endTime. More...

ScanVertexResultIterator	scanVertex (String spaceName, int part, String tagName, int limit, long startTime, long endTime)
	scan vertex of specific part with no returnCols, limit, startTime and endTime. More...

ScanVertexResultIterator	scanVertex (String spaceName, String tagName, List< String > returnCols, int limit, long startTime, long endTime, boolean allowPartSuccess, boolean allowReadFromFollower)
	scan vertex of all parts with specific return cols, limit, startTime, endTime， whether allow partial success, whether allow read from storage follower. More...

ScanVertexResultIterator	scanVertex (String spaceName, int part, String tagName, List< String > returnCols, int limit, long startTime, long endTime, boolean allowPartSuccess, boolean allowReadFromFollower)
	scan vertex of specific part with specific return cols, limit, startTime, endTime， whether allow partial success, whether allow read from storage follower. More...

ScanVertexResultIterator	scanVertex (String spaceName, String tagName, int limit, long startTime, long endTime, boolean allowPartSuccess, boolean allowReadFromFollower)
	scan vertex of all parts with no return cols, limit, startTime, endTime， whether allow partial success, whether allow read from storage follower. More...

ScanVertexResultIterator	scanVertex (String spaceName, int part, String tagName, int limit, long startTime, long endTime, boolean allowPartSuccess, boolean allowReadFromFollower)
	scan vertex of specific part with no return cols, limit, startTime, endTime， whether allow partial success, whether allow read from storage follower. More...

ScanEdgeResultIterator	scanEdge (String spaceName, String edgeName, List< String > returnCols)
	scan edge of all parts with return cols. More...

ScanEdgeResultIterator	scanEdge (String spaceName, int part, String edgeName, List< String > returnCols)
	scan edge of specific part with return cols. More...

ScanEdgeResultIterator	scanEdge (String spaceName, String edgeName)
	scan edge of all parts with no return cols. More...

ScanEdgeResultIterator	scanEdge (String spaceName, int part, String edgeName)
	scan edge of specific part with no return cols. More...

ScanEdgeResultIterator	scanEdge (String spaceName, String edgeName, List< String > returnCols, int limit)
	scan edge of all parts with return cols and limit config. More...

ScanEdgeResultIterator	scanEdge (String spaceName, int part, String edgeName, List< String > returnCols, int limit)
	scan edge of specific part with return cols. More...

ScanEdgeResultIterator	scanEdge (String spaceName, String edgeName, int limit)
	scan edge of all parts with no return cols and limit config. More...

ScanEdgeResultIterator	scanEdge (String spaceName, int part, String edgeName, int limit)
	scan edge of specific part with no return cols and limit config. More...

ScanEdgeResultIterator	scanEdge (String spaceName, String edgeName, List< String > returnCols, int limit, long startTime, long endTime)
	scan edge of all parts with return cols and limit, start time, end time config. More...

ScanEdgeResultIterator	scanEdge (String spaceName, int part, String edgeName, List< String > returnCols, int limit, long startTime, long endTime)
	scan edge of specific part with return cols and limit, start time, end time config. More...

ScanEdgeResultIterator	scanEdge (String spaceName, String edgeName, int limit, long startTime, long endTime)
	scan edge of all parts with no return cols and limit, start time, end time config. More...

ScanEdgeResultIterator	scanEdge (String spaceName, int part, String edgeName, int limit, long startTime, long endTime)
	scan edge of specific part with no return cols and limit, start time, end time config. More...

ScanEdgeResultIterator	scanEdge (String spaceName, String edgeName, List< String > returnCols, int limit, long startTime, long endTime, boolean allowPartSuccess, boolean allowReadFromFollower)
	scan edge of all parts with return cols and limit, start time, end time, if allow partial success, if allow read data from storage follower config. More...

ScanEdgeResultIterator	scanEdge (String spaceName, int part, String edgeName, List< String > returnCols, int limit, long startTime, long endTime, boolean allowPartSuccess, boolean allowReadFromFollower)
	scan edge of specific part with return cols and limit, start time, end time, if allow partial success, if allow read data from storage follower config. More...

ScanEdgeResultIterator	scanEdge (String spaceName, String edgeName, int limit, long startTime, long endTime, boolean allowPartSuccess, boolean allowReadFromFollower)
	scan edge of all parts with no return cols and limit, start time, end time, if allow partial success, if allow read data from storage follower config. More...

ScanEdgeResultIterator	scanEdge (String spaceName, int part, String edgeName, int limit, long startTime, long endTime, boolean allowPartSuccess, boolean allowReadFromFollower)
	scan edge of specific part with no return cols and limit, start time, end time, if allow partial success, if allow read data from storage follower config. More...

void	close ()
	release storage client

Protected Member Functions
GraphStorageConnection	getConnection ()
	return client's connection session More...

Detailed Description

Definition at line 31 of file StorageClient.java.

Constructor & Destructor Documentation

◆ StorageClient() [1/3]

StorageClient	(	String	ip,
		int	port
	)

Get a Nebula Storage client that executes the scan query to get NebulaGraph's data with one server host.

Parameters

ip	the ip of metad server
port	the port of metad server

Definition at line 57 of file StorageClient.java.

◆ StorageClient() [2/3]

StorageClient ( List< HostAddress > addresses )

Get a Nebula Storage client that executes the scan query to get NebulaGraph's data with multi servers' host.

Parameters

addresses the HostAddress list of metad servers

Definition at line 67 of file StorageClient.java.

◆ StorageClient() [3/3]

StorageClient	(	List< HostAddress >	addresses,
		int	timeout
	)

Get a Nebula Storage client that executes the scan query to get NebulaGraph's data with multi servers' hosts and timeout.

Parameters

addresses	the HostAddress list of metad servers
timeout	the timeout of scan vertex or edge

Definition at line 79 of file StorageClient.java.

Member Function Documentation

◆ connect()

boolean connect ( ) throws Exception

Connect to Nebula Storage server.

Returns: true if connect successfully.

Definition at line 106 of file StorageClient.java.

Here is the call graph for this function:

◆ getConnection()

GraphStorageConnection getConnection ( )

protected

return client's connection session

Returns: StorageConnection

Definition at line 1149 of file StorageClient.java.

◆ scanEdge() [1/16]

ScanEdgeResultIterator scanEdge	(	String	spaceName,
		int	part,
		String	edgeName
	)

scan edge of specific part with no return cols.

the result only contains edge src id, dst id, rank.

Parameters

spaceName	Nebula space name
part	Nebula data partition
edgeName	Nebula edge type name

Returns: an iterator to get data by call ScanEdgeResultIterator#next()

Definition at line 720 of file StorageClient.java.

Here is the call graph for this function:

◆ scanEdge() [2/16]

ScanEdgeResultIterator scanEdge	(	String	spaceName,
		int	part,
		String	edgeName,
		int	limit
	)

scan edge of specific part with no return cols and limit config.

the result only contains edge src id, dst id, rank.

Parameters

spaceName	Nebula space name
part	Nebula data partition
edgeName	Nebula edge type name
limit	the data amount of scan operation for each partition in every iterator

Returns: an iterator to get data by call ScanEdgeResultIterator#next()

Definition at line 787 of file StorageClient.java.

Here is the call graph for this function:

◆ scanEdge() [3/16]

ScanEdgeResultIterator scanEdge	(	String	spaceName,
		int	part,
		String	edgeName,
		int	limit,
		long	startTime,
		long	endTime
	)

scan edge of specific part with no return cols and limit, start time, end time config.

the result only contains edge src id, dst id, rank.

Parameters

spaceName	Nebula space name
part	Nebula data partition
edgeName	Nebula edge type name
limit	the data amount of scan operation for each partition in every iterator
startTime	the time range's start time of the data to be scanned, if data was insert before start time, then it will not be return.
endTime	the time range's end time of the data to be scanned, if data was insert after end time, then it will not be return.

Returns: an iterator to get data by call ScanEdgeResultIterator#next()

Definition at line 881 of file StorageClient.java.

Here is the call graph for this function:

◆ scanEdge() [4/16]

ScanEdgeResultIterator scanEdge	(	String	spaceName,
		int	part,
		String	edgeName,
		int	limit,
		long	startTime,
		long	endTime,
		boolean	allowPartSuccess,
		boolean	allowReadFromFollower
	)

scan edge of specific part with no return cols and limit, start time, end time, if allow partial success, if allow read data from storage follower config.

the result only contains edge src id, dst id, rank.

Parameters

spaceName	Nebula space name
edgeName	Nebula edge type name
part	Nebula data partition
limit	the data amount of scan operation for each partition in every iterator
startTime	the time range's start time of the data to be scanned, if data was insert before start time, then it will not be return.
endTime	the time range's end time of the data to be scanned, if data was insert after end time, then it will not be return.
allowPartSuccess	if allow part success
allowReadFromFollower	if allow read from follower

Returns: an iterator to get data by call ScanEdgeResultIterator#next()

Definition at line 1015 of file StorageClient.java.

Here is the call graph for this function:

◆ scanEdge() [5/16]

ScanEdgeResultIterator scanEdge	(	String	spaceName,
		int	part,
		String	edgeName,
		List< String >	returnCols
	)

scan edge of specific part with return cols.

the result contains edge src id, dst id, rank and return cols.

Parameters

spaceName	Nebula space name
part	Nebula data partition
edgeName	Nebula edge type name
returnCols	Nebula edge properties to return

Returns: an iterator to get data by call ScanEdgeResultIterator#next()

Definition at line 691 of file StorageClient.java.

Here is the call graph for this function:

◆ scanEdge() [6/16]

ScanEdgeResultIterator scanEdge	(	String	spaceName,
		int	part,
		String	edgeName,
		List< String >	returnCols,
		int	limit
	)

scan edge of specific part with return cols.

the result contains edge src id, dst id, rank and return cols.

Parameters

spaceName	Nebula space name
edgeName	Nebula edge type name
returnCols	Nebula edge properties to return
limit	the data amount of scan operation for each partition in every iterator

Returns: an iterator to get data by call ScanEdgeResultIterator#next()

Definition at line 754 of file StorageClient.java.

Here is the call graph for this function:

◆ scanEdge() [7/16]

ScanEdgeResultIterator scanEdge	(	String	spaceName,
		int	part,
		String	edgeName,
		List< String >	returnCols,
		int	limit,
		long	startTime,
		long	endTime
	)

scan edge of specific part with return cols and limit, start time, end time config.

the result contains edge src id, dst id, rank and return cols.

Parameters

spaceName	Nebula space name
part	Nebula data partition
edgeName	Nebula edge type name
returnCols	Nebula edge properties to return
limit	the data amount of scan operation for each partition in every iterator
startTime	the time range's start time of the data to be scanned, if data was insert before start time, then it will not be return.
endTime	the time range's end time of the data to be scanned, if data was insert after end time, then it will not be return.

Returns: an iterator to get data by call ScanEdgeResultIterator#next()

Definition at line 830 of file StorageClient.java.

Here is the call graph for this function:

◆ scanEdge() [8/16]

ScanEdgeResultIterator scanEdge	(	String	spaceName,
		int	part,
		String	edgeName,
		List< String >	returnCols,
		int	limit,
		long	startTime,
		long	endTime,
		boolean	allowPartSuccess,
		boolean	allowReadFromFollower
	)

scan edge of specific part with return cols and limit, start time, end time, if allow partial success, if allow read data from storage follower config.

the result contains edge src id, dst id, rank and return cols.

Parameters

spaceName	Nebula space name
part	Nebula data partition
edgeName	Nebula edge type name
limit	the data amount of scan operation for each partition in every iterator
startTime	the time range's start time of the data to be scanned, if data was insert before start time, then it will not be return.
endTime	the time range's end time of the data to be scanned, if data was insert after end time, then it will not be return.
allowPartSuccess	if allow part success
allowReadFromFollower	if allow read from follower

Returns: an iterator to get data by call ScanEdgeResultIterator#next()

Definition at line 947 of file StorageClient.java.

Here is the call graph for this function:

◆ scanEdge() [9/16]

ScanEdgeResultIterator scanEdge	(	String	spaceName,
		String	edgeName
	)

scan edge of all parts with no return cols.

the result only contains edge src id, dst id, rank.

Parameters

spaceName	Nebula space name
edgeName	Nebula edge type name

Returns: an iterator to get data by call ScanEdgeResultIterator#next()

Definition at line 706 of file StorageClient.java.

Here is the call graph for this function:

◆ scanEdge() [10/16]

ScanEdgeResultIterator scanEdge	(	String	spaceName,
		String	edgeName,
		int	limit
	)

scan edge of all parts with no return cols and limit config.

the result only contains edge src id, dst id, rank.

Parameters

spaceName	Nebula space name
edgeName	Nebula edge type name
limit	the data amount of scan operation for each partition in every iterator

Returns: an iterator to get data by call ScanEdgeResultIterator#next()

Definition at line 771 of file StorageClient.java.

Here is the call graph for this function:

◆ scanEdge() [11/16]

ScanEdgeResultIterator scanEdge	(	String	spaceName,
		String	edgeName,
		int	limit,
		long	startTime,
		long	endTime
	)

scan edge of all parts with no return cols and limit, start time, end time config.

the result only contains edge src id, dst id, rank.

Parameters

spaceName	Nebula space name
edgeName	Nebula edge type name
limit	the data amount of scan operation for each partition in every iterator
startTime	the time range's start time of the data to be scanned, if data was insert before start time, then it will not be return.
endTime	the time range's end time of the data to be scanned, if data was insert after end time, then it will not be return.

Returns: an iterator to get data by call ScanEdgeResultIterator#next()

Definition at line 856 of file StorageClient.java.

Here is the call graph for this function:

◆ scanEdge() [12/16]

ScanEdgeResultIterator scanEdge	(	String	spaceName,
		String	edgeName,
		int	limit,
		long	startTime,
		long	endTime,
		boolean	allowPartSuccess,
		boolean	allowReadFromFollower
	)

scan edge of all parts with no return cols and limit, start time, end time, if allow partial success, if allow read data from storage follower config.

the result only contains edge src id, dst id, rank.

Parameters

spaceName	Nebula space name
edgeName	Nebula edge type name
limit	the data amount of scan operation for each partition in every iterator
startTime	the time range's start time of the data to be scanned, if data was insert before start time, then it will not be return.
endTime	the time range's end time of the data to be scanned, if data was insert after end time, then it will not be return.
allowPartSuccess	if allow part success
allowReadFromFollower	if allow read from follower

Returns: an iterator to get data by call ScanEdgeResultIterator#next()

Definition at line 979 of file StorageClient.java.

Here is the call graph for this function:

◆ scanEdge() [13/16]

ScanEdgeResultIterator scanEdge	(	String	spaceName,
		String	edgeName,
		List< String >	returnCols
	)

scan edge of all parts with return cols.

the result contains edge src id, dst id, rank and return cols.

Parameters

spaceName	Nebula space name
edgeName	Nebula edge type name
returnCols	Nebula edge properties to return

Returns: an iterator to get data by call ScanVertexResultIterator#next()

Definition at line 674 of file StorageClient.java.

Here is the caller graph for this function:

◆ scanEdge() [14/16]

ScanEdgeResultIterator scanEdge	(	String	spaceName,
		String	edgeName,
		List< String >	returnCols,
		int	limit
	)

scan edge of all parts with return cols and limit config.

the result contains edge src id, dst id, rank and return cols.

Parameters

spaceName	Nebula space name
edgeName	Nebula edge type name
returnCols	Nebula edge properties to return
limit	the data amount of scan operation for each partition in every iterator

Returns: an iterator to get data by call ScanEdgeResultIterator#next()

Definition at line 736 of file StorageClient.java.

Here is the call graph for this function:

◆ scanEdge() [15/16]

ScanEdgeResultIterator scanEdge	(	String	spaceName,
		String	edgeName,
		List< String >	returnCols,
		int	limit,
		long	startTime,
		long	endTime
	)

scan edge of all parts with return cols and limit, start time, end time config.

the result only contains edge src id, dst id, rank and return cols.

Parameters

spaceName	Nebula space name
edgeName	Nebula edge type name
returnCols	Nebula edge properties to return
limit	the data amount of scan operation for each partition in every iterator

Returns: an iterator to get data by call ScanEdgeResultIterator#next()

Definition at line 803 of file StorageClient.java.

Here is the call graph for this function:

◆ scanEdge() [16/16]

ScanEdgeResultIterator scanEdge	(	String	spaceName,
		String	edgeName,
		List< String >	returnCols,
		int	limit,
		long	startTime,
		long	endTime,
		boolean	allowPartSuccess,
		boolean	allowReadFromFollower
	)

scan edge of all parts with return cols and limit, start time, end time, if allow partial success, if allow read data from storage follower config.

the result contains edge src id, dst id, rank and return cols.

Parameters

spaceName	Nebula space name
edgeName	Nebula edge type name
limit	the data amount of scan operation for each partition in every iterator
startTime	the time range's start time of the data to be scanned, if data was insert before start time, then it will not be return.
endTime	the time range's end time of the data to be scanned, if data was insert after end time, then it will not be return.
allowPartSuccess	if allow part success
allowReadFromFollower	if allow read from follower

Returns: an iterator to get data by call ScanEdgeResultIterator#next()

Definition at line 910 of file StorageClient.java.

Here is the call graph for this function:

◆ scanVertex() [1/16]

ScanVertexResultIterator scanVertex	(	String	spaceName,
		int	part,
		String	tagName
	)

scan vertex of specific part with no return cols.

the result only contains vertex id.

Parameters

spaceName	Nebula space name
part	Nebula data partition
tagName	Nebula tag name

Returns: an iterator to get data by call ScanVertexResultIterator#next()

Definition at line 203 of file StorageClient.java.

Here is the call graph for this function:

◆ scanVertex() [2/16]

ScanVertexResultIterator scanVertex	(	String	spaceName,
		int	part,
		String	tagName,
		int	limit
	)

scan vertex of specific part with no return cols and limit.

the result only contains vertex id.

Parameters

spaceName	Nebula space name
part	Nebula data partition
tagName	Nebula tag name
limit	the data amount of scan in every iterator

Returns: an iterator to get data by call ScanVertexResultIterator#next()

Definition at line 274 of file StorageClient.java.

Here is the call graph for this function:

◆ scanVertex() [3/16]

ScanVertexResultIterator scanVertex	(	String	spaceName,
		int	part,
		String	tagName,
		int	limit,
		long	startTime,
		long	endTime
	)

scan vertex of specific part with no returnCols, limit, startTime and endTime.

the result contains vertex id and return cols.

Parameters

spaceName	Nebula space name
tagName	Nebula tag name
limit	the data amount of scan operation for each partition in every iterator
startTime	the time range's start time of the data to be scanned, if data was insert before start time, then it will not be return.
endTime	the time range's end time of the data to be scanned, if data was insert after end time, then it will not be return.

Returns: an iterator to get data by call ScanVertexResultIterator#next()

Definition at line 371 of file StorageClient.java.

Here is the call graph for this function:

◆ scanVertex() [4/16]

ScanVertexResultIterator scanVertex	(	String	spaceName,
		int	part,
		String	tagName,
		int	limit,
		long	startTime,
		long	endTime,
		boolean	allowPartSuccess,
		boolean	allowReadFromFollower
	)

scan vertex of specific part with no return cols, limit, startTime, endTime， whether allow partial success, whether allow read from storage follower.

the result only contains vertex id.

Parameters

spaceName	Nebula graph space
part	Nebula data partition
tagName	Nebula tag name
limit	the data amount of scan operation for each partition in every iterator
startTime	the time range's start time of the data to be scanned, if data was insert before start time, then it will not be return.
endTime	the time range's end time of the data to be scanned, if data was insert after end time, then it will not be return.
allowPartSuccess	if allow part success
allowReadFromFollower	if allow read from follower

Returns: an iterator to get data by call ScanVertexResultIterator#next()

Definition at line 545 of file StorageClient.java.

Here is the call graph for this function:

◆ scanVertex() [5/16]

ScanVertexResultIterator scanVertex	(	String	spaceName,
		int	part,
		String	tagName,
		List< String >	returnCols
	)

scan vertex of specific part with specific return cols, if returnCols is an empty list, then return all the columns of specific tagName.

the result contains vertex id and return cols.

Parameters

spaceName	Nebula space name
part	Nebula data partition
tagName	Nebula tag name
returnCols	Nebula tag properties to return

Returns: an iterator to get data by call ScanVertexResultIterator#next()

Definition at line 175 of file StorageClient.java.

Here is the call graph for this function:

◆ scanVertex() [6/16]

ScanVertexResultIterator scanVertex	(	String	spaceName,
		int	part,
		String	tagName,
		List< String >	returnCols,
		int	limit
	)

scan vertex of specific part with specific return cols and limit.

the result contains vertex id and return cols.

Parameters

spaceName	Nebula space name
part	Nebula data partition
tagName	Nebula tag name
returnCols	Nebula tag properties to return
limit	the data amount of scan in every iterator

Returns: an iterator to get data by call ScanVertexResultIterator#next()

Definition at line 238 of file StorageClient.java.

Here is the call graph for this function:

◆ scanVertex() [7/16]

ScanVertexResultIterator scanVertex	(	String	spaceName,
		int	part,
		String	tagName,
		List< String >	returnCols,
		int	limit,
		long	startTime,
		long	endTime
	)

scan vertex of specific part with specific returnCols, limit, startTime and endTime.

the result contains vertex id and return cols.

Parameters

spaceName	Nebula space name
part	Nebula data partition
tagName	Nebula tag name
returnCols	Nebula tag properties to return
limit	the data amount of scan operation for each partition in every iterator
startTime	the time range's start time of the data to be scanned, if data was insert before start time, then it will not be return.
endTime	the time range's end time of the data to be scanned, if data was insert after end time, then it will not be return.

Returns: an iterator to get data by call ScanVertexResultIterator#next()

Definition at line 323 of file StorageClient.java.

Here is the call graph for this function:

◆ scanVertex() [8/16]

ScanVertexResultIterator scanVertex	(	String	spaceName,
		int	part,
		String	tagName,
		List< String >	returnCols,
		int	limit,
		long	startTime,
		long	endTime,
		boolean	allowPartSuccess,
		boolean	allowReadFromFollower
	)

scan vertex of specific part with specific return cols, limit, startTime, endTime， whether allow partial success, whether allow read from storage follower.

the result contains vertex id and return cols.

Parameters

spaceName	Nebula graph space
part	Nebula data partition
tagName	Nebula tag name
returnCols	Nebula tag properties to return
limit	the data amount of scan operation for each partition in every iterator
startTime	the time range's start time of the data to be scanned, if data was insert before start time, then it will not be return.
endTime	the time range's end time of the data to be scanned, if data was insert after end time, then it will not be return.
allowPartSuccess	if allow part success
allowReadFromFollower	if allow read from follower

Returns: an iterator to get data by call ScanVertexResultIterator#next()

Definition at line 458 of file StorageClient.java.

Here is the call graph for this function:

◆ scanVertex() [9/16]

ScanVertexResultIterator scanVertex	(	String	spaceName,
		String	tagName
	)

scan vertex of all parts with no return cols.

the result only contains vertex id.

Parameters

spaceName	Nebula space name
tagName	Nebula tag name

Returns: an iterator to get data by call ScanVertexResultIterator#next()

Definition at line 189 of file StorageClient.java.

Here is the call graph for this function:

◆ scanVertex() [10/16]

ScanVertexResultIterator scanVertex	(	String	spaceName,
		String	tagName,
		int	limit
	)

scan vertex of all parts with no return cols and limit.

the result only contains vertex id.

Parameters

spaceName	Nebula space name
tagName	Nebula tag name
limit	the data amount of scan in every iterator

Returns: an iterator to get data by call ScanVertexResultIterator#next()

Definition at line 257 of file StorageClient.java.

Here is the call graph for this function:

◆ scanVertex() [11/16]

ScanVertexResultIterator scanVertex	(	String	spaceName,
		String	tagName,
		int	limit,
		long	startTime,
		long	endTime
	)

scan vertex of all parts with no returnCols, limit, startTime and endTime.

the result contains vertex id and return cols.

Parameters

spaceName	Nebula space name
tagName	Nebula tag name
limit	the data amount of scan operation for each partition in every iterator
startTime	the time range's start time of the data to be scanned, if data was insert before start time, then it will not be return.
endTime	the time range's end time of the data to be scanned, if data was insert after end time, then it will not be return.

Returns: an iterator to get data by call ScanVertexResultIterator#next()

Definition at line 348 of file StorageClient.java.

Here is the call graph for this function:

◆ scanVertex() [12/16]

ScanVertexResultIterator scanVertex	(	String	spaceName,
		String	tagName,
		int	limit,
		long	startTime,
		long	endTime,
		boolean	allowPartSuccess,
		boolean	allowReadFromFollower
	)

scan vertex of all parts with no return cols, limit, startTime, endTime， whether allow partial success, whether allow read from storage follower.

the result only contains vertex id.

Parameters

spaceName	Nebula graph space
tagName	Nebula tag name
limit	the data amount of scan operation for each partition in every iterator
startTime	the time range's start time of the data to be scanned, if data was insert before start time, then it will not be return.
endTime	the time range's end time of the data to be scanned, if data was insert after end time, then it will not be return.
allowPartSuccess	if allow part success
allowReadFromFollower	if allow read from follower

Returns: an iterator to get data by call ScanVertexResultIterator#next()

Definition at line 501 of file StorageClient.java.

Here is the call graph for this function:

◆ scanVertex() [13/16]

ScanVertexResultIterator scanVertex	(	String	spaceName,
		String	tagName,
		List< String >	returnCols
	)

scan vertex of all parts with specific return cols, if returnCols is an empty list, then return all the columns of specific tagName.

the result contains vertex id and return cols.

Parameters

spaceName	Nebula space name
tagName	Nebula tag name
returnCols	Nebula tag properties to return

Returns: an iterator to get data by call ScanVertexResultIterator#next()

Definition at line 158 of file StorageClient.java.

Here is the caller graph for this function:

◆ scanVertex() [14/16]

ScanVertexResultIterator scanVertex	(	String	spaceName,
		String	tagName,
		List< String >	returnCols,
		int	limit
	)

scan vertex of all parts with specific return cols and limit.

the result contains vertex id and return cols.

Parameters

spaceName	Nebula space name
tagName	Nebula tag name
returnCols	Nebula tag properties to return
limit	the data amount of scan in every iterator

Returns: an iterator to get data by call ScanVertexResultIterator#next()

Definition at line 218 of file StorageClient.java.

Here is the call graph for this function:

◆ scanVertex() [15/16]

ScanVertexResultIterator scanVertex	(	String	spaceName,
		String	tagName,
		List< String >	returnCols,
		int	limit,
		long	startTime,
		long	endTime
	)

scan vertex of all parts with specific returnCols, limit, startTime and endTime.

the result contains vertex id and return cols.

Parameters

spaceName	Nebula space name
tagName	Nebula tag name
returnCols	nebula tag properties to return
limit	the data amount of scan operation for each partition in every iterator
startTime	the time range's start time of the data to be scanned, if data was insert before start time, then it will not be return.
endTime	the time range's end time of the data to be scanned, if data was insert after end time, then it will not be return.

Returns: an iterator to get data by call ScanVertexResultIterator#next()

Definition at line 297 of file StorageClient.java.

Here is the call graph for this function:

◆ scanVertex() [16/16]

ScanVertexResultIterator scanVertex	(	String	spaceName,
		String	tagName,
		List< String >	returnCols,
		int	limit,
		long	startTime,
		long	endTime,
		boolean	allowPartSuccess,
		boolean	allowReadFromFollower
	)

scan vertex of all parts with specific return cols, limit, startTime, endTime， whether allow partial success, whether allow read from storage follower.

the result contains vertex id and return cols.

Parameters

spaceName	Nebula graph space
tagName	Nebula tag name
returnCols	Nebula tag properties to return
limit	the data amount of scan operation for each partition in every iterator
startTime	the time range's start time of the data to be scanned, if data was insert before start time, then it will not be return.
endTime	the time range's end time of the data to be scanned, if data was insert after end time, then it will not be return.
allowPartSuccess	if allow part success
allowReadFromFollower	if allow read from follower

Returns: an iterator to get data by call ScanVertexResultIterator#next()

Definition at line 410 of file StorageClient.java.

Here is the call graph for this function:

◆ setStorageAddressMapping()

void setStorageAddressMapping ( Map< String, String > storageAddressMapping )

The storage address translation relationship is set to convert the storage address that cannot be obtained by requesting the meta service.

Parameters

storageAddressMapping sourceAddressFromMeta -> targetAddress,Format ip:port. eg: 127.0.0.1:9559 -> 10.1.1.2:9559， Translates the storage 127.0.0.1:9559 address obtained from the meta server to 10.1.1.2:9559. It will use 10.1.1.2:9559 to request storage. Instead of 27.0.0.1:9559

Definition at line 139 of file StorageClient.java.

Here is the call graph for this function:

The documentation for this class was generated from the following file:

client/src/main/java/com/vesoft/nebula/client/storage/StorageClient.java

Public Member Functions

Protected Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ StorageClient() [1/3]

◆ StorageClient() [2/3]

◆ StorageClient() [3/3]

Member Function Documentation

◆ connect()

◆ getConnection()

◆ scanEdge() [1/16]

◆ scanEdge() [2/16]

◆ scanEdge() [3/16]

◆ scanEdge() [4/16]

◆ scanEdge() [5/16]

◆ scanEdge() [6/16]

◆ scanEdge() [7/16]

◆ scanEdge() [8/16]

◆ scanEdge() [9/16]

◆ scanEdge() [10/16]

◆ scanEdge() [11/16]

◆ scanEdge() [12/16]

◆ scanEdge() [13/16]

◆ scanEdge() [14/16]

◆ scanEdge() [15/16]

◆ scanEdge() [16/16]

◆ scanVertex() [1/16]

◆ scanVertex() [2/16]

◆ scanVertex() [3/16]

◆ scanVertex() [4/16]

◆ scanVertex() [5/16]

◆ scanVertex() [6/16]

◆ scanVertex() [7/16]

◆ scanVertex() [8/16]

◆ scanVertex() [9/16]

◆ scanVertex() [10/16]

◆ scanVertex() [11/16]

◆ scanVertex() [12/16]

◆ scanVertex() [13/16]

◆ scanVertex() [14/16]

◆ scanVertex() [15/16]

◆ scanVertex() [16/16]

◆ setStorageAddressMapping()