s3select

Documentation

Index

• Constants
• func BuildQueryRunner(name string, body hcl.Body, ctx *hcl.EvalContext) (queryrunner.QueryRunner, hcl.Diagnostics)
• type PreparedQuery
  • func (q *PreparedQuery) Run(ctx context.Context, variables map[string]cty.Value, ...) (*queryrunner.QueryResult, error)
• type QueryCSVBlock
• type QueryJSONBlock
• type QueryParquetBlock
• type QueryRunner
  • func (r *QueryRunner) Name() string
  • func (r *QueryRunner) Prepare(base *queryrunner.QueryBase) (queryrunner.PreparedQuery, hcl.Diagnostics)
  • func (r *QueryRunner) RunQuery(ctx context.Context, params *runQueryParameters) (*queryrunner.QueryResult, error)
  • func (r *QueryRunner) Type() string

Constants

const TypeName = "s3_select"

Functions

func BuildQueryRunner

func BuildQueryRunner(name string, body hcl.Body, ctx *hcl.EvalContext) (queryrunner.QueryRunner, hcl.Diagnostics)

Types

type PreparedQuery

type PreparedQuery struct {
	*queryrunner.QueryBase

	Expression      hcl.Expression `hcl:"expression"`
	BucketName      string         `hcl:"bucket_name"`
	ObjectKeyPrefix hcl.Expression `hcl:"object_key_prefix"`
	ObjectKeySuffix *string        `hcl:"object_key_suffix"`
	ScanLimit       *string        `hcl:"scan_limit"`
	CompressionType string         `hcl:"compression_type"`
	ContinueOnError bool           `hcl:"continue_on_error,optional"`

	CSVBlock     *QueryCSVBlock     `hcl:"csv,block"`
	JSONBlock    *QueryJSONBlock    `hcl:"json,block"`
	ParquetBlock *QueryParquetBlock `hcl:"parquet,block"`
	// contains filtered or unexported fields
}

func (*PreparedQuery) Run

func (q *PreparedQuery) Run(ctx context.Context, variables map[string]cty.Value, functions map[string]function.Function) (*queryrunner.QueryResult, error)

type QueryCSVBlock

type QueryCSVBlock struct {
	AllowQuotedRecordDelimiter *bool   `hcl:"allow_quoted_record_delimiter"`
	FileHeaderInfo             *string `hcl:"file_header_info"`
	FieldDelimiter             *string `hcl:"field_delimiter"`
	QuoteCharacter             *string `hcl:"quote_character"`
	QuoteEscapeCharacter       *string `hcl:"quote_escape_character"`
	RecordDelimiter            *string `hcl:"record_delimiter"`
}

type QueryJSONBlock

type QueryJSONBlock struct {
	Type string `hcl:"type"`
}

type QueryParquetBlock

type QueryParquetBlock struct{}

type QueryRunner

type QueryRunner struct {
	Region *string `hcl:"region"`
	// contains filtered or unexported fields
}

func (*QueryRunner) Name

func (r *QueryRunner) Name() string

func (*QueryRunner) Prepare

func (r *QueryRunner) Prepare(base *queryrunner.QueryBase) (queryrunner.PreparedQuery, hcl.Diagnostics)

func (*QueryRunner) RunQuery

func (r *QueryRunner) RunQuery(ctx context.Context, params *runQueryParameters) (*queryrunner.QueryResult, error)

func (*QueryRunner) Type

func (r *QueryRunner) Type() string