Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
K
|
L
|
M
|
N
|
P
|
R
|
S
|
T
|
U
|
V
|
W
|
Z
A
add_dictionary_to_versions() (hip_data_tools.hipages.version_tracking.VersionTracker method)
add_interval_partitioning_column() (in module hip_data_tools.apache.kafka)
add_object_version() (hip_data_tools.hipages.version_tracking.VersionTracker method)
add_partitions() (hip_data_tools.aws.athena.AthenaUtil method)
(hip_data_tools.etl.adwords_to_athena.AdWordsReportsToAthena method)
add_string_to_version_tracking() (hip_data_tools.hipages.version_tracking.VersionTracker method)
add_versions_from_json_file() (hip_data_tools.hipages.version_tracking.VersionTracker method)
AdWordsAdGroupAdUtil (class in hip_data_tools.google.adwords)
AdWordsAdGroupUtil (class in hip_data_tools.google.adwords)
AdWordsCampaignUtil (class in hip_data_tools.google.adwords)
AdWordsCustomerUtil (class in hip_data_tools.google.adwords)
AdWordsDataReader (class in hip_data_tools.google.adwords)
AdWordsManagedCustomerUtil (class in hip_data_tools.google.adwords)
AdWordsOfflineConversionUtil (class in hip_data_tools.google.adwords)
AdWordsParallelDataReadEstimator (class in hip_data_tools.google.adwords)
AdWordsReportDefinitionReader (class in hip_data_tools.google.adwords)
AdWordsReportReader (class in hip_data_tools.google.adwords)
AdWordsReportsToAthena (class in hip_data_tools.etl.adwords_to_athena)
AdWordsReportsToAthenaSettings (class in hip_data_tools.etl.adwords_to_athena)
AdWordsReportsToS3 (class in hip_data_tools.etl.adwords_to_s3)
AdWordsReportToS3Settings (class in hip_data_tools.etl.adwords_to_s3)
AdWordsToAthena (class in hip_data_tools.etl.adwords_to_athena)
AdWordsToAthenaSettings (class in hip_data_tools.etl.adwords_to_athena)
AdWordsToS3 (class in hip_data_tools.etl.adwords_to_s3)
AdWordsToS3Settings (class in hip_data_tools.etl.adwords_to_s3)
AdWordsUtil (class in hip_data_tools.google.adwords)
AthenaToAdWordsOfflineConversion (class in hip_data_tools.etl.athena_to_adwords)
AthenaToAdWordsOfflineConversionSettings (class in hip_data_tools.etl.athena_to_adwords)
AthenaToAthena (class in hip_data_tools.etl.athena_to_athena)
AthenaToAthenaSettings (class in hip_data_tools.etl.athena_to_athena)
AthenaToCassandra (class in hip_data_tools.etl.athena_to_cassandra)
AthenaToCassandraSettings (class in hip_data_tools.etl.athena_to_cassandra)
AthenaToDataFrame (class in hip_data_tools.etl.athena_to_dataframe)
AthenaToDataFrameSettings (class in hip_data_tools.etl.athena_to_dataframe)
AthenaToS3 (class in hip_data_tools.etl.athena_to_s3)
AthenaToS3Settings (class in hip_data_tools.etl.athena_to_s3)
AthenaUtil (class in hip_data_tools.aws.athena)
awql_to_dataframe() (hip_data_tools.google.adwords.AdWordsReportReader method)
AwsConnectionManager (class in hip_data_tools.aws.common)
AwsConnectionSettings (class in hip_data_tools.aws.common)
AwsSecretsManager (class in hip_data_tools.aws.common)
AwsUtil (class in hip_data_tools.aws.common)
B
BatchS3UploaderConfig (class in hip_data_tools.apache.kafka)
bootstrap_servers (hip_data_tools.apache.kafka.KafkaProducer attribute)
bucket (hip_data_tools.apache.kafka.BatchS3UploaderConfig attribute)
build_query() (hip_data_tools.etl.adwords_to_s3.AdWordsToS3 method)
C
camel_case_detect (in module hip_data_tools.common)
CassandraConnectionManager (class in hip_data_tools.apache.cassandra)
CassandraConnectionSettings (class in hip_data_tools.apache.cassandra)
CassandraSecretsManager (class in hip_data_tools.apache.cassandra)
CassandraUtil (class in hip_data_tools.apache.cassandra)
check_for_decorated_declaration_in_file() (in module hip_data_tools.hipages.version_tracking)
CLASS_DECORATOR_STRING (in module hip_data_tools.hipages.version_tracking)
client() (hip_data_tools.aws.common.AwsConnectionManager method)
config (hip_data_tools.apache.kafka.KafkaProducer attribute)
configs (hip_data_tools.apache.kafka.ConsumerConfig attribute)
(hip_data_tools.apache.kafka.ProducerConfig attribute)
ConsumerConfig (class in hip_data_tools.apache.kafka)
convert_msgs_to_dictionary() (in module hip_data_tools.apache.kafka)
create_and_upsert_all() (hip_data_tools.etl.s3_to_cassandra.S3ToCassandra method)
create_athena_table() (hip_data_tools.etl.adwords_to_athena.AdWordsReportsToAthena method)
(hip_data_tools.etl.adwords_to_athena.AdWordsToAthena method)
create_batch_s3_uploader() (in module hip_data_tools.apache.kafka)
create_bucket() (hip_data_tools.aws.s3.S3Util method)
create_conduit() (in module hip_data_tools.apache.kafka)
create_consumer() (in module hip_data_tools.apache.kafka)
create_events_snapshot() (hip_data_tools.apache.kafka.KafkaConduit method)
create_poller() (in module hip_data_tools.apache.kafka)
create_producer() (in module hip_data_tools.apache.kafka)
create_table() (hip_data_tools.aws.athena.AthenaUtil method)
(hip_data_tools.etl.s3_to_cassandra.S3ToCassandra method)
create_table_from_dataframe() (hip_data_tools.apache.cassandra.CassandraUtil method)
create_table_from_model() (hip_data_tools.apache.cassandra.CassandraUtil method)
current_epoch() (in module hip_data_tools.etl.common)
current_state() (hip_data_tools.etl.common.EtlSinkRecordStateManager method)
D
dataclass() (in module hip_data_tools.apache.cassandra)
(in module hip_data_tools.aws.common)
(in module hip_data_tools.etl.adwords_to_athena)
(in module hip_data_tools.etl.adwords_to_s3)
(in module hip_data_tools.etl.athena_to_adwords)
(in module hip_data_tools.etl.athena_to_athena)
(in module hip_data_tools.etl.athena_to_cassandra)
(in module hip_data_tools.etl.athena_to_dataframe)
(in module hip_data_tools.etl.athena_to_s3)
(in module hip_data_tools.etl.google_sheet_to_athena)
(in module hip_data_tools.etl.google_sheet_to_s3)
(in module hip_data_tools.etl.s3_to_cassandra)
(in module hip_data_tools.etl.s3_to_dataframe)
(in module hip_data_tools.google.adwords)
(in module hip_data_tools.google.common)
dataframe_columns_to_snake_case() (in module hip_data_tools.common)
dataframe_to_cassandra_tuples() (in module hip_data_tools.apache.cassandra)
DataFrameTransformer (class in hip_data_tools.etl.common)
DecoratorError
DEFAULT_CONSUMER_CONF (in module hip_data_tools.apache.kafka)
DEFAULT_KAFKA_TIMESTAMP_COLUMN_NAME (in module hip_data_tools.apache.kafka)
DEFAULT_PRODUCER_CONF (in module hip_data_tools.apache.kafka)
DEFAULT_TIMESTAMP_PARTITION_KEY (in module hip_data_tools.apache.kafka)
DEFINITION_MAPPING (in module hip_data_tools.hipages.version_tracking)
delete_recursive() (hip_data_tools.aws.s3.S3Util method)
delete_recursive_match_suffix() (hip_data_tools.aws.s3.S3Util method)
DictKeyValueSource (class in hip_data_tools.common)
dicts_to_cassandra_tuples() (in module hip_data_tools.apache.cassandra)
DictTransformer (class in hip_data_tools.etl.common)
download_all_as_dataframe() (hip_data_tools.google.adwords.AdWordsDataReader method)
download_all_as_dict() (hip_data_tools.google.adwords.AdWordsDataReader method)
download_directory() (hip_data_tools.aws.s3.S3Util method)
download_file() (hip_data_tools.aws.s3.S3Util method)
download_json() (hip_data_tools.aws.s3.S3Util method)
download_next_page_as_dataframe() (hip_data_tools.google.adwords.AdWordsDataReader method)
download_next_page_as_dict() (hip_data_tools.google.adwords.AdWordsDataReader method)
download_object_and_deserialise() (hip_data_tools.aws.s3.S3Util method)
download_parquet_as_dataframe() (hip_data_tools.aws.s3.S3Util method)
download_strings() (hip_data_tools.aws.s3.S3Util method)
download_strings_from_directory() (hip_data_tools.aws.s3.S3Util method)
drop_table() (hip_data_tools.aws.athena.AthenaUtil method)
E
ENVIRONMENT (in module hip_data_tools.common)
EnvironmentKeyValueSource (class in hip_data_tools.common)
ETL (class in hip_data_tools.etl.common)
etl_signature (hip_data_tools.etl.common.EtlSinkRecordState attribute)
EtlSinkRecordState (class in hip_data_tools.etl.common)
EtlSinkRecordState.DoesNotExist
EtlSinkRecordState.MultipleObjectsReturned
EtlSinkRecordStateManager (class in hip_data_tools.etl.common)
EtlStates (class in hip_data_tools.etl.common)
execute() (hip_data_tools.apache.cassandra.CassandraUtil method)
(hip_data_tools.etl.athena_to_athena.AthenaToAthena method)
(hip_data_tools.etl.athena_to_s3.AthenaToS3 method)
execute_all() (hip_data_tools.etl.common.ETL method)
execute_next() (hip_data_tools.etl.common.ETL method)
exists() (hip_data_tools.common.DictKeyValueSource method)
(hip_data_tools.common.EnvironmentKeyValueSource method)
(hip_data_tools.common.KeyValueSource method)
export_path (hip_data_tools.apache.kafka.BatchS3UploaderConfig attribute)
extract_athena_type_from_value() (in module hip_data_tools.aws.athena)
extract_next() (hip_data_tools.etl.common.Extractor method)
Extractor (class in hip_data_tools.etl.common)
F
Failed (hip_data_tools.etl.common.EtlStates attribute)
failed() (hip_data_tools.etl.common.EtlSinkRecordStateManager method)
find_and_export_relevant_versions() (in module hip_data_tools.hipages.version_tracking)
find_any_relevant_decorations_in_file() (in module hip_data_tools.hipages.version_tracking)
find_relevant_file_versions() (in module hip_data_tools.hipages.version_tracking)
find_tracked_modules() (in module hip_data_tools.hipages.version_tracking)
flatten_nested_dict() (in module hip_data_tools.common)
G
generate_create_table_statement() (hip_data_tools.etl.athena_to_athena.AthenaToAthena method)
generate_csv_ctas() (in module hip_data_tools.aws.athena)
generate_parquet_ctas() (in module hip_data_tools.aws.athena)
generate_partitioned_dataframes() (hip_data_tools.apache.kafka.KafkaS3BatchExporter method)
generate_snapshot_file_name_with_timestamp() (in module hip_data_tools.apache.kafka)
get() (hip_data_tools.common.DictKeyValueSource method)
(hip_data_tools.common.EnvironmentKeyValueSource method)
(hip_data_tools.common.KeyValueSource method)
get_adwords_client() (hip_data_tools.google.adwords.GoogleAdWordsConnectionManager method)
get_all_accounts() (hip_data_tools.google.adwords.AdWordsManagedCustomerUtil method)
get_all_accounts_as_dataframe() (hip_data_tools.google.adwords.AdWordsManagedCustomerUtil method)
get_all_files_as_data_frame() (hip_data_tools.etl.s3_to_dataframe.S3ToDataFrame method)
get_all_keys() (hip_data_tools.aws.s3.S3Util method)
get_athena_columns_from_dataframe() (in module hip_data_tools.aws.athena)
get_client() (hip_data_tools.aws.common.AwsUtil method)
(hip_data_tools.google.common.GoogleApiConnectionManager method)
(hip_data_tools.google.sheets.GoogleSheetConnectionManager method)
get_cluster() (hip_data_tools.apache.cassandra.CassandraConnectionManager method)
get_cql_columns_from_dataframe() (in module hip_data_tools.apache.cassandra)
get_customers() (hip_data_tools.google.adwords.AdWordsCustomerUtil method)
get_data_frame() (hip_data_tools.etl.s3_to_dataframe.S3ToDataFrame method)
get_dataframe() (hip_data_tools.google.sheets.SheetUtil method)
get_fields_names() (hip_data_tools.google.sheets.SheetUtil method)
get_fields_types() (hip_data_tools.google.sheets.SheetUtil method)
get_from_env_or_default_with_warning() (in module hip_data_tools.common)
get_glue_table_metadata() (hip_data_tools.aws.athena.AthenaUtil method)
get_keys() (hip_data_tools.aws.s3.S3Util method)
get_keys_modified_in_range() (hip_data_tools.aws.s3.S3Util method)
get_latest_git_hash_of_files_in_repo() (in module hip_data_tools.hipages.version_tracking)
get_msgs() (hip_data_tools.apache.kafka.KafkaPoller method)
get_object_metadata() (hip_data_tools.aws.s3.S3Util method)
get_page_as_list_of_dict() (in module hip_data_tools.google.adwords)
get_parallel_payloads() (hip_data_tools.etl.adwords_to_s3.AdWordsToS3 method)
(hip_data_tools.google.adwords.AdWordsDataReader method)
(hip_data_tools.google.adwords.AdWordsParallelDataReadEstimator method)
get_partitions_from_partitions_dict() (in module hip_data_tools.aws.athena)
get_random_string() (in module hip_data_tools.etl.common)
get_report_fields() (hip_data_tools.google.adwords.AdWordsReportDefinitionReader method)
get_resource() (hip_data_tools.aws.common.AwsUtil method)
get_secret() (hip_data_tools.common.SecretsManager method)
get_session() (hip_data_tools.apache.cassandra.CassandraConnectionManager method)
get_table_columns() (hip_data_tools.aws.athena.AthenaUtil method)
get_table_data_location() (hip_data_tools.aws.athena.AthenaUtil method)
get_table_ddl() (hip_data_tools.aws.athena.AthenaUtil method)
get_table_settings_for_dataframe() (in module hip_data_tools.aws.athena)
get_target_prefix_with_partition_dirs() (hip_data_tools.etl.adwords_to_athena.AdWordsReportsToAthena method)
get_value_matrix() (hip_data_tools.google.sheets.SheetUtil method)
get_version_dict() (hip_data_tools.hipages.version_tracking.VersionTracker method)
GoogleAdWordsConnectionManager (class in hip_data_tools.google.adwords)
GoogleAdWordsConnectionSettings (class in hip_data_tools.google.adwords)
GoogleAdWordsSecretsManager (class in hip_data_tools.google.adwords)
GoogleApiConnectionManager (class in hip_data_tools.google.common)
GoogleApiConnectionSettings (class in hip_data_tools.google.common)
GoogleApiSecretsManager (class in hip_data_tools.google.common)
GoogleOAuthConnectionManager (class in hip_data_tools.google.adwords)
GoogleOAuthConnectionSettings (class in hip_data_tools.google.adwords)
GoogleSheetConnectionManager (class in hip_data_tools.google.sheets)
GoogleSheetsToAthenaSettings (class in hip_data_tools.etl.google_sheet_to_athena)
GoogleSheetsToS3Settings (class in hip_data_tools.etl.google_sheet_to_s3)
GoogleSheetToAthena (class in hip_data_tools.etl.google_sheet_to_athena)
GoogleSheetToS3 (class in hip_data_tools.etl.google_sheet_to_s3)
H
has_next() (hip_data_tools.etl.common.ETL method)
(hip_data_tools.etl.common.Extractor method)
hip_data_tools (module)
hip_data_tools.apache (module)
hip_data_tools.apache.cassandra (module)
hip_data_tools.apache.kafka (module)
hip_data_tools.aws (module)
hip_data_tools.aws.athena (module)
hip_data_tools.aws.common (module)
hip_data_tools.aws.s3 (module)
hip_data_tools.common (module)
hip_data_tools.etl (module)
hip_data_tools.etl.adwords_to_athena (module)
hip_data_tools.etl.adwords_to_s3 (module)
hip_data_tools.etl.athena_to_adwords (module)
hip_data_tools.etl.athena_to_athena (module)
hip_data_tools.etl.athena_to_cassandra (module)
hip_data_tools.etl.athena_to_dataframe (module)
hip_data_tools.etl.athena_to_s3 (module)
hip_data_tools.etl.common (module)
hip_data_tools.etl.google_sheet_to_athena (module)
hip_data_tools.etl.google_sheet_to_s3 (module)
hip_data_tools.etl.s3_to_cassandra (module)
hip_data_tools.etl.s3_to_dataframe (module)
hip_data_tools.etl.s3_to_s3 (module)
hip_data_tools.google (module)
hip_data_tools.google.adwords (module)
hip_data_tools.google.common (module)
hip_data_tools.google.sheets (module)
hip_data_tools.hipages (module)
hip_data_tools.hipages.version_tracking (module)
I
instantiate_producer() (hip_data_tools.apache.kafka.KafkaProducer method)
K
kafka_consumer (hip_data_tools.apache.kafka.KafkaPoller attribute)
KafkaConduit (class in hip_data_tools.apache.kafka)
KafkaPoller (class in hip_data_tools.apache.kafka)
KafkaPollerConfig (class in hip_data_tools.apache.kafka)
KafkaProducer (class in hip_data_tools.apache.kafka)
KafkaS3BatchExporter (class in hip_data_tools.apache.kafka)
KeyValueSource (class in hip_data_tools.common)
L
list_source_files() (hip_data_tools.etl.s3_to_dataframe.S3ToDataFrame method)
(hip_data_tools.etl.s3_to_s3.S3ToS3FileCopy method)
load() (hip_data_tools.etl.common.Loader method)
load_sheet_to_athena() (hip_data_tools.etl.google_sheet_to_athena.GoogleSheetToAthena method)
Loader (class in hip_data_tools.etl.common)
LOG (in module hip_data_tools.common)
M
main() (in module hip_data_tools.hipages.version_tracking)
METHOD_DECORATOR_STRING (in module hip_data_tools.hipages.version_tracking)
move_recursive() (hip_data_tools.aws.s3.S3Util method)
N
nested_list_of_dict_to_dataframe() (in module hip_data_tools.common)
next() (hip_data_tools.etl.s3_to_dataframe.S3ToDataFrame method)
NoProducerInstantiatedError
P
parse_and_export_msgs() (hip_data_tools.apache.kafka.KafkaS3BatchExporter method)
partition_key_nm (hip_data_tools.apache.kafka.BatchS3UploaderConfig attribute)
partition_msgs_by_kafka_ts() (hip_data_tools.apache.kafka.KafkaS3BatchExporter method)
pk (hip_data_tools.etl.common.EtlSinkRecordState attribute)
poll_kafka_for_messages() (hip_data_tools.apache.kafka.KafkaPoller method)
poll_topic_and_upload_to_s3() (hip_data_tools.apache.kafka.KafkaConduit method)
prepare_batches() (hip_data_tools.apache.cassandra.CassandraUtil method)
Processing (hip_data_tools.etl.common.EtlStates attribute)
processing() (hip_data_tools.etl.common.EtlSinkRecordStateManager method)
produce_msg() (hip_data_tools.apache.kafka.KafkaProducer method)
producer (hip_data_tools.apache.kafka.KafkaProducer attribute)
ProducerConfig (class in hip_data_tools.apache.kafka)
publish_dict_as_json() (hip_data_tools.apache.kafka.KafkaProducer method)
R
random() (in module hip_data_tools.etl.common)
read_as_dataframe() (hip_data_tools.apache.cassandra.CassandraUtil method)
read_as_dictonary_list() (hip_data_tools.apache.cassandra.CassandraUtil method)
read_lines_as_list() (hip_data_tools.aws.s3.S3Util method)
Ready (hip_data_tools.etl.common.EtlStates attribute)
ready() (hip_data_tools.etl.common.EtlSinkRecordStateManager method)
record_identifier (hip_data_tools.etl.common.EtlSinkRecordState attribute)
record_state (hip_data_tools.etl.common.EtlSinkRecordState attribute)
register_class_for_version_tracking() (in module hip_data_tools.hipages.version_tracking)
register_method_for_version_tracking() (in module hip_data_tools.hipages.version_tracking)
rename_file() (hip_data_tools.aws.s3.S3Util method)
repair_table_partitions() (hip_data_tools.aws.athena.AthenaUtil method)
reset() (hip_data_tools.etl.common.Extractor method)
reset_source() (hip_data_tools.etl.common.ETL method)
resource() (hip_data_tools.aws.common.AwsConnectionManager method)
run_query() (hip_data_tools.aws.athena.AthenaUtil method)
S
S3ToCassandra (class in hip_data_tools.etl.s3_to_cassandra)
S3ToCassandraSettings (class in hip_data_tools.etl.s3_to_cassandra)
S3ToDataFrame (class in hip_data_tools.etl.s3_to_dataframe)
S3ToDataFrameSettings (class in hip_data_tools.etl.s3_to_dataframe)
S3ToS3FileCopy (class in hip_data_tools.etl.s3_to_s3)
S3Util (class in hip_data_tools.aws.s3)
SecretsManager (class in hip_data_tools.common)
serialise_and_upload_object() (hip_data_tools.aws.s3.S3Util method)
set_query() (hip_data_tools.google.adwords.AdWordsDataReader method)
set_query_to_fetch_all() (hip_data_tools.google.adwords.AdWordsAdGroupAdUtil method)
(hip_data_tools.google.adwords.AdWordsAdGroupUtil method)
(hip_data_tools.google.adwords.AdWordsCampaignUtil method)
set_query_to_fetch_by_campaign() (hip_data_tools.google.adwords.AdWordsAdGroupUtil method)
setup_connection() (hip_data_tools.apache.cassandra.CassandraConnectionManager method)
SheetUtil (class in hip_data_tools.google.sheets)
SinkSettings (class in hip_data_tools.etl.common)
SourceSettings (class in hip_data_tools.etl.common)
special_characters_detect (in module hip_data_tools.common)
state_created (hip_data_tools.etl.common.EtlSinkRecordState attribute)
state_last_updated (hip_data_tools.etl.common.EtlSinkRecordState attribute)
Succeeded (hip_data_tools.etl.common.EtlStates attribute)
succeeded() (hip_data_tools.etl.common.EtlSinkRecordStateManager method)
sync_etl_state_table() (in module hip_data_tools.etl.common)
T
timeout_interval (hip_data_tools.apache.kafka.KafkaPoller attribute)
to_snake_case() (in module hip_data_tools.common)
topic (hip_data_tools.apache.kafka.KafkaPoller attribute)
(hip_data_tools.apache.kafka.KafkaProducer attribute)
transfer() (hip_data_tools.etl.adwords_to_s3.AdWordsReportsToS3 method)
transfer_all() (hip_data_tools.etl.adwords_to_s3.AdWordsToS3 method)
transfer_next_iteration() (hip_data_tools.etl.adwords_to_s3.AdWordsToS3 method)
transform() (hip_data_tools.etl.common.DataFrameTransformer method)
(hip_data_tools.etl.common.DictTransformer method)
(hip_data_tools.etl.common.Transformer method)
Transformer (class in hip_data_tools.etl.common)
ts_col_nm (hip_data_tools.apache.kafka.BatchS3UploaderConfig attribute)
U
upload_all() (hip_data_tools.etl.athena_to_adwords.AthenaToAdWordsOfflineConversion method)
upload_binary_stream() (hip_data_tools.aws.s3.S3Util method)
upload_conversions() (hip_data_tools.google.adwords.AdWordsOfflineConversionUtil method)
upload_dataframe_as_parquet() (hip_data_tools.aws.s3.S3Util method)
upload_directory() (hip_data_tools.aws.s3.S3Util method)
upload_file() (hip_data_tools.aws.s3.S3Util method)
upload_json() (hip_data_tools.aws.s3.S3Util method)
upload_next() (hip_data_tools.etl.athena_to_adwords.AthenaToAdWordsOfflineConversion method)
upsert_all_files() (hip_data_tools.etl.s3_to_cassandra.S3ToCassandra method)
upsert_dataframe() (hip_data_tools.apache.cassandra.CassandraUtil method)
upsert_dataframe_in_batches() (hip_data_tools.apache.cassandra.CassandraUtil method)
upsert_dictonary_list() (hip_data_tools.apache.cassandra.CassandraUtil method)
upsert_dictonary_list_in_batches() (hip_data_tools.apache.cassandra.CassandraUtil method)
upsert_file() (hip_data_tools.etl.s3_to_cassandra.S3ToCassandra method)
V
validate_and_fix_common_integer_fields() (in module hip_data_tools.common)
ValidationError
VersionTracker (class in hip_data_tools.hipages.version_tracking)
W
watch_query() (hip_data_tools.aws.athena.AthenaUtil method)
write_sheet_data_to_s3() (hip_data_tools.etl.google_sheet_to_s3.GoogleSheetToS3 method)
write_versions_to_json() (in module hip_data_tools.hipages.version_tracking)
Z
zeep_object_to_dict() (in module hip_data_tools.google.adwords)
zip_columns() (in module hip_data_tools.aws.athena)
hip-data-tools
Navigation
Related Topics
Documentation overview
Quick search