Documentation
¶
Index ¶
- func BenchmarkCount(b *testing.B)
- func BenchmarkFilter(b *testing.B)
- func BenchmarkFlightThroughput(b *testing.B)
- func RunFlightThroughputBenchmarks(serverAddr, parquetDir string) error
- func TestFlightThroughputBenchmark(t *testing.T)
- func WriteCSV(results []Result, w io.Writer) error
- func WriteJSON(results []Result, w io.Writer) error
- func WriteMarkdown(results []Result, w io.Writer) error
- type BenchmarkResult
- type FlightThroughputBenchmark
- func (b *FlightThroughputBenchmark) BenchmarkAggregation(tableName string) (*BenchmarkResult, error)
- func (b *FlightThroughputBenchmark) BenchmarkFilteredQuery(tableName string) (*BenchmarkResult, error)
- func (b *FlightThroughputBenchmark) BenchmarkFullTableScan(tableName string) (*BenchmarkResult, error)
- func (b *FlightThroughputBenchmark) BenchmarkJoinQuery(table1, table2 string) (*BenchmarkResult, error)
- func (b *FlightThroughputBenchmark) BenchmarkMetadata() (*BenchmarkResult, error)
- func (b *FlightThroughputBenchmark) BenchmarkPreparedStatement(tableName string) (*BenchmarkResult, error)
- func (b *FlightThroughputBenchmark) BenchmarkStreaming(tableName string) (*BenchmarkResult, error)
- func (b *FlightThroughputBenchmark) BenchmarkSustainedThroughput(tableName string, iterations int) (*BenchmarkResult, error)
- func (b *FlightThroughputBenchmark) Cleanup() error
- func (b *FlightThroughputBenchmark) Setup() error
- type Result
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BenchmarkCount ¶
func BenchmarkFilter ¶
func BenchmarkFlightThroughput ¶
Benchmark function for Go's testing framework
func RunFlightThroughputBenchmarks ¶
RunFlightThroughputBenchmarks runs all Flight throughput benchmarks
func TestFlightThroughputBenchmark ¶
Test function for the benchmark
Types ¶
type BenchmarkResult ¶
type BenchmarkResult struct {
Name string
Duration time.Duration
RowsReturned int64
BatchCount int
Throughput float64 // rows per second
DataSize int64 // bytes processed (if available)
}
BenchmarkResult represents the result of a benchmark run
func (*BenchmarkResult) String ¶
func (r *BenchmarkResult) String() string
type FlightThroughputBenchmark ¶
type FlightThroughputBenchmark struct {
// contains filtered or unexported fields
}
FlightThroughputBenchmark measures Flight protocol throughput
func NewFlightThroughputBenchmark ¶
func NewFlightThroughputBenchmark(serverAddr, parquetDir string) *FlightThroughputBenchmark
NewFlightThroughputBenchmark creates a new benchmark instance
func (*FlightThroughputBenchmark) BenchmarkAggregation ¶
func (b *FlightThroughputBenchmark) BenchmarkAggregation(tableName string) (*BenchmarkResult, error)
BenchmarkAggregation measures throughput for aggregation queries
func (*FlightThroughputBenchmark) BenchmarkFilteredQuery ¶
func (b *FlightThroughputBenchmark) BenchmarkFilteredQuery(tableName string) (*BenchmarkResult, error)
BenchmarkFilteredQuery measures throughput for filtered queries
func (*FlightThroughputBenchmark) BenchmarkFullTableScan ¶
func (b *FlightThroughputBenchmark) BenchmarkFullTableScan(tableName string) (*BenchmarkResult, error)
BenchmarkFullTableScan measures throughput for full table scans
func (*FlightThroughputBenchmark) BenchmarkJoinQuery ¶
func (b *FlightThroughputBenchmark) BenchmarkJoinQuery(table1, table2 string) (*BenchmarkResult, error)
BenchmarkJoinQuery measures throughput for join operations
func (*FlightThroughputBenchmark) BenchmarkMetadata ¶
func (b *FlightThroughputBenchmark) BenchmarkMetadata() (*BenchmarkResult, error)
BenchmarkMetadata measures throughput for metadata operations
func (*FlightThroughputBenchmark) BenchmarkPreparedStatement ¶
func (b *FlightThroughputBenchmark) BenchmarkPreparedStatement(tableName string) (*BenchmarkResult, error)
BenchmarkPreparedStatement measures throughput for prepared statements
func (*FlightThroughputBenchmark) BenchmarkStreaming ¶
func (b *FlightThroughputBenchmark) BenchmarkStreaming(tableName string) (*BenchmarkResult, error)
BenchmarkStreaming measures throughput for streaming queries
func (*FlightThroughputBenchmark) BenchmarkSustainedThroughput ¶
func (b *FlightThroughputBenchmark) BenchmarkSustainedThroughput(tableName string, iterations int) (*BenchmarkResult, error)
BenchmarkSustainedThroughput measures sustained throughput by loading the largest file multiple times
func (*FlightThroughputBenchmark) Cleanup ¶
func (b *FlightThroughputBenchmark) Cleanup() error
Cleanup releases resources
func (*FlightThroughputBenchmark) Setup ¶
func (b *FlightThroughputBenchmark) Setup() error
Setup initializes the benchmark
Source Files
Directories