GraphStorageClient Class Reference

Inheritance diagram for GraphStorageClient:

Collaboration diagram for GraphStorageClient:

Public Member Functions
def	__init__ (self, meta_cache, storage_addrs=None, time_out=60000)
def	get_conns (self)
def	__del__ (self)
def	close (self)
def	get_space_addrs (self, space_name)
def	scan_vertex (self, space_name, tag_name, prop_names=[], limit=DEFAULT_LIMIT, start_time=DEFAULT_START_TIME, end_time=DEFAULT_END_TIME, where=None, only_latest_version=False, enable_read_from_follower=True, partial_success=False)
def	scan_vertex_with_part (self, space_name, part, tag_name, prop_names=[], limit=DEFAULT_LIMIT, start_time=DEFAULT_START_TIME, end_time=DEFAULT_END_TIME, where=None, only_latest_version=False, enable_read_from_follower=True, partial_success=False)
def	scan_edge (self, space_name, edge_name, prop_names=[], limit=DEFAULT_LIMIT, start_time=DEFAULT_START_TIME, end_time=DEFAULT_END_TIME, where=None, only_latest_version=False, enable_read_from_follower=True, partial_success=False)
def	scan_edge_with_part (self, space_name, part, edge_name, prop_names=[], limit=DEFAULT_LIMIT, start_time=DEFAULT_START_TIME, end_time=DEFAULT_END_TIME, where=None, only_latest_version=False, enable_read_from_follower=True, partial_success=False)

Static Public Attributes
int	DEFAULT_START_TIME = 0
	DEFAULT_END_TIME = sys.maxsize
int	DEFAULT_LIMIT = 1000

Detailed Description

Definition at line 33 of file GraphStorageClient.py.

Member Function Documentation

close()

def close

(

self

)

close the GraphStorageClient

:return:

Definition at line 55 of file GraphStorageClient.py.

Here is the caller graph for this function:

get_conns()

def get_conns

(

self

)

get all connections which connect to storaged, the ScanResult use it

:return: list<GraphStorageConnection>

Definition at line 45 of file GraphStorageClient.py.

Here is the call graph for this function:

get_space_addrs()

def get_space_addrs	(		self,
			space_name
	)

get all storage addresses that manage space

:param space_name: the specified space name
:return: list<(ip, port)>

Definition at line 85 of file GraphStorageClient.py.

scan_edge()

def scan_edge	(		self,
			space_name,
			edge_name,
			prop_names = [],
			limit = DEFAULT_LIMIT,
			start_time = DEFAULT_START_TIME,
			end_time = DEFAULT_END_TIME,
			where = None,
			only_latest_version = False,
			enable_read_from_follower = True,
			partial_success = False
	)

scan edge with the specified space_name, edge_name,
if the prop_names is empty, will return all properties of the edge

:param prop_names: if given empty, return all property
:param edge_name: the edge name
:param space_name: the space name
:param limit: the max vertex number from one storaged
:param start_time: the min version of vertex
:param end_time: the max version of vertex
:param where: now is unsupported
:param only_latest_version: when storage enable multi versions and only_latest_version is true,
only return latest version.
when storage disable multi versions, just use the default value.
:param enable_read_from_follower: if set to false, forbid follower read
:param partial_success: if set true, when partial success, it will continue until finish
:return: ScanResult

Definition at line 236 of file GraphStorageClient.py.

Here is the call graph for this function:

scan_edge_with_part()

def scan_edge_with_part	(		self,
			space_name,
			part,
			edge_name,
			prop_names = [],
			limit = DEFAULT_LIMIT,
			start_time = DEFAULT_START_TIME,
			end_time = DEFAULT_END_TIME,
			where = None,
			only_latest_version = False,
			enable_read_from_follower = True,
			partial_success = False
	)

scan edge with the specified space_name, partId, edge_name,
if the prop_names is empty, will return all properties of the edge

:param space_name: the space name
:param part: the partition num of the given space
:type prop_names: if given empty, return all property
:param edge_name: the edge name
:param limit: the max vertex number from one storaged
:param start_time: the min version of edge
:param end_time: the max version of edge
:param where: now is unsupported
:param only_latest_version: when storage enable multi versions and only_latest_version is true,
only return latest version.
when storage disable multi versions, just use the default value.
:param enable_read_from_follower: if set to false, forbid follower read
:param partial_success: if set true, when partial success, it will continue until finish
:return: ScanResult

Definition at line 281 of file GraphStorageClient.py.

Here is the call graph for this function:

scan_vertex()

def scan_vertex	(		self,
			space_name,
			tag_name,
			prop_names = [],
			limit = DEFAULT_LIMIT,
			start_time = DEFAULT_START_TIME,
			end_time = DEFAULT_END_TIME,
			where = None,
			only_latest_version = False,
			enable_read_from_follower = True,
			partial_success = False
	)

scan vertex with the specified space_name, tag_name,
if the prop_names is empty, will return all properties of the tag

:param prop_names: if given empty, return all property
:param tag_name: the tag name
:param space_name: the space name
:param limit: the max vertex number from one storaged
:param start_time: the min version of vertex
:param end_time: the max version of vertex
:param where: now is unsupported
:param only_latest_version: when storage enable multi versions and only_latest_version is true,
only return latest version.
when storage disable multi versions, just use the default value.
:param enable_read_from_follower: if set to false, forbid follower read
:param partial_success: if set true, when partial success, it will continue until finish
:return: ScanResult

Definition at line 93 of file GraphStorageClient.py.

Here is the call graph for this function:

scan_vertex_with_part()

def scan_vertex_with_part	(		self,
			space_name,
			part,
			tag_name,
			prop_names = [],
			limit = DEFAULT_LIMIT,
			start_time = DEFAULT_START_TIME,
			end_time = DEFAULT_END_TIME,
			where = None,
			only_latest_version = False,
			enable_read_from_follower = True,
			partial_success = False
	)

scan vertex with the specified space_name, partId, tag_name,
if the prop_names is empty, will return all properties of the tag

:param prop_names: if given empty, return all property
:param tag_name: the tag name
:type part: part id
:param space_name: the space name
:param limit: the max vertex number from one storaged
:param start_time: the min version of vertex
:param end_time: the max version of vertex
:param where: now is unsupported
:param only_latest_version: when storage enable multi versions and only_latest_version is true,
only return latest version.
when storage disable multi versions, just use the default value.
:param enable_read_from_follower: if set to false, forbid follower read
:param partial_success: if set true, when partial success, it will continue until finish
:return: ScanResult

Definition at line 138 of file GraphStorageClient.py.

Here is the call graph for this function:

---

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

• nebula3/sclient/GraphStorageClient.py