Index

_

_generate_select_expression_for_as_is() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_extended_string_to_boolean() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_extended_string_to_date() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_extended_string_to_double() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_extended_string_to_float() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_extended_string_to_int() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_extended_string_to_long() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_extended_string_to_timestamp() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_extended_string_unix_timestamp_ms_to_date() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_extended_string_unix_timestamp_ms_to_timestamp() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_has_value() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_IntBoolean() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_IntNull() (in module spooq.transformer.mapper_custom_data_types)

_generate_select_expression_for_json_string() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_keep() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_meters_to_cm() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_no_change() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_StringBoolean() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_StringNull() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_timestamp_ms_to_ms() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_timestamp_ms_to_s() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_timestamp_s_to_ms() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_timestamp_s_to_s() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_TimestampMonth() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_for_unix_timestamp_ms_to_spark_timestamp() (in module spooq.transformer.mapper_custom_data_types) _generate_select_expression_without_casting() (in module spooq.transformer.mapper_custom_data_types)

A

apply() (in module spooq.transformer.mapper_transformations)

as_is() (in module spooq.transformer.mapper_transformations)

E

EnumCleaner (class in spooq.transformer.enum_cleaner) execute() (PipelineFactory method) Exploder (class in spooq.transformer.exploder) extract() (Extractor method) (JDBCExtractorFullLoad method) (JDBCExtractorIncremental method) (JSONExtractor method)

Extractor (class in spooq.extractor.extractor)

G

get_logging_level() (in module spooq.spooq_logger)

get_metadata() (PipelineFactory method) get_pipeline() (PipelineFactory method)

H

has_value() (in module spooq.transformer.mapper_transformations)

HiveLoader (class in spooq.loader.hive_loader)

I

initialize() (in module spooq.spooq_logger)

J

JDBCExtractor (class in spooq.extractor.jdbc) JDBCExtractorFullLoad (class in spooq.extractor.jdbc)

JDBCExtractorIncremental (class in spooq.extractor.jdbc) JSONExtractor (class in spooq.extractor.json_files)

L

load() (HiveLoader method)

logger (Extractor attribute)

M

map_values() (in module spooq.transformer.mapper_transformations) Mapper (class in spooq.transformer.mapper) meters_to_cm() (in module spooq.transformer.mapper_transformations) module spooq.extractor.extractor spooq.extractor.jdbc spooq.extractor.json_files spooq.loader.hive_loader spooq.loader.loader spooq.pipeline.factory spooq.pipeline.pipeline spooq.spooq_logger spooq.transformer.enum_cleaner spooq.transformer.exploder spooq.transformer.mapper_custom_data_types spooq.transformer.mapper_transformations spooq.transformer.newest_by_group spooq.transformer.null_cleaner spooq.transformer.sieve spooq.transformer.threshold_cleaner spooq.transformer.transformer

N

name (Extractor attribute)

NewestByGroup (class in spooq.transformer.newest_by_group) NullCleaner (class in spooq.transformer.null_cleaner)

P

PipelineFactory (class in spooq.pipeline.factory)

S

Sieve (class in spooq.transformer.sieve) spooq.extractor.extractor module spooq.extractor.jdbc module spooq.extractor.json_files module spooq.loader.hive_loader module spooq.loader.loader module spooq.pipeline.factory module spooq.pipeline.pipeline module spooq.spooq_logger module spooq.transformer.enum_cleaner module

spooq.transformer.exploder module spooq.transformer.mapper_custom_data_types module spooq.transformer.mapper_transformations module spooq.transformer.newest_by_group module spooq.transformer.null_cleaner module spooq.transformer.sieve module spooq.transformer.threshold_cleaner module spooq.transformer.transformer module str_to_array() (in module spooq.transformer.mapper_transformations)

T

ThresholdCleaner (class in spooq.transformer.threshold_cleaner) to_bool() (in module spooq.transformer.mapper_transformations) to_double() (in module spooq.transformer.mapper_transformations) to_float() (in module spooq.transformer.mapper_transformations) to_int() (in module spooq.transformer.mapper_transformations) to_json_string() (in module spooq.transformer.mapper_transformations) to_long() (in module spooq.transformer.mapper_transformations) to_num() (in module spooq.transformer.mapper_transformations)

to_str() (in module spooq.transformer.mapper_transformations) to_timestamp() (in module spooq.transformer.mapper_transformations) transform() (EnumCleaner method) (Exploder method) (NewestByGroup method) (NullCleaner method) (Sieve method) (ThresholdCleaner method)

U

url (PipelineFactory attribute)