tiled.client.dataframe.DaskDataFrameClient

class tiled.client.dataframe.DaskDataFrameClient(context, *, item, structure_clients, structure=None, include_data_sources=False)[source]

Client-side wrapper around an dataframe-like that returns dask dataframes

__init__(context, *, item, structure_clients, structure=None, include_data_sources=False)

Methods

__init__(context, *, item, structure_clients)

append_partition(dataframe, partition)

asset_manifest(data_sources)

Return a manifest of the relative paths of the contents in each asset.

compute()

Alias to client.read().compute()

data_sources()

delete_tree()

export(filepath[, columns, format])

Download data in some format and write to a file.

include_data_sources()

Ensure that data source and asset information is fetched.

login([username, provider])

Depending on the server's authentication method, this will prompt for username/password:

logout()

Log out.

new_variation([structure])

This is intended primarily for internal use and use by subclasses.

raw_export([destination_directory, max_workers])

Download the raw assets backing this node.

read([columns])

Access the entire DataFrame.

read_partition(partition[, columns])

Access one partition in a partitioned (dask) dataframe.

refresh()

structure()

Return a dataclass describing the structure of the data.

update_metadata([metadata, specs])

EXPERIMENTAL: Update metadata.

write(dataframe)

write_partition(dataframe, partition)

Attributes

URL_CHARACTER_LIMIT

columns

context

formats

List formats that the server can export this data as.

item

JSON payload describing this item.

metadata

Metadata about this data source.

metadata_revisions

specs

List of specifications describing the structure of the metadata and/or data.

structure_family

Quick access to this entry

uri

Direct link to this entry