LICENSE
README.md
pyproject.toml
src/datapipeline/__init__.py
src/datapipeline/plugins.py
src/datapipeline/analysis/__init__.py
src/datapipeline/analysis/vector_analyzer.py
src/datapipeline/cli/app.py
src/datapipeline/cli/openers.py
src/datapipeline/cli/visuals.py
src/datapipeline/cli/commands/analyze.py
src/datapipeline/cli/commands/domain.py
src/datapipeline/cli/commands/filter.py
src/datapipeline/cli/commands/link.py
src/datapipeline/cli/commands/list_.py
src/datapipeline/cli/commands/plugin.py
src/datapipeline/cli/commands/run.py
src/datapipeline/cli/commands/source.py
src/datapipeline/common/__init__.py
src/datapipeline/common/geo.py
src/datapipeline/config/__init__.py
src/datapipeline/config/catalog.py
src/datapipeline/config/project.py
src/datapipeline/config/dataset/dataset.py
src/datapipeline/config/dataset/feature.py
src/datapipeline/config/dataset/group_by.py
src/datapipeline/config/dataset/loader.py
src/datapipeline/config/dataset/normalize.py
src/datapipeline/domain/__init__.py
src/datapipeline/domain/feature.py
src/datapipeline/domain/record.py
src/datapipeline/domain/vector.py
src/datapipeline/filters/filters.py
src/datapipeline/mappers/noop.py
src/datapipeline/mappers/synthetic/time.py
src/datapipeline/parsers/identity.py
src/datapipeline/pipeline/__init__.py
src/datapipeline/pipeline/pipelines.py
src/datapipeline/pipeline/stages.py
src/datapipeline/pipeline/utils/keygen.py
src/datapipeline/pipeline/utils/memory_sort.py
src/datapipeline/pipeline/utils/ordering.py
src/datapipeline/pipeline/utils/transform_utils.py
src/datapipeline/services/bootstrap.py
src/datapipeline/services/constants.py
src/datapipeline/services/entrypoints.py
src/datapipeline/services/factories.py
src/datapipeline/services/paths.py
src/datapipeline/services/project_paths.py
src/datapipeline/services/scaffold/__init__.py
src/datapipeline/services/scaffold/domain.py
src/datapipeline/services/scaffold/filter.py
src/datapipeline/services/scaffold/mappers.py
src/datapipeline/services/scaffold/plugin.py
src/datapipeline/services/scaffold/source.py
src/datapipeline/services/scaffold/templates.py
src/datapipeline/sources/__init__.py
src/datapipeline/sources/composed_loader.py
src/datapipeline/sources/decoders.py
src/datapipeline/sources/factory.py
src/datapipeline/sources/transports.py
src/datapipeline/sources/models/__init__.py
src/datapipeline/sources/models/base.py
src/datapipeline/sources/models/generator.py
src/datapipeline/sources/models/loader.py
src/datapipeline/sources/models/parser.py
src/datapipeline/sources/models/source.py
src/datapipeline/sources/models/synthetic.py
src/datapipeline/sources/synthetic/__init__.py
src/datapipeline/sources/synthetic/time/__init__.py
src/datapipeline/sources/synthetic/time/loader.py
src/datapipeline/sources/synthetic/time/parser.py
src/datapipeline/streams/canonical.py
src/datapipeline/streams/raw.py
src/datapipeline/templates/plugin_skeleton/README.md
src/datapipeline/templates/plugin_skeleton/pyproject.toml
src/datapipeline/templates/plugin_skeleton/config/project.yaml
src/datapipeline/templates/plugin_skeleton/config/recipe.yaml
src/datapipeline/templates/plugin_skeleton/config/contracts/time_hour_sin.yaml
src/datapipeline/templates/plugin_skeleton/config/contracts/time_linear.yaml
src/datapipeline/templates/plugin_skeleton/config/contracts/time_ticks.yaml
src/datapipeline/templates/plugin_skeleton/config/distilleries/time_ticks.yaml
src/datapipeline/templates/plugin_skeleton/src/{{PACKAGE_NAME}}/__init__.py
src/datapipeline/templates/stubs/dto.py.j2
src/datapipeline/templates/stubs/filter.py.j2
src/datapipeline/templates/stubs/loader_synthetic.py.j2
src/datapipeline/templates/stubs/mapper.py.j2
src/datapipeline/templates/stubs/parser.py.j2
src/datapipeline/templates/stubs/parser_custom.py.j2
src/datapipeline/templates/stubs/record.py.j2
src/datapipeline/templates/stubs/source.yaml.j2
src/datapipeline/transforms/sequence.py
src/datapipeline/transforms/transforms.py
src/datapipeline/utils/__init__.py
src/datapipeline/utils/load.py
src/datapipeline/utils/time.py
src/jerry_thomas.egg-info/PKG-INFO
src/jerry_thomas.egg-info/SOURCES.txt
src/jerry_thomas.egg-info/dependency_links.txt
src/jerry_thomas.egg-info/entry_points.txt
src/jerry_thomas.egg-info/requires.txt
src/jerry_thomas.egg-info/top_level.txt