Index

A

Annotator (class in spooq.transformer.annotator) AnnotatorMode (class in spooq.transformer.annotator)

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

C

ColumnMappingNotSupported

ColumnNotFound

D

DataTypeValidationFailed

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)

load_comments_from_metastore_table() (in module spooq.transformer.annotator) logger (Extractor attribute)

M

map_values() (in module spooq.transformer.mapper_transformations) Mapper (class in spooq.transformer.mapper) MapperMode (class in spooq.transformer.mapper) MapperParameterNotSupported meters_to_cm() (in module spooq.transformer.mapper_transformations) MissingColumnHandling (class in spooq.transformer.annotator) (class in spooq.transformer.mapper) 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.annotator spooq.transformer.enum_cleaner spooq.transformer.exploder spooq.transformer.mapper 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.annotator module

spooq.transformer.enum_cleaner module spooq.transformer.exploder module spooq.transformer.mapper 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() (Annotator method) (EnumCleaner method) (Exploder method) (Mapper method) (NewestByGroup method) (NullCleaner method) (Sieve method) (ThresholdCleaner method)

U

update_comment() (in module spooq.transformer.annotator)

url (PipelineFactory attribute)