API Reference

intake_accumulo.source.AccumuloSource(table) Read data from Accumulo table.
class intake_accumulo.source.AccumuloSource(table, host='localhost', port=42424, username='root', password='secret', metadata=None)[source]

Read data from Accumulo table.

Parameters:
table : str

The database table that will act as source

host : str

The server hostname for the given table

port : int

The server port for the given table

username : str

The username used to connect to the Accumulo cluster

password : str

The password used to connect to the Accumulo cluster

Attributes:
cache_dirs
datashape
description
hvplot

Returns a hvPlot object to provide a high-level plotting API.

plot

Returns a hvPlot object to provide a high-level plotting API.

plots

List custom associated quick-plots

Methods

close() Close open resources corresponding to this data source.
discover() Open resource and populate the source attributes.
read() Load entire dataset into a container and return it
read_chunked() Return iterator over container fragments of data source
read_partition(i) Return a part of the data corresponding to i-th partition.
to_dask() Return a dask container for this data source
to_spark() Provide an equivalent data object in Apache Spark
yaml([with_plugin]) Return YAML representation of this data-source
set_cache_dir