PyODPS
Installation instructions
Platform instructions
Basic types and operations
DataFrame
Database interfaces
User experience enhancement
Configuration
Create and use third-party libraries
Frequently asked questions
API Reference
PyODPS
Index
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
O
|
P
|
Q
|
R
|
S
|
T
|
U
|
V
|
W
|
Z
A
abort() (odps.tunnel.TableStreamUploadSession method)
(odps.tunnel.TableUpsertSession method)
abort_write_session() (odps.apis.storage_api_v2.StorageApiArrowClient method)
(odps.apis.storage_api_v2.StorageApiClient method)
access_token (odps.apis.storage_api_v2.WriteStreamRequest attribute)
add_columns() (odps.models.Table method)
all() (odps.df.CollectionExpr method)
(odps.df.expr.groupby.GroupBy method)
any() (odps.df.CollectionExpr method)
(odps.df.expr.groupby.GroupBy method)
append_id() (odps.df.CollectionExpr method)
apply() (odps.df.CollectionExpr method)
applymap() (odps.df.CollectionExpr method)
ArchiveResource (class in odps.models)
Array (class in odps.types)
arrow_options (odps.apis.storage_api_v2.CreateReadSessionRequest attribute)
ArrowOptions (class in odps.apis.storage_api_v2)
ArrowOptions.TimestampUnit (class in odps.apis.storage_api_v2)
ArrowReader (class in odps.apis.storage_api_v2)
ArrowWriter (class in odps.apis.storage_api_v2)
(class in odps.tunnel)
as_account() (odps.ODPS method)
ast() (odps.df.CollectionExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
(odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
astype() (odps.df.SequenceExpr method)
B
batch_persist() (odps.df.DataFrame static method)
between() (odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
bfill() (odps.df.CollectionExpr method)
Bigint (class in odps.types)
Binary (class in odps.types)
blob_reference (odps.apis.storage_api_v2.WriteBlobResponse attribute)
blob_references (odps.apis.storage_api_v2.ReadBlobRequest attribute)
(odps.apis.storage_api_v2.WriteBlobResponse attribute)
BlobDataIterator (class in odps.apis.storage_api_v2)
BlobStreamReader (class in odps.apis.storage_api_v2)
BlobStreamWriter (class in odps.apis.storage_api_v2)
BlobWriteItem (class in odps.apis.storage_api_v2)
bloom_filter() (odps.df.CollectionExpr method)
Boolean (class in odps.types)
BufferedArrowWriter (class in odps.tunnel)
BufferedRecordWriter (class in odps.tunnel)
byte_size (odps.apis.storage_api_v2.GetWriteStreamResponse attribute)
C
capitalize() (odps.df.expr.expressions.StringSequenceExpr method)
cat() (odps.df.expr.expressions.StringSequenceExpr method)
change_partition_spec() (odps.models.partition.Partition method)
(odps.models.Table method)
Char (class in odps.types)
ChecksumType (class in odps.apis.storage_api_v2)
close() (odps.apis.storage_api_v2.StreamReader method)
,
[1]
(odps.models.FileResource method)
(odps.tunnel.ArrowWriter method)
(odps.tunnel.BufferedArrowWriter method)
(odps.tunnel.BufferedRecordWriter method)
(odps.tunnel.RecordWriter method)
(odps.tunnel.Upsert method)
close_write_stream() (odps.apis.storage_api_v2.StorageApiArrowClient method)
(odps.apis.storage_api_v2.StorageApiClient method)
CloseWriteStreamRequest (class in odps.apis.storage_api_v2)
CloseWriteStreamResponse (class in odps.apis.storage_api_v2)
CollectionExpr (class in odps.df)
Column (class in odps.apis.storage_api_v2)
(class in odps.types)
column_index (odps.apis.storage_api_v2.WriteBlobRequest attribute)
columns (odps.apis.storage_api_v2.PreviewTableRequest attribute)
(odps.df.CollectionExpr property)
(odps.models.TableSchema property)
comment (odps.models.Table attribute)
commit() (odps.tunnel.TableUploadSession method)
(odps.tunnel.TableUpsertSession method)
commit_write_session() (odps.apis.storage_api_v2.StorageApiArrowClient method)
(odps.apis.storage_api_v2.StorageApiClient method)
compile() (odps.df.CollectionExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
(odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
Compression (class in odps.apis.storage_api_v2)
compression (odps.apis.storage_api_v2.ReadStreamRequest attribute)
(odps.apis.storage_api_v2.WriteStreamRequest attribute)
concat() (odps.df.CollectionExpr method)
(odps.df.SequenceExpr method)
contains() (odps.df.expr.expressions.StringSequenceExpr method)
continuous() (odps.df.CollectionExpr method)
(odps.df.SequenceExpr method)
copy() (odps.models.ml.OfflineModel method)
copy_offline_model() (odps.ODPS method)
count (odps.tunnel.InstanceDownloadSession attribute)
(odps.tunnel.TableDownloadSession attribute)
count() (odps.df.CollectionExpr method)
(odps.df.expr.expressions.StringSequenceExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
(odps.df.SequenceExpr method)
create_download_session() (odps.tunnel.InstanceTunnel method)
(odps.tunnel.TableTunnel method)
create_external_volume() (odps.ODPS method)
create_fs_volume() (odps.ODPS method)
create_function() (odps.ODPS method)
create_parted_volume() (odps.ODPS method)
create_partition() (odps.models.Table method)
create_read_session() (odps.apis.storage_api_v2.StorageApiArrowClient method)
(odps.apis.storage_api_v2.StorageApiClient method)
create_resource() (odps.ODPS method)
create_role() (odps.ODPS method)
create_schema() (odps.ODPS method)
create_stream_upload_session() (odps.tunnel.TableTunnel method)
create_table() (odps.ODPS method)
create_upload_session() (odps.tunnel.TableTunnel method)
create_upsert_session() (odps.tunnel.TableTunnel method)
create_user() (odps.ODPS method)
create_volume_directory() (odps.ODPS method)
create_write_session() (odps.apis.storage_api_v2.StorageApiArrowClient method)
(odps.apis.storage_api_v2.StorageApiClient method)
create_write_stream() (odps.apis.storage_api_v2.StorageApiArrowClient method)
(odps.apis.storage_api_v2.StorageApiClient method)
CreateReadSessionRequest (class in odps.apis.storage_api_v2)
CreateReadSessionResponse (class in odps.apis.storage_api_v2)
CreateWriteSessionRequest (class in odps.apis.storage_api_v2)
CreateWriteSessionResponse (class in odps.apis.storage_api_v2)
CreateWriteStreamRequest (class in odps.apis.storage_api_v2)
CreateWriteStreamResponse (class in odps.apis.storage_api_v2)
creation_time (odps.models.Table attribute)
cumcount() (odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
cume_dist() (odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
cummax() (odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
cummean() (odps.df.expr.groupby.Int64SequenceGroupBy method)
cummedian() (odps.df.expr.groupby.Int64SequenceGroupBy method)
cummin() (odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
cumstd() (odps.df.expr.groupby.Int64SequenceGroupBy method)
cumsum() (odps.df.expr.groupby.Int64SequenceGroupBy method)
cut() (odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
D
data_columns (odps.apis.storage_api_v2.ReadStreamRequest attribute)
data_format (odps.apis.storage_api_v2.ReadStreamRequest attribute)
data_schema (odps.apis.storage_api_v2.CreateReadSessionResponse attribute)
(odps.apis.storage_api_v2.CreateWriteStreamResponse attribute)
DataFormat (class in odps.apis.storage_api_v2)
DataFrame (class in odps.df)
DataSchema (class in odps.apis.storage_api_v2)
Date (class in odps.types)
Datetime (class in odps.types)
Decimal (class in odps.types)
delete() (odps.tunnel.Upsert method)
delete_columns() (odps.models.Table method)
delete_function() (odps.ODPS method)
delete_materialized_view() (odps.ODPS method)
delete_offline_model() (odps.ODPS method)
delete_partition() (odps.models.Table method)
delete_resource() (odps.ODPS method)
delete_role() (odps.ODPS method)
delete_schema() (odps.ODPS method)
delete_table() (odps.ODPS method)
delete_user() (odps.ODPS method)
delete_view() (odps.ODPS method)
delete_volume() (odps.ODPS method)
delete_volume_file() (odps.ODPS method)
delete_volume_partition() (odps.ODPS method)
delete_xflow() (odps.ODPS method)
dense_rank() (odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
discrete() (odps.df.CollectionExpr method)
(odps.df.SequenceExpr method)
distinct() (odps.df.CollectionExpr method)
Double (class in odps.types)
download_id (odps.apis.storage_api_v2.CreateReadSessionResponse attribute)
drop() (odps.df.CollectionExpr method)
(odps.df.SequenceExpr method)
(odps.models.Function method)
(odps.models.partition.Partition method)
(odps.models.Table method)
dropna() (odps.df.CollectionExpr method)
dtype (odps.df.SequenceExpr property)
E
enable_large_string (odps.apis.storage_api_v2.CreateReadSessionResponse attribute)
endswith() (odps.df.expr.expressions.StringSequenceExpr method)
erase_key_value() (odps.df.CollectionExpr method)
(odps.df.SequenceExpr method)
error_code (odps.apis.storage_api_v2.GetWriteStreamResponse attribute)
error_message (odps.apis.storage_api_v2.GetWriteStreamResponse attribute)
exactly_once_mode (odps.apis.storage_api_v2.CreateWriteStreamRequest attribute)
except_() (odps.df.CollectionExpr method)
(odps.df.SequenceExpr method)
exclude() (odps.df.CollectionExpr method)
exclude_fields() (odps.df.CollectionExpr method)
execute() (odps.df.CollectionExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
(odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
execute_archive_table() (odps.ODPS method)
execute_freeze_command() (odps.ODPS method)
execute_merge_files() (odps.ODPS method)
execute_security_query() (odps.ODPS method)
execute_sql() (odps.ODPS method)
execute_sql_cost() (odps.ODPS method)
execute_sql_interactive() (odps.ODPS method)
execute_xflow() (odps.ODPS method)
exist_function() (odps.ODPS method)
exist_instance() (odps.ODPS method)
exist_model() (odps.ODPS method)
exist_offline_model() (odps.ODPS method)
exist_partition() (odps.models.Table method)
exist_partitions() (odps.models.Table method)
exist_project() (odps.ODPS method)
exist_quota() (odps.ODPS method)
exist_resource() (odps.ODPS method)
exist_role() (odps.ODPS method)
exist_schema() (odps.ODPS method)
exist_table() (odps.ODPS method)
exist_user() (odps.ODPS method)
exist_volume() (odps.ODPS method)
exist_volume_partition() (odps.ODPS method)
exist_xflow() (odps.ODPS method)
expiration_time (odps.apis.storage_api_v2.CreateReadSessionResponse attribute)
extract() (odps.df.expr.expressions.StringSequenceExpr method)
extract_kv() (odps.df.CollectionExpr method)
F
ffill() (odps.df.CollectionExpr method)
field_types (odps.types.Struct attribute)
FileResource (class in odps.models)
FileResource.Mode (class in odps.models)
fillna() (odps.df.CollectionExpr method)
(odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
filter() (odps.df.CollectionExpr method)
filter_parts() (odps.df.CollectionExpr method)
filter_predicate (odps.apis.storage_api_v2.CreateReadSessionRequest attribute)
filter_predicate_fallback (odps.apis.storage_api_v2.CreateReadSessionRequest attribute)
find() (odps.df.expr.expressions.StringSequenceExpr method)
finish() (odps.apis.storage_api_v2.ArrowWriter method)
(odps.apis.storage_api_v2.BlobStreamWriter method)
,
[1]
(odps.apis.storage_api_v2.StreamWriter method)
flags (odps.apis.storage_api_v2.CreateWriteSessionRequest attribute)
Float (class in odps.types)
flush() (odps.models.FileResource method)
(odps.tunnel.Upsert method)
from_lists() (odps.models.TableSchema class method)
Function (class in odps.models)
G
get() (odps.df.expr.expressions.StringSequenceExpr method)
get_blocks_written() (odps.tunnel.BufferedArrowWriter method)
(odps.tunnel.BufferedRecordWriter method)
get_ddl() (odps.models.Table method)
get_function() (odps.ODPS method)
get_instance() (odps.ODPS method)
get_log() (odps.models.Worker method)
get_logview_address() (odps.models.Instance method)
(odps.ODPS method)
get_logview_host() (odps.ODPS method)
get_max_partition() (odps.models.Table method)
get_model() (odps.models.ml.OfflineModel method)
(odps.ODPS method)
get_offline_model() (odps.ODPS method)
get_partition() (odps.models.Table method)
get_project() (odps.ODPS method)
get_project_policy() (odps.ODPS method)
get_quota() (odps.ODPS method)
get_read_session() (odps.apis.storage_api_v2.StorageApiArrowClient method)
(odps.apis.storage_api_v2.StorageApiClient method)
get_request_id() (odps.apis.storage_api_v2.BlobStreamWriter method)
(odps.apis.storage_api_v2.StreamReader method)
(odps.apis.storage_api_v2.StreamWriter method)
get_resource() (odps.ODPS method)
get_role_policy() (odps.ODPS method)
get_route_token() (odps.apis.storage_api_v2.StreamWriter method)
get_schema() (odps.ODPS method)
get_security_option() (odps.ODPS method)
get_security_options() (odps.ODPS method)
get_sql_task_cost() (odps.models.Instance method)
get_status() (odps.apis.storage_api_v2.BlobStreamWriter method)
(odps.apis.storage_api_v2.StreamReader method)
(odps.apis.storage_api_v2.StreamWriter method)
get_table() (odps.ODPS method)
get_task_cost() (odps.models.Instance method)
get_task_detail() (odps.models.Instance method)
get_task_detail2() (odps.models.Instance method)
get_task_info() (odps.models.Instance method)
get_task_names() (odps.models.Instance method)
get_task_progress() (odps.models.Instance method)
get_task_quota() (odps.models.Instance method)
get_task_result() (odps.models.Instance method)
get_task_results() (odps.models.Instance method)
get_task_statuses() (odps.models.Instance method)
get_task_summary() (odps.models.Instance method)
get_task_workers() (odps.models.Instance method)
get_volume() (odps.ODPS method)
get_volume_file() (odps.ODPS method)
get_volume_partition() (odps.ODPS method)
get_worker_log() (odps.models.Instance method)
get_write_session() (odps.apis.storage_api_v2.StorageApiArrowClient method)
(odps.apis.storage_api_v2.StorageApiClient method)
get_write_stream() (odps.apis.storage_api_v2.StorageApiArrowClient method)
(odps.apis.storage_api_v2.StorageApiClient method)
get_write_stream_response() (odps.apis.storage_api_v2.ArrowWriter method)
(odps.apis.storage_api_v2.StreamWriter method)
,
[1]
get_xflow() (odps.ODPS method)
get_xflow_results() (odps.ODPS method)
get_xflow_sub_instances() (odps.ODPS method)
GetWriteSessionResponse (class in odps.apis.storage_api_v2)
GetWriteStreamResponse (class in odps.apis.storage_api_v2)
GroupBy (class in odps.df.expr.groupby)
groupby() (odps.df.CollectionExpr method)
H
hash() (odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
head() (odps.df.CollectionExpr method)
(odps.df.SequenceExpr method)
(odps.models.partition.Partition method)
(odps.models.Table method)
hll_count() (odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
(odps.df.SequenceExpr method)
I
id (odps.tunnel.InstanceDownloadSession attribute)
(odps.tunnel.TableDownloadSession attribute)
(odps.tunnel.TableStreamUploadSession attribute)
(odps.tunnel.TableUploadSession attribute)
(odps.tunnel.TableUpsertSession attribute)
incremental_read (odps.apis.storage_api_v2.CreateReadSessionRequest attribute)
incremental_read_options (odps.apis.storage_api_v2.CreateReadSessionRequest attribute)
(odps.apis.storage_api_v2.CreateReadSessionResponse attribute)
IncrementalReadOptions (class in odps.apis.storage_api_v2)
inner_join() (odps.df.CollectionExpr method)
(odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
Instance (class in odps.models)
Instance.DownloadSessionCreationError
Instance.Status (class in odps.models)
Instance.Task (class in odps.models)
Instance.Task.TaskProgress (class in odps.models)
Instance.Task.TaskStatus (class in odps.models)
Instance.TaskSummary (class in odps.models)
InstanceDownloadSession (class in odps.tunnel)
InstanceTunnel (class in odps.tunnel)
Int (class in odps.types)
Int64SequenceExpr (class in odps.df.expr.expressions)
Int64SequenceGroupBy (class in odps.df.expr.groupby)
intersect() (odps.df.CollectionExpr method)
(odps.df.SequenceExpr method)
is_running() (odps.models.Instance method)
is_successful() (odps.models.Instance method)
is_terminated() (odps.models.Instance method)
isalnum() (odps.df.expr.expressions.StringSequenceExpr method)
isalpha() (odps.df.expr.expressions.StringSequenceExpr method)
isdecimal() (odps.df.expr.expressions.StringSequenceExpr method)
isdigit() (odps.df.expr.expressions.StringSequenceExpr method)
isin() (odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
islower() (odps.df.expr.expressions.StringSequenceExpr method)
isna() (odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
isnull() (odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
isnumeric() (odps.df.expr.expressions.StringSequenceExpr method)
isspace() (odps.df.expr.expressions.StringSequenceExpr method)
istitle() (odps.df.expr.expressions.StringSequenceExpr method)
isupper() (odps.df.expr.expressions.StringSequenceExpr method)
iter_pandas() (odps.models.Instance method)
(odps.models.partition.Partition method)
(odps.models.Table method)
iter_xflow_sub_instances() (odps.ODPS method)
iterate_partitions() (odps.models.Table method)
J
JarResource (class in odps.models)
join() (odps.df.CollectionExpr method)
(odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
Json (class in odps.types)
K
key_type (odps.types.Map attribute)
key_value() (odps.df.CollectionExpr method)
(odps.df.SequenceExpr method)
kurt() (odps.df.CollectionExpr method)
(odps.df.expr.expressions.Int64SequenceExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
kurtosis() (odps.df.CollectionExpr method)
(odps.df.expr.expressions.Int64SequenceExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
L
label_field() (odps.df.CollectionExpr method)
lag() (odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
last_data_modified_time (odps.models.Table attribute)
latest_version (odps.apis.storage_api_v2.CreateReadSessionResponse attribute)
lead() (odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
left_join() (odps.df.CollectionExpr method)
(odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
len() (odps.df.expr.expressions.StringSequenceExpr method)
lifecycle (odps.models.Table attribute)
limit (odps.apis.storage_api_v2.PreviewTableRequest attribute)
limit() (odps.df.CollectionExpr method)
list_functions() (odps.ODPS method)
list_instance_queueing_infos() (odps.ODPS method)
list_instances() (odps.ODPS method)
list_models() (odps.ODPS method)
list_offline_models() (odps.ODPS method)
list_projects() (odps.ODPS method)
list_quotas() (odps.ODPS method)
list_resources() (odps.ODPS method)
list_role_users() (odps.ODPS method)
list_roles() (odps.ODPS method)
list_schemas() (odps.ODPS method)
list_tables() (odps.ODPS method)
list_tables_model() (odps.ODPS method)
list_user_roles() (odps.ODPS method)
list_users() (odps.ODPS method)
list_volume_files() (odps.ODPS method)
list_volume_partitions() (odps.ODPS method)
list_volumes() (odps.ODPS method)
list_xflows() (odps.ODPS method)
ljust() (odps.df.expr.expressions.StringSequenceExpr method)
lower() (odps.df.expr.expressions.StringSequenceExpr method)
lstrip() (odps.df.expr.expressions.StringSequenceExpr method)
LZ4_FRAME (odps.apis.storage_api_v2.Compression attribute)
M
Map (class in odps.types)
map() (odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
map_reduce() (odps.df.CollectionExpr method)
max() (odps.df.CollectionExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
(odps.df.SequenceExpr method)
max_batch_raw_size (odps.apis.storage_api_v2.ReadStreamRequest attribute)
max_batch_rows (odps.apis.storage_api_v2.ReadStreamRequest attribute)
mean() (odps.df.CollectionExpr method)
(odps.df.expr.expressions.Int64SequenceExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
median() (odps.df.CollectionExpr method)
(odps.df.expr.expressions.Int64SequenceExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
melt() (odps.df.CollectionExpr method)
message (odps.apis.storage_api_v2.CreateReadSessionResponse attribute)
mime_type (odps.apis.storage_api_v2.BlobStreamReader property)
min() (odps.df.CollectionExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
(odps.df.SequenceExpr method)
min_max_scale() (odps.df.CollectionExpr method)
min_rank() (odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
moment() (odps.df.CollectionExpr method)
(odps.df.expr.expressions.Int64SequenceExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
move_volume_file() (odps.ODPS method)
N
name (odps.models.Table attribute)
(odps.types.Column attribute)
(odps.types.Partition attribute)
new_record() (odps.models.Table method)
(odps.tunnel.TableStreamUploadSession method)
(odps.tunnel.TableUploadSession method)
(odps.tunnel.TableUpsertSession method)
next() (odps.apis.storage_api_v2.BlobStreamReader method)
notin() (odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
notna() (odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
notnull() (odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
nth_value() (odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
nullable (odps.types.Column attribute)
(odps.types.Partition attribute)
NullScalar() (in module odps.df)
nunique() (odps.df.CollectionExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
(odps.df.SequenceExpr method)
O
ODPS (class in odps)
OfflineModel (class in odps.models.ml)
open() (odps.models.FileResource method)
open_arrow_reader() (odps.tunnel.InstanceDownloadSession method)
(odps.tunnel.TableDownloadSession method)
open_arrow_writer() (odps.tunnel.TableUploadSession method)
open_preview_reader() (odps.tunnel.TableTunnel method)
open_reader() (odps.models.Instance method)
(odps.models.partition.Partition method)
(odps.models.Table method)
(odps.models.TableResource method)
open_record_reader() (odps.tunnel.InstanceDownloadSession method)
(odps.tunnel.TableDownloadSession method)
open_record_writer() (odps.tunnel.TableStreamUploadSession method)
(odps.tunnel.TableUploadSession method)
open_resource() (odps.ODPS method)
open_upsert_stream() (odps.tunnel.TableUpsertSession method)
open_volume_reader() (odps.ODPS method)
open_volume_writer() (odps.ODPS method)
open_writer() (odps.models.Table method)
(odps.models.TableResource method)
outer_join() (odps.df.CollectionExpr method)
(odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
owner (odps.models.Table attribute)
P
pad() (odps.df.expr.expressions.StringSequenceExpr method)
partial_partition_spec (odps.apis.storage_api_v2.CreateWriteSessionRequest attribute)
Partition (class in odps.models.partition)
(class in odps.types)
partition (odps.apis.storage_api_v2.PreviewTableRequest attribute)
(odps.models.TableResource property)
partition_values (odps.apis.storage_api_v2.WriteBlobRequest attribute)
partitions (odps.models.TableSchema property)
percent_rank() (odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
persist() (odps.df.CollectionExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
(odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
pivot() (odps.df.CollectionExpr method)
pivot_table() (odps.df.CollectionExpr method)
precision (odps.types.Decimal attribute)
preview_table() (odps.apis.storage_api_v2.StorageApiArrowClient method)
(odps.apis.storage_api_v2.StorageApiClient method)
preview_table_arrow() (odps.apis.storage_api_v2.StorageApiArrowClient method)
PreviewTableRequest (class in odps.apis.storage_api_v2)
Project (class in odps.models)
Project.AuthQueryStatus (class in odps.models)
Project.ProjectStatus (class in odps.models)
Project.ProjectType (class in odps.models)
put_task_info() (odps.models.Instance method)
PyResource (class in odps.models)
Q
qcut() (odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
quantile() (odps.df.CollectionExpr method)
(odps.df.expr.expressions.Int64SequenceExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
query() (odps.df.CollectionExpr method)
R
RandomScalar (class in odps.df)
rank() (odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
read() (odps.apis.storage_api_v2.ArrowReader method)
(odps.apis.storage_api_v2.BlobStreamReader method)
(odps.apis.storage_api_v2.StreamReader method)
(odps.models.FileResource method)
(odps.tunnel.TunnelArrowReader method)
(odps.tunnel.TunnelRecordReader method)
read_blobs() (odps.apis.storage_api_v2.StorageApiArrowClient method)
(odps.apis.storage_api_v2.StorageApiClient method)
read_data() (odps.apis.storage_api_v2.BlobDataIterator method)
read_next_batch() (odps.tunnel.TunnelArrowReader method)
read_rows_arrow() (odps.apis.storage_api_v2.StorageApiArrowClient method)
read_rows_stream() (odps.apis.storage_api_v2.StorageApiArrowClient method)
(odps.apis.storage_api_v2.StorageApiClient method)
read_table() (odps.ODPS method)
readable() (odps.apis.storage_api_v2.StreamReader method)
,
[1]
ReadBlobRequest (class in odps.apis.storage_api_v2)
readline() (odps.models.FileResource method)
readlines() (odps.models.FileResource method)
ReadStreamRequest (class in odps.apis.storage_api_v2)
Record (class in odps.models)
record_count (odps.apis.storage_api_v2.CreateReadSessionResponse attribute)
(odps.apis.storage_api_v2.GetWriteStreamResponse attribute)
(odps.apis.storage_api_v2.WriteStreamRequest attribute)
RecordWriter (class in odps.tunnel)
rename() (odps.models.Table method)
rename_column() (odps.models.Table method)
repeat() (odps.df.expr.expressions.StringSequenceExpr method)
replace() (odps.df.expr.expressions.StringSequenceExpr method)
request_id (odps.apis.storage_api_v2.CloseWriteStreamResponse attribute)
(odps.apis.storage_api_v2.CreateReadSessionResponse attribute)
(odps.apis.storage_api_v2.CreateWriteSessionResponse attribute)
(odps.apis.storage_api_v2.CreateWriteStreamResponse attribute)
(odps.apis.storage_api_v2.GetWriteSessionResponse attribute)
(odps.apis.storage_api_v2.GetWriteStreamResponse attribute)
(odps.apis.storage_api_v2.WriteBlobResponse attribute)
required_bucket_ids (odps.apis.storage_api_v2.CreateReadSessionRequest attribute)
required_data_columns (odps.apis.storage_api_v2.CreateReadSessionRequest attribute)
required_partition_columns (odps.apis.storage_api_v2.CreateReadSessionRequest attribute)
required_partitions (odps.apis.storage_api_v2.CreateReadSessionRequest attribute)
reshuffle() (odps.df.CollectionExpr method)
Resource (class in odps.models)
Resource.Type (class in odps.models)
resources (odps.models.Function property)
rfind() (odps.df.expr.expressions.StringSequenceExpr method)
right_join() (odps.df.CollectionExpr method)
(odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
rjust() (odps.df.expr.expressions.StringSequenceExpr method)
role() (odps.df.SequenceExpr method)
roles() (odps.df.CollectionExpr method)
route_token (odps.apis.storage_api_v2.CreateWriteSessionResponse attribute)
(odps.apis.storage_api_v2.CreateWriteStreamResponse attribute)
(odps.apis.storage_api_v2.GetWriteSessionResponse attribute)
(odps.apis.storage_api_v2.StorageApiArrowClient property)
(odps.apis.storage_api_v2.StorageApiClient property)
row_count (odps.apis.storage_api_v2.ReadStreamRequest attribute)
row_number() (odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
row_offset (odps.apis.storage_api_v2.ReadStreamRequest attribute)
(odps.apis.storage_api_v2.WriteStreamRequest attribute)
rstrip() (odps.df.expr.expressions.StringSequenceExpr method)
run_archive_table() (odps.ODPS method)
run_freeze_command() (odps.ODPS method)
run_merge_files() (odps.ODPS method)
run_security_query() (odps.ODPS method)
run_sql() (odps.ODPS method)
run_sql_interactive() (odps.ODPS method)
run_xflow() (odps.ODPS method)
S
sample() (odps.df.CollectionExpr method)
Scalar (class in odps.df)
scale (odps.types.Decimal attribute)
schema (odps.ODPS property)
(odps.tunnel.InstanceDownloadSession attribute)
(odps.tunnel.TableDownloadSession attribute)
schema_version (odps.apis.storage_api_v2.CreateWriteStreamResponse attribute)
seek() (odps.models.FileResource method)
select() (odps.df.CollectionExpr method)
select_features() (odps.df.CollectionExpr method)
SequenceExpr (class in odps.df)
SequenceGroupBy (class in odps.df.expr.groupby)
serialize() (odps.apis.storage_api_v2.BlobWriteItem method)
session_id (odps.apis.storage_api_v2.CloseWriteStreamRequest attribute)
(odps.apis.storage_api_v2.CreateReadSessionResponse attribute)
(odps.apis.storage_api_v2.CreateWriteSessionResponse attribute)
(odps.apis.storage_api_v2.CreateWriteStreamRequest attribute)
(odps.apis.storage_api_v2.ReadStreamRequest attribute)
(odps.apis.storage_api_v2.WriteBlobRequest attribute)
(odps.apis.storage_api_v2.WriteStreamRequest attribute)
session_stats (odps.apis.storage_api_v2.CreateReadSessionResponse attribute)
session_status (odps.apis.storage_api_v2.CreateReadSessionResponse attribute)
session_type (odps.apis.storage_api_v2.CreateReadSessionResponse attribute)
SessionStats (class in odps.apis.storage_api_v2)
SessionStatus (class in odps.apis.storage_api_v2)
set_cluster_info() (odps.models.Table method)
set_comment() (odps.models.Table method)
set_lifecycle() (odps.models.Table method)
set_owner() (odps.models.Table method)
set_project_policy() (odps.ODPS method)
set_role_policy() (odps.ODPS method)
set_security_option() (odps.ODPS method)
set_storage_tier() (odps.models.partition.Partition method)
(odps.models.Table method)
setdiff() (odps.df.CollectionExpr method)
(odps.df.SequenceExpr method)
simple_columns (odps.models.TableSchema property)
size (odps.apis.storage_api_v2.WriteBlobResponse attribute)
(odps.models.Table attribute)
size() (odps.df.CollectionExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
(odps.df.SequenceExpr method)
size_limit (odps.types.Char attribute)
(odps.types.Varchar attribute)
skew() (odps.df.CollectionExpr method)
(odps.df.expr.expressions.Int64SequenceExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
skip_remaining_data_and_footer() (odps.apis.storage_api_v2.BlobDataIterator method)
skip_row_num (odps.apis.storage_api_v2.ReadStreamRequest attribute)
slice() (odps.df.expr.expressions.StringSequenceExpr method)
Smallint (class in odps.types)
sort() (odps.df.CollectionExpr method)
sort_values() (odps.df.CollectionExpr method)
split() (odps.df.CollectionExpr method)
(odps.df.expr.expressions.StringSequenceExpr method)
split_bucket_id (odps.apis.storage_api_v2.CreateReadSessionResponse attribute)
split_index (odps.apis.storage_api_v2.ReadStreamRequest attribute)
split_max_file_num (odps.apis.storage_api_v2.CreateReadSessionRequest attribute)
split_mode (odps.apis.storage_api_v2.CreateReadSessionResponse attribute)
split_options (odps.apis.storage_api_v2.CreateReadSessionRequest attribute)
SplitOptions (class in odps.apis.storage_api_v2)
SplitOptions.SplitMode (class in odps.apis.storage_api_v2)
splits_count (odps.apis.storage_api_v2.CreateReadSessionResponse attribute)
startswith() (odps.df.expr.expressions.StringSequenceExpr method)
Status (class in odps.apis.storage_api_v2)
status (odps.apis.storage_api_v2.CreateReadSessionResponse attribute)
(odps.apis.storage_api_v2.GetWriteStreamResponse attribute)
std() (odps.df.CollectionExpr method)
(odps.df.expr.expressions.Int64SequenceExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
std_scale() (odps.df.CollectionExpr method)
stop() (odps.models.Instance method)
stop_instance() (odps.ODPS method)
stop_job() (odps.ODPS method)
StorageApiArrowClient (class in odps.apis.storage_api_v2)
StorageApiClient (class in odps.apis.storage_api_v2)
stream_id (odps.apis.storage_api_v2.CloseWriteStreamRequest attribute)
(odps.apis.storage_api_v2.CreateWriteStreamRequest attribute)
(odps.apis.storage_api_v2.WriteBlobRequest attribute)
(odps.apis.storage_api_v2.WriteStreamRequest attribute)
stream_version (odps.apis.storage_api_v2.CloseWriteStreamRequest attribute)
(odps.apis.storage_api_v2.CreateWriteStreamRequest attribute)
(odps.apis.storage_api_v2.WriteBlobRequest attribute)
(odps.apis.storage_api_v2.WriteStreamRequest attribute)
StreamReader (class in odps.apis.storage_api_v2)
streams (odps.apis.storage_api_v2.GetWriteSessionResponse attribute)
StreamWriter (class in odps.apis.storage_api_v2)
String (class in odps.types)
StringSequenceExpr (class in odps.df.expr.expressions)
strip() (odps.df.expr.expressions.StringSequenceExpr method)
strptime() (odps.df.expr.expressions.StringSequenceExpr method)
Struct (class in odps.types)
sum() (odps.df.CollectionExpr method)
(odps.df.expr.expressions.Int64SequenceExpr method)
(odps.df.expr.expressions.StringSequenceExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
supported_data_format (odps.apis.storage_api_v2.CreateReadSessionResponse attribute)
swapcase() (odps.df.expr.expressions.StringSequenceExpr method)
switch() (odps.df.CollectionExpr method)
(odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
T
Table (class in odps.models)
table (odps.models.TableResource property)
Table.Type (class in odps.models)
table_id (odps.apis.storage_api_v2.CreateWriteStreamResponse attribute)
table_schema (odps.models.Table attribute)
TableDownloadSession (class in odps.tunnel)
TableResource (class in odps.models)
TableSchema (class in odps.models)
TableStreamUploadSession (class in odps.tunnel)
TableTunnel (class in odps.tunnel)
TableUploadSession (class in odps.tunnel)
TableUpsertSession (class in odps.tunnel)
tail() (odps.df.CollectionExpr method)
(odps.df.SequenceExpr method)
tell() (odps.models.FileResource method)
Timestamp (class in odps.types)
TimestampNTZ (class in odps.types)
Tinyint (class in odps.types)
title() (odps.df.expr.expressions.StringSequenceExpr method)
to_datetime() (odps.df.expr.expressions.Int64SequenceExpr method)
to_df() (odps.models.partition.Partition method)
(odps.models.Table method)
to_kv() (odps.df.CollectionExpr method)
to_pandas() (odps.df.CollectionExpr method)
(odps.df.SequenceExpr method)
(odps.models.Instance method)
(odps.models.partition.Partition method)
(odps.models.Table method)
(odps.tunnel.TunnelArrowReader method)
todict() (odps.df.expr.expressions.StringSequenceExpr method)
tolist() (odps.df.CollectionExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
(odps.df.SequenceExpr method)
touch() (odps.models.partition.Partition method)
(odps.models.Table method)
truncate() (odps.models.FileResource method)
(odps.models.partition.Partition method)
(odps.models.Table method)
tunnel_endpoint (odps.ODPS property)
TunnelArrowReader (class in odps.tunnel)
TunnelRecordReader (class in odps.tunnel)
type (odps.models.Table attribute)
(odps.types.Column attribute)
(odps.types.Partition attribute)
U
UNCOMPRESSED (odps.apis.storage_api_v2.Compression attribute)
union() (odps.df.CollectionExpr method)
(odps.df.SequenceExpr method)
update() (odps.models.Function method)
(odps.models.TableResource method)
upper() (odps.df.expr.expressions.StringSequenceExpr method)
Upsert (class in odps.tunnel)
upsert() (odps.tunnel.Upsert method)
User (class in odps.models.security)
V
validate_data_type() (in module odps.types)
value_counts() (odps.df.SequenceExpr method)
value_type (odps.types.Array attribute)
(odps.types.Map attribute)
var() (odps.df.CollectionExpr method)
(odps.df.expr.expressions.Int64SequenceExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
Varchar (class in odps.types)
verify() (odps.df.CollectionExpr method)
(odps.df.expr.groupby.GroupBy method)
(odps.df.expr.groupby.Int64SequenceGroupBy method)
(odps.df.expr.groupby.SequenceGroupBy method)
(odps.df.RandomScalar method)
(odps.df.Scalar method)
(odps.df.SequenceExpr method)
view() (odps.df.CollectionExpr method)
(odps.df.DataFrame method)
VolumeDownloadSession (class in odps.tunnel)
VolumeTunnel (class in odps.tunnel)
VolumeUploadSession (class in odps.tunnel)
W
wait_for_completion() (odps.models.Instance method)
wait_for_success() (odps.models.Instance method)
warning_message (odps.apis.storage_api_v2.CloseWriteStreamResponse attribute)
(odps.apis.storage_api_v2.CreateWriteSessionResponse attribute)
(odps.apis.storage_api_v2.GetWriteSessionResponse attribute)
(odps.apis.storage_api_v2.WriteBlobResponse attribute)
weight_field() (odps.df.CollectionExpr method)
Worker (class in odps.models)
writable() (odps.apis.storage_api_v2.BlobStreamWriter method)
,
[1]
(odps.apis.storage_api_v2.StreamWriter method)
,
[1]
write() (odps.apis.storage_api_v2.ArrowWriter method)
(odps.apis.storage_api_v2.BlobStreamWriter method)
(odps.apis.storage_api_v2.StreamWriter method)
(odps.models.FileResource method)
(odps.tunnel.ArrowWriter method)
(odps.tunnel.BufferedArrowWriter method)
(odps.tunnel.BufferedRecordWriter method)
(odps.tunnel.RecordWriter method)
write_blob_batch() (odps.apis.storage_api_v2.StorageApiArrowClient method)
(odps.apis.storage_api_v2.StorageApiClient method)
write_blob_stream() (odps.apis.storage_api_v2.StorageApiArrowClient method)
(odps.apis.storage_api_v2.StorageApiClient method)
write_blobs() (odps.apis.storage_api_v2.BlobWriteItem static method)
write_frame_to() (odps.apis.storage_api_v2.BlobWriteItem method)
write_rows_arrow() (odps.apis.storage_api_v2.StorageApiArrowClient method)
write_rows_stream() (odps.apis.storage_api_v2.StorageApiArrowClient method)
(odps.apis.storage_api_v2.StorageApiClient method)
write_sql_result_to_table() (odps.ODPS method)
write_table() (odps.ODPS method)
WriteBlobRequest (class in odps.apis.storage_api_v2)
WriteBlobResponse (class in odps.apis.storage_api_v2)
writelines() (odps.models.FileResource method)
WriteStreamRequest (class in odps.apis.storage_api_v2)
Z
zfill() (odps.df.expr.expressions.StringSequenceExpr method)
ZSTD (odps.apis.storage_api_v2.Compression attribute)