beamds.beam.sql package

Submodules

beamds.beam.sql.core module

class beamds.beam.sql.core.BeamAthena(*args, _store_init_path=None, _save_init_args=True, **kwargs)

Bases: BeamSQL

property connection

property engine

get_sample(n=1, **kwargs)

get_schema()

sql(query)

class beamds.beam.sql.core.BeamSQL(*args, _store_init_path=None, _save_init_args=True, **kwargs)

Bases: Processor

property columns

property database

static df2table(df, name, metadata=None)

property engine

get_sample(n=1, **kwargs)

get_schema()

property index

property llm

nlp(query, **kwargs)

set_columns(columns)

set_database(database)

set_index(index)

set_llm(llm)

set_table(table)

sql(query, **kwargs)

property table

Module contents