gpu_chunking Namespace Reference

Classes
class	GPUChunking

Functions
__global__ void	chunk_kernel (const int *data, int *chunk_boundaries, int data_size, int window_size, float threshold)

Function Documentation

chunk_kernel()

__global__ void gpu_chunking::chunk_kernel	(	const int *	data,
		int *	chunk_boundaries,
		int	data_size,
		int	window_size,
		float	threshold
	)

Definition at line 21 of file gpu_chunking.hpp.

                                              {
    int idx = blockIdx.x * blockDim.x + threadIdx.x;
    if (idx >= data_size - window_size)
        return;
 
    // Compute local statistics for the window
    float window_sum = 0.0f;
    float window_max = data[idx];
    float window_min = data[idx];
 
    for (int i = 0; i < window_size; ++i) {
        int current = data[idx + i];
        window_sum += current;
        window_max = max(window_max, (float)current);
        window_min = min(window_min, (float)current);
    }
 
    float window_mean = window_sum / window_size;
    float variance = 0.0f;
 
    // Compute variance
    for (int i = 0; i < window_size; ++i) {
        float diff = data[idx + i] - window_mean;
        variance += diff * diff;
    }
    variance /= window_size;
 
    // Determine if this position should be a chunk boundary
    bool is_boundary = false;
    if (idx > 0) {
        float prev_value = data[idx - 1];
        float current_value = data[idx];
        float value_diff = abs(current_value - prev_value);
        float range = window_max - window_min;
 
        is_boundary = (value_diff > threshold * range) && (variance > threshold * window_mean);
    }
 
    chunk_boundaries[idx] = is_boundary ? 1 : 0;
}