athena

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

type AssetMaterializationMap map[pipeline.MaterializationType]map[pipeline.MaterializationStrategy]MaterializerFunc

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

type Client interface {
	RunQueryWithoutResult(ctx context.Context, query *query.Query) error
	Select(ctx context.Context, query *query.Query) ([][]interface{}, error)
	GetResultsLocation() string
	Ping(ctx context.Context) error
	SelectWithSchema(ctx context.Context, queryObject *query.Query) (*query.QueryResult, error)
}

type Config struct {
	OutputBucket    string
	Region          string
	AccessID        string
	SecretAccessKey string
	SessionToken    string
	Database        string
}

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

type Materializer struct {
	MaterializationMap AssetMaterializationMap
	// contains filtered or unexported fields
}

type MaterializerFunc func(task *pipeline.Asset, query, location string) ([]string, error)

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

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

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