pyarrow.flight.FlightEndpoint#

class pyarrow.flight.FlightEndpoint(ticket, locations, expiration_time=None, app_metadata='')#

基类: _Weakrefable

一个 Flight 流,以及用于访问它的票据和位置。

__init__()#

从票据和位置列表创建 FlightEndpoint。

参数:
ticketTicketbytes

访问此 flight 所需的票据

locationslist of str URIs

此 flight 可用的位置

expiration_timeTimestampScalar, 默认值 None

此流的过期时间。如果存在,客户端可以假定他们可以重试 DoGet 请求。否则,客户端应避免重试 DoGet 请求。

app_metadatabytesstr, 默认值 “”

应用程序定义的不透明元数据。

引发:
ArrowException

如果其中一个位置 URI 不是有效的 URI。

方法

__init__

从票据和位置列表创建 FlightEndpoint。

deserialize(cls, serialized)

解析此类型的在线传输格式表示。

serialize(self)

获取此类型的在线传输格式表示。

属性

app_metadata

获取应用程序定义的 opaque 元数据。

expiration_time

获取此流的过期时间。

locations

获取此 flight 可用的位置。

ticket

获取此端点中的票据。

app_metadata#

获取应用程序定义的 opaque 元数据。

classmethod deserialize(cls, serialized)#

解析此类型的在线传输格式表示。

在与可能需要返回 Flight 类型的非 Flight 系统(例如 REST 服务)互操作时很有用。

expiration_time#

获取此流的过期时间。

如果存在,客户端可以假定他们可以重试 DoGet 请求。否则,客户端应避免重试 DoGet 请求。

locations#

获取此 flight 可用的位置。

serialize(self)#

获取此类型的在线传输格式表示。

在与可能需要返回 Flight 类型的非 Flight 系统(例如 REST 服务)互操作时很有用。

ticket#

获取此端点中的票据。