WithArtifactExtractor is used to specify an artifact extractor this is needed if the artifact contains a collection of rows which needs explicit extraction (not this is in addition to the default extraction performed by the loaded).

WithArtifactLoader is used to specify an artifact loader.

WithDefaultArtifactSourceConfig sets the default config, e.g.

WithRowPerLine is used when creating an ArtifactSourceImpl it specifies that the row source should treat each line as a separate row.

WithSkipHeaderRow is used when creating an ArtifactSourceImpl it specifies that the row source should skip the first row (header row).

ArtifactSourceImpl is a [row_source.RowSource] that extracts rows from an 'artifact' Artifacts are defined as some entity which contains a collection of rows, which must be extracted/processed in some way to produce 'raw' rows which can be streamed to a collection.

for now, sources must be parametrized by a connection, so we need a dummy connection for those that don't need one.

InitSourceRequest is an sdk type which is mapped from the proto.InitSourceRequest.

NilArtifactCollectionState is a collection state that does nothing it is used by PluginSourceWrapper - as the actual collection state is implemented by the source plugin.

PluginSourceWrapper is an implementation of ArtifactSource which wraps a GRPC plugin which implements the source all RowSource implementations delegate to the plugin, while the remainder of the ArtifactSource operations: loading, extraction are handled by the base ArtifactSourceImpl.

ArtifactSource is an interface providing methods for discovering and downloading artifacts to the local file system an [row_source.RowSourceImpl] must be configured to have a ArtifactSource implementation.

Extractor is an interface which provides a method for extracting rows from an artifact.