maxframe.dataframe.read_odps_query#

maxframe.dataframe.read_odps_query(query: str, odps_entry: ODPS = None, index_col: None | str | List[str] = None, string_as_binary: bool = None, sql_hints: Dict[str, str] = None, anonymous_col_prefix: str = '_anon_col_', skip_schema: bool = False, dtype_backend: str = None, **kw)[源代码]#

从 MaxCompute (ODPS) 查询中读取数据到 DataFrame。

支持将某些列指定为索引。如果未指定，将生成 RangeIndex。

参数:

  • query (str) -- MaxCompute SQL 语句。

  • index_col (Union[None, str, List[str]]) -- 指定为索引的列。

  • string_as_binary (bool, optional) -- 是否将字符串列转换为二进制。

  • sql_hints (Dict[str, str], optional) -- 用户指定的 SQL 提示。

  • anonymous_col_prefix (str, optional) -- 匿名列的前缀，默认为 '_anon_col_'。

  • skip_schema (bool, optional) -- 跳过执行前解析输出模式。一旦配置了此选项，输出 DataFrame 在执行前不能作为其他 DataFrame 运算符的输入。

  • dtype_backend ({'numpy', 'pyarrow'}, default 'numpy') -- 应用于结果 DataFrame 的后端数据类型（仍处于实验阶段）。

返回:

result -- 从 MaxCompute (ODPS) 表中读取的 DataFrame

返回类型:

DataFrame