singer_sdk.InlineMapper

class singer_sdk.InlineMapper(config: Optional[Union[dict, pathlib.PurePath, str, List[Union[pathlib.PurePath, str]]]] = None, parse_env_config: bool = False, validate_config: bool = True)

Abstract base class for inline mappers.

cli = <Command cli>

abstract map_activate_version_message(message_dict: dict) → Iterable[singer.messages.Message]

Map a version message to zero or more new messages.

Parameters

message_dict – An ACTIVATE_VERSION message JSON dictionary.

abstract map_record_message(message_dict: dict) → Iterable[singer.messages.Message]

Map a record message to zero or more new messages.

Parameters

message_dict – A RECORD message JSON dictionary.

abstract map_schema_message(message_dict: dict) → Iterable[singer.messages.Message]

Map a schema message to zero or more new messages.

Parameters

message_dict – A SCHEMA message JSON dictionary.

abstract map_state_message(message_dict: dict) → Iterable[singer.messages.Message]

Map a state message to zero or more new messages.

Parameters

message_dict – A STATE message JSON dictionary.