cosmotech.coal.store

cosmotech.coal.store.csv

Functions:

Name	Description
store_csv_file
convert_store_table_to_csv

store_csv_file(table_name, csv_path, replace_existsing_file=False, store=None)

convert_store_table_to_csv(table_name, csv_path, replace_existsing_file=False, store=None)

cosmotech.coal.store.native_python

Functions:

Name	Description
store_pylist
convert_table_as_pylist

store_pylist(table_name, data, replace_existsing_file=False, store=None)

convert_table_as_pylist(table_name, store=None)

cosmotech.coal.store.output.aws_channel.AwsChannel

Bases: ChannelInterface

              flowchart TD
              cosmotech.coal.store.output.aws_channel.AwsChannel[AwsChannel]
              cosmotech.coal.store.output.channel_interface.ChannelInterface[ChannelInterface]

                              cosmotech.coal.store.output.channel_interface.ChannelInterface --> cosmotech.coal.store.output.aws_channel.AwsChannel
                


              click cosmotech.coal.store.output.aws_channel.AwsChannel href "" "cosmotech.coal.store.output.aws_channel.AwsChannel"
              click cosmotech.coal.store.output.channel_interface.ChannelInterface href "" "cosmotech.coal.store.output.channel_interface.ChannelInterface"
            

Methods:

Name	Description
send
delete

send(filter=None)

delete()

cosmotech.coal.store.output.az_storage_channel.AzureStorageChannel

Bases: ChannelInterface

              flowchart TD
              cosmotech.coal.store.output.az_storage_channel.AzureStorageChannel[AzureStorageChannel]
              cosmotech.coal.store.output.channel_interface.ChannelInterface[ChannelInterface]

                              cosmotech.coal.store.output.channel_interface.ChannelInterface --> cosmotech.coal.store.output.az_storage_channel.AzureStorageChannel
                


              click cosmotech.coal.store.output.az_storage_channel.AzureStorageChannel href "" "cosmotech.coal.store.output.az_storage_channel.AzureStorageChannel"
              click cosmotech.coal.store.output.channel_interface.ChannelInterface href "" "cosmotech.coal.store.output.channel_interface.ChannelInterface"
            

Methods:

Name	Description
send
delete

send(filter=None)

delete()

cosmotech.coal.store.output.channel_interface.ChannelInterface

Methods:

Name	Description
send
delete
is_available

send(filter=None)

delete()

is_available()

cosmotech.coal.store.output.channel_spliter.ChannelSpliter

Bases: ChannelInterface

              flowchart TD
              cosmotech.coal.store.output.channel_spliter.ChannelSpliter[ChannelSpliter]
              cosmotech.coal.store.output.channel_interface.ChannelInterface[ChannelInterface]

                              cosmotech.coal.store.output.channel_interface.ChannelInterface --> cosmotech.coal.store.output.channel_spliter.ChannelSpliter
                


              click cosmotech.coal.store.output.channel_spliter.ChannelSpliter href "" "cosmotech.coal.store.output.channel_spliter.ChannelSpliter"
              click cosmotech.coal.store.output.channel_interface.ChannelInterface href "" "cosmotech.coal.store.output.channel_interface.ChannelInterface"
            

Methods:

Name	Description
send
delete

send(filter=None)

delete()

cosmotech.coal.store.output.postgres_channel.PostgresChannel

Bases: ChannelInterface

              flowchart TD
              cosmotech.coal.store.output.postgres_channel.PostgresChannel[PostgresChannel]
              cosmotech.coal.store.output.channel_interface.ChannelInterface[ChannelInterface]

                              cosmotech.coal.store.output.channel_interface.ChannelInterface --> cosmotech.coal.store.output.postgres_channel.PostgresChannel
                


              click cosmotech.coal.store.output.postgres_channel.PostgresChannel href "" "cosmotech.coal.store.output.postgres_channel.PostgresChannel"
              click cosmotech.coal.store.output.channel_interface.ChannelInterface href "" "cosmotech.coal.store.output.channel_interface.ChannelInterface"
            

Methods:

Name	Description
send
delete

send(filter=None)

delete()

cosmotech.coal.store.pandas

Functions:

Name	Description
store_dataframe
convert_store_table_to_dataframe

store_dataframe(table_name, dataframe, replace_existsing_file=False, store=None)

convert_store_table_to_dataframe(table_name, store=None)

cosmotech.coal.store.parquet

Functions:

Name	Description
store_parquet_file
convert_store_table_to_parquet

store_parquet_file(table_name, parquet_path, replace_existsing_file=False, store=None)

convert_store_table_to_parquet(table_name, parquet_path, replace_existsing_file=False, store=None)

cosmotech.coal.store.pyarrow

Functions:

Name	Description
store_table
convert_store_table_to_dataframe

store_table(table_name, data, replace_existsing_file=False, store=None)

convert_store_table_to_dataframe(table_name, store=None)

cosmotech.coal.store.store

Functions:

Name	Description
table_name_to_lower

table_name_to_lower(func)

cosmotech.coal.store.store.Store

Methods:

Name	Description
sanitize_column
reset
get_table
table_exists
get_table_schema
add_table
execute_query
list_tables

sanitize_column(column_name) staticmethod

reset()

get_table(table_name)

table_exists(table_name)

get_table_schema(table_name)

add_table(table_name, data=pyarrow.Table, replace=False)

execute_query(sql_query, parameters=None)

list_tables()