singer_sdk.InlineMapper

class singer_sdk.InlineMapper

Abstract base class for inline mappers.

cli = <Command cli>

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

Map a version message to zero or more new messages.

Parameters

message_dict – An ACTIVATE_VERSION message JSON dictionary.

map_batch_message(message_dict: dict) → Iterable[Message]

Map a batch message to zero or more new messages.

Parameters

message_dict – A BATCH message JSON dictionary.

Raises

NotImplementedError – if not implemented by subclass.

abstract map_record_message(message_dict: dict) → Iterable[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[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[Message]

Map a state message to zero or more new messages.

Parameters

message_dict – A STATE message JSON dictionary.