Index

A | B | C | D | E | F | G | H | J | K | L | M | O | P | R | S | T | U

A

absolute_path() (in module sparkly.utils)
assertDataFrameEqual() (sparkly.testing.SparklyTest method)
assertRowsEqual() (sparkly.testing.SparklyTest method)
attach_writer_to_dataframe() (in module sparkly.writer)

B

by_url() (sparkly.reader.SparklyReader method)
(sparkly.writer.SparklyWriter method)

C

cassandra() (sparkly.reader.SparklyReader method)
(sparkly.writer.SparklyWriter method)
CassandraFixture (class in sparkly.testing)
create_table() (sparkly.catalog.SparklyCatalog method)

D

drop_table() (sparkly.catalog.SparklyCatalog method)

E

elastic() (sparkly.reader.SparklyReader method)
(sparkly.writer.SparklyWriter method)
ElasticFixture (class in sparkly.testing)

F

Fixture (class in sparkly.testing)

G

get_db_name() (in module sparkly.catalog)
get_or_create() (sparkly.session.SparklySession class method)
get_table_name() (in module sparkly.catalog)
get_table_properties() (sparkly.catalog.SparklyCatalog method)
get_table_property() (sparkly.catalog.SparklyCatalog method)

H

has_database() (sparkly.catalog.SparklyCatalog method)
has_jar() (sparkly.session.SparklySession method)
has_package() (sparkly.session.SparklySession method)
has_table() (sparkly.catalog.SparklyCatalog method)

J

jars (sparkly.session.SparklySession attribute)

K

kafka() (sparkly.reader.SparklyReader method)
(sparkly.writer.SparklyWriter method)
kafka_get_topics_offsets() (in module sparkly.utils)
KafkaFixture (class in sparkly.testing)
KafkaWatcher (class in sparkly.testing)

L

lru_cache (class in sparkly.utils)

M

multijoin() (in module sparkly.functions)
mysql() (sparkly.reader.SparklyReader method)
(sparkly.writer.SparklyWriter method)
MysqlFixture (class in sparkly.testing)

O

options (sparkly.session.SparklySession attribute)

P

packages (sparkly.session.SparklySession attribute)
parse_schema() (in module sparkly.utils)

R

redis() (sparkly.writer.SparklyWriter method)
rename_table() (sparkly.catalog.SparklyCatalog method)
repositories (sparkly.session.SparklySession attribute)

S

schema_has() (in module sparkly.utils)
session (sparkly.testing.SparklyTest attribute)
set_table_property() (sparkly.catalog.SparklyCatalog method)
setup_data() (sparkly.testing.Fixture method)
sparkly (module)
sparkly.catalog (module)
sparkly.functions (module)
sparkly.reader (module)
sparkly.session (module)
sparkly.testing (module)
sparkly.utils (module)
sparkly.writer (module)
SparklyCatalog (class in sparkly.catalog)
SparklyGlobalSessionTest (class in sparkly.testing)
SparklyReader (class in sparkly.reader)
SparklySession (class in sparkly.session)
SparklyTest (class in sparkly.testing)
SparklyWriter (class in sparkly.writer)
stop() (sparkly.session.SparklySession class method)
switch_case() (in module sparkly.functions)

T

teardown_data() (sparkly.testing.Fixture method)

U

udfs (sparkly.session.SparklySession attribute)