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)

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