ExecutionIdToFileName convert an execution id and chunk number to a filename assuming a convention of <executionId>-<chunkNumber>.jsonl.

FileNameToExecutionId convert a filename to an execution id assuming a convention of <executionId>-<chunkNumber>.jsonl.

RegisterCollector registers a collector constructor directly this is only used if we need to specify a custom collector (used for custom tables).

RegisterTable registers a collector constructor with the factory this is called from the package init function of the table implementation.

RegisterTableFormat registers a collector constructor for a table which supports Format this is called from the package init function of the table implementation.

WithSchema is a MapOption which sets the schema on a Mapper.

JSONLChunkSize the number of rows to write in each JSONL file - make the same size as duck db uses to infer schema (10000).

Factory is a global TableFactory instance.

ArtifactConversionCollector is a collector that converts artifacts directly to JSONL S is the table config type.

CollectorImpl is a generic implementation of the Collector interface it is responsible for coordinating the collection process and reporting status R is the type of the row struct S is the type of the partition config T is the type of the table U is the type of the connection.

CollectorWithFormat is a collector that has a table format The format is parsed from the source format config.

JSONLWriter implements [ChunkWriter] and writes rows to JSONL files.

TableWithFormatImpl is a generic struct representing a plugin table definition with a format.

Collector is an interface which provides a methods for collecting table data from a source This is implemented by the generic CollectorImpl struct.

MapInitialisedRow is an interface which provides a means to initialise a row struct from a string map this is used in combination with the GonxMapper/GrokMapper.

Mapper is a generic interface which provides a method for mapping raw source data into row structs R is the type of the row struct which the mapperFunc outputs.

SchemaSetter is an interface which provides a method to set the schema.

Table is a generic interface representing a plugin table definition R is the row struct type.

TableWithFormat is a generic interface representing a plugin table definition with a format.