records-mover
stable
Contents:
records_mover package
records-mover
Index
Edit on GitHub
Index
_
|
A
|
B
|
D
|
E
|
F
|
G
|
L
|
M
|
O
|
P
|
R
|
S
|
T
_
__init__() (records_mover.airflow.hooks.RecordsHook method)
(records_mover.airflow.hooks.SqlAlchemyDbHook method)
(records_mover.records.DelimitedRecordsFormat method)
(records_mover.records.ParquetRecordsFormat method)
(records_mover.records.ProcessingInstructions method)
(records_mover.Session method)
A
APPEND (records_mover.records.ExistingTableHandling attribute)
AvroRecordsFormat (class in records_mover.records)
B
BaseRecordsFormat (class in records_mover.records.base_records_format)
D
data_url() (records_mover.records.sources.RecordsSources method)
(records_mover.records.targets.RecordsTargets method)
dataframe() (records_mover.records.sources.RecordsSources method)
dataframes() (records_mover.records.sources.RecordsSources method)
DELETE_AND_OVERWRITE (records_mover.records.ExistingTableHandling attribute)
DelimitedRecordsFormat (class in records_mover.records)
DelimitedVariant (in module records_mover.records)
directory_from_url() (records_mover.records.sources.RecordsSources method)
(records_mover.records.targets.RecordsTargets method)
DROP_AND_RECREATE (records_mover.records.ExistingTableHandling attribute)
E
ExistingTableHandling (class in records_mover.records)
F
fileobj() (records_mover.records.targets.RecordsTargets method)
fileobjs() (records_mover.records.sources.RecordsSources method)
format_type (records_mover.records.AvroRecordsFormat attribute)
G
generate_filename() (records_mover.records.AvroRecordsFormat method)
get_conn() (records_mover.airflow.hooks.RecordsHook method)
(records_mover.airflow.hooks.SqlAlchemyDbHook method)
get_db_engine() (records_mover.Session method)
get_default_db_engine() (records_mover.Session method)
google_sheet() (records_mover.records.sources.RecordsSources method)
(records_mover.records.targets.RecordsTargets method)
L
local_file() (records_mover.records.sources.RecordsSources method)
(records_mover.records.targets.RecordsTargets method)
M
module
records_mover
records_mover.airflow.hooks
records_mover.records
records_mover.records.sources
records_mover.records.targets
move (records_mover.Records attribute)
(records_mover.records.Records attribute)
move() (in module records_mover)
(in module records_mover.records)
move_count (records_mover.records.MoveResult attribute)
MoveResult (class in records_mover.records)
O
output_urls (records_mover.records.MoveResult attribute)
P
ParquetRecordsFormat (class in records_mover.records)
ProcessingInstructions (class in records_mover.records)
R
Records (class in records_mover)
(class in records_mover.records)
records (records_mover.Session property)
records_mover
module
records_mover.airflow.hooks
module
records_mover.records
module
records_mover.records.sources
module
records_mover.records.targets
module
RecordsException
RecordsFolderNonEmptyException
RecordsHook (class in records_mover.airflow.hooks)
RecordsSources (class in records_mover.records.sources)
RecordsTargets (class in records_mover.records.targets)
S
Session (class in records_mover)
set_stream_logging() (in module records_mover)
(records_mover.Session method)
sources (records_mover.Records attribute)
(records_mover.records.Records attribute)
spectrum() (records_mover.records.targets.RecordsTargets method)
SqlAlchemyDbHook (class in records_mover.airflow.hooks)
T
table() (records_mover.records.sources.RecordsSources method)
(records_mover.records.targets.RecordsTargets method)
targets (records_mover.Records attribute)
(records_mover.records.Records attribute)
TRUNCATE_AND_OVERWRITE (records_mover.records.ExistingTableHandling attribute)
Read the Docs
v: stable
Versions
latest
stable
publish_docs
Downloads
On Read the Docs
Project Home
Builds