evaluation

Documentation

Index

• type FragmentEvaluator
  • func NewFragmentEvaluator(scorer *scoring.RuleBasedScorer, logger *slog.Logger) *FragmentEvaluator
  • func (fe *FragmentEvaluator) Name() string
  • func (fe *FragmentEvaluator) Process(ctx context.Context, pctx *pipeline.PipelineContext) (*scoring.ProcessResult, error)

Types

type FragmentEvaluator

type FragmentEvaluator struct {
	// contains filtered or unexported fields
}

FragmentEvaluator evaluates the quality of data fragments from sources.

func NewFragmentEvaluator

func NewFragmentEvaluator(scorer *scoring.RuleBasedScorer, logger *slog.Logger) *FragmentEvaluator

NewFragmentEvaluator creates a new FragmentEvaluator.

func (*FragmentEvaluator) Name

func (fe *FragmentEvaluator) Name() string

Name implements the Processor interface.

func (*FragmentEvaluator) Process

func (fe *FragmentEvaluator) Process(ctx context.Context, pctx *pipeline.PipelineContext) (*scoring.ProcessResult, error)

Process evaluates all fragments in the pipeline context.