executor

Documentation

Index

• type Database
  • func (d *Database) GetTable(ctx context.Context, name string, options map[string]string) (physical.DatasourceImplementation, physical.Schema, error)
  • func (d *Database) ListTables(ctx context.Context) ([]string, error)
• type ExecutionDatasource
  • func (e *ExecutionDatasource) Run(ctx execution.ExecutionContext, produce execution.ProduceFn, ...) error
• type Manager
• type PhysicalDatasource
  • func (p *PhysicalDatasource) Materialize(ctx context.Context, env physical.Environment, schema physical.Schema, ...) (execution.Node, error)
  • func (p *PhysicalDatasource) PushDownPredicates(newPredicates, pushedDownPredicates []physical.Expression) (rejected, pushedDown []physical.Expression, changed bool)
• type PluginExecutor
  • func (e *PluginExecutor) Close() error
  • func (e *PluginExecutor) RunPlugin(ctx context.Context, pluginRef config.PluginReference, databaseName string, ...) (*Database, error)

Types

type Database

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

func (*Database) GetTable

func (d *Database) GetTable(ctx context.Context, name string, options map[string]string) (physical.DatasourceImplementation, physical.Schema, error)

func (*Database) ListTables

func (d *Database) ListTables(ctx context.Context) ([]string, error)

type ExecutionDatasource

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

func (*ExecutionDatasource) Run

func (e *ExecutionDatasource) Run(ctx execution.ExecutionContext, produce execution.ProduceFn, metaSend execution.MetaSendFn) error

type Manager

type Manager interface {
	GetPluginBinaryPath(name config.PluginReference, version *semver.Version) (string, error)
}

type PhysicalDatasource

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

func (*PhysicalDatasource) Materialize

func (p *PhysicalDatasource) Materialize(ctx context.Context, env physical.Environment, schema physical.Schema, pushedDownPredicates []physical.Expression) (execution.Node, error)

func (*PhysicalDatasource) PushDownPredicates

func (p *PhysicalDatasource) PushDownPredicates(newPredicates, pushedDownPredicates []physical.Expression) (rejected, pushedDown []physical.Expression, changed bool)

type PluginExecutor

type PluginExecutor struct {
	Manager Manager
	// contains filtered or unexported fields
}

func (*PluginExecutor) Close

func (e *PluginExecutor) Close() error

func (*PluginExecutor) RunPlugin

func (e *PluginExecutor) RunPlugin(ctx context.Context, pluginRef config.PluginReference, databaseName string, version *semver.Version, config yaml.Node) (*Database, error)