cura

Documentation

Index

• func ReleaseDriver(d *Driver)
• type Driver
  • func CreateDriver() *Driver
  • func (d *Driver) Compile(json string) int
  • func (d *Driver) Explain(json string, extended bool) (int, []string)
  • func (d *Driver) FinishPipeline() int
  • func (d *Driver) HasNextPipeline() bool
  • func (d *Driver) IsHeapSource(sourceId int64) bool
  • func (d *Driver) IsPipelineFinal() bool
  • func (d *Driver) PipelineHasNextSource() bool
  • func (d *Driver) PipelineNextSource() int64
  • func (d *Driver) PipelinePush(threadId int64, sourceId int64, record *array.Record) (int, *InputRecord)
  • func (d *Driver) PipelineStream(threadId int64, sourceId int64, record *array.Record, rows uint64) (int, *OutputRecord)
  • func (d *Driver) PreparePipeline() int
  • func (d *Driver) SetBucketAggregate(enable bool) int
  • func (d *Driver) SetBucketAggregateBuckets(buckets uint64) int
  • func (d *Driver) SetExclusiveDefaultMemoryResource(exclusive bool) int
  • func (d *Driver) SetMemoryResource(memoryResource MemoryResource) int
  • func (d *Driver) SetMemoryResourceSize(size uint64) int
  • func (d *Driver) SetMemoryResourceSizePerThread(size uint64) int
  • func (d *Driver) SetThreadsPerPipeline(threadsPerPipeline uint64) int
• type InputRecord
• type MemoryResource
• type OutputRecord

Functions

func ReleaseDriver

func ReleaseDriver(d *Driver)

Types

type Driver

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

func CreateDriver

func CreateDriver() *Driver

func (*Driver) Compile

func (d *Driver) Compile(json string) int

func (*Driver) Explain

func (d *Driver) Explain(json string, extended bool) (int, []string)

func (*Driver) FinishPipeline

func (d *Driver) FinishPipeline() int

func (*Driver) HasNextPipeline

func (d *Driver) HasNextPipeline() bool

func (*Driver) IsHeapSource

func (d *Driver) IsHeapSource(sourceId int64) bool

func (*Driver) IsPipelineFinal

func (d *Driver) IsPipelineFinal() bool

func (*Driver) PipelineHasNextSource

func (d *Driver) PipelineHasNextSource() bool

func (*Driver) PipelineNextSource

func (d *Driver) PipelineNextSource() int64

func (*Driver) PipelinePush

func (d *Driver) PipelinePush(threadId int64, sourceId int64, record *array.Record) (int, *InputRecord)

func (*Driver) PipelineStream

func (d *Driver) PipelineStream(threadId int64, sourceId int64, record *array.Record, rows uint64) (int, *OutputRecord)

func (*Driver) PreparePipeline

func (d *Driver) PreparePipeline() int

func (*Driver) SetBucketAggregate

func (d *Driver) SetBucketAggregate(enable bool) int

func (*Driver) SetBucketAggregateBuckets

func (d *Driver) SetBucketAggregateBuckets(buckets uint64) int

func (*Driver) SetExclusiveDefaultMemoryResource

func (d *Driver) SetExclusiveDefaultMemoryResource(exclusive bool) int

func (*Driver) SetMemoryResource

func (d *Driver) SetMemoryResource(memoryResource MemoryResource) int

func (*Driver) SetMemoryResourceSize

func (d *Driver) SetMemoryResourceSize(size uint64) int

func (*Driver) SetMemoryResourceSizePerThread

func (d *Driver) SetMemoryResourceSizePerThread(size uint64) int

func (*Driver) SetThreadsPerPipeline

func (d *Driver) SetThreadsPerPipeline(threadsPerPipeline uint64) int

type InputRecord

type InputRecord struct {
	array.Record
	// contains filtered or unexported fields
}

type MemoryResource

type MemoryResource int8

const (
	Arena MemoryResource = iota
	ArenaPerThread
	Pool
	PoolPerThread
	Managed
	Cuda
)

type OutputRecord

type OutputRecord struct {
	array.Record
	// contains filtered or unexported fields
}