32_columnContainer = columnContainer; 37_columnContainer = new PrimitiveColumnContainer<T>(values); 43_columnContainer = new PrimitiveColumnContainer<T>(values); 49_columnContainer = new PrimitiveColumnContainer<T>(length); 54_columnContainer = new PrimitiveColumnContainer<T>(buffer, nullBitMap, length, nullCount);

22PrimitiveColumnComputation<T>.Instance.Abs(ret._columnContainer); 28PrimitiveColumnComputation<T>.Instance.All(_columnContainer, out bool ret); 34PrimitiveColumnComputation<T>.Instance.Any(_columnContainer, out bool ret); 41PrimitiveColumnComputation<T>.Instance.CumulativeMax(ret._columnContainer); 48PrimitiveColumnComputation<T>.Instance.CumulativeMax(ret._columnContainer, rowIndices); 55PrimitiveColumnComputation<T>.Instance.CumulativeMin(ret._columnContainer); 62PrimitiveColumnComputation<T>.Instance.CumulativeMin(ret._columnContainer, rowIndices); 69PrimitiveColumnComputation<T>.Instance.CumulativeProduct(ret._columnContainer); 76PrimitiveColumnComputation<T>.Instance.CumulativeProduct(ret._columnContainer, rowIndices); 83PrimitiveColumnComputation<T>.Instance.CumulativeSum(ret._columnContainer); 90PrimitiveColumnComputation<T>.Instance.CumulativeSum(ret._columnContainer, rowIndices); 96PrimitiveColumnComputation<T>.Instance.Max(_columnContainer, out T? ret); 102PrimitiveColumnComputation<T>.Instance.Max(_columnContainer, rowIndices, out T? ret); 108PrimitiveColumnComputation<T>.Instance.Min(_columnContainer, out T? ret); 114PrimitiveColumnComputation<T>.Instance.Min(_columnContainer, rowIndices, out T? ret); 120PrimitiveColumnComputation<T>.Instance.Product(_columnContainer, out T? ret); 126PrimitiveColumnComputation<T>.Instance.Product(_columnContainer, rowIndices, out T? ret); 132PrimitiveColumnComputation<T>.Instance.Sum(_columnContainer, out T? ret); 138PrimitiveColumnComputation<T>.Instance.Sum(_columnContainer, rowIndices, out T? ret); 145PrimitiveColumnComputation<T>.Instance.Round(ret._columnContainer);

28internal PrimitiveColumnContainer<T> ColumnContainer => _columnContainer; 38Length = _columnContainer.Length; 44Length = _columnContainer.Length; 64for (int i = 0; i < _columnContainer.Buffers.Count; i++) 66yield return _columnContainer.Buffers[i].ReadOnlyMemory; 77for (int i = 0; i < _columnContainer.NullBitMapBuffers.Count; i++) 79ReadOnlyDataFrameBuffer<byte> buffer = _columnContainer.NullBitMapBuffers[i]; 116protected internal override int GetMaxRecordBatchLength(long startIndex) => _columnContainer.MaxRecordBatchLength(startIndex); 131int bufferIndex = numberOfRows == 0 ? 0 : _columnContainer.GetIndexOfBufferContainingRowIndex(startIndex); 134if (numberOfRows != 0 && numberOfRows > _columnContainer.Buffers[bufferIndex].Length - offset) 147ReadOnlyDataFrameBuffer<T> valueBuffer = (numberOfRows == 0) ? null : _columnContainer.Buffers[bufferIndex]; 148ReadOnlyDataFrameBuffer<byte> nullBuffer = (numberOfRows == 0) ? null : _columnContainer.NullBitMapBuffers[bufferIndex]; 165ArrowBuffer arrowValueBuffer = numberOfRows == 0 ? ArrowBuffer.Empty : new ArrowBuffer(_columnContainer.Buffers[bufferIndex].ReadOnlyBuffer); 166ArrowBuffer arrowNullBuffer = numberOfRows == 0 ? ArrowBuffer.Empty : new ArrowBuffer(_columnContainer.NullBitMapBuffers[bufferIndex].ReadOnlyBuffer); 203return _columnContainer[startIndex, length]; 233protected T? GetTypedValue(long rowIndex) => _columnContainer[rowIndex]; 241_columnContainer[rowIndex] = (T?)value; 252set => _columnContainer[rowIndex] = value; 285_columnContainer.Resize(length); 286Length = _columnContainer.Length; 291_columnContainer.Append(value); 297_columnContainer.AppendMany(value, count); 306Debug.Assert(_columnContainer.NullCount >= 0); 307return _columnContainer.NullCount; 312public override bool IsValid(long index) => _columnContainer.IsValid(index); 314public IEnumerator<T?> GetEnumerator() => _columnContainer.GetEnumerator(); 451var newColumnContainer = _columnContainer.Clone(); 484retContainer = _columnContainer.Clone(mapIndices._columnContainer, typeof(long), invertMapIndices); 488retContainer = _columnContainer.Clone(mapIndices._columnContainer, typeof(int), invertMapIndices); 522var value = _columnContainer[curRow]; 535PrimitiveColumnContainer<bool> newColumnContainer = _columnContainer.CloneAsBoolContainer(); 541PrimitiveColumnContainer<byte> newColumnContainer = _columnContainer.CloneAsByteContainer(); 547PrimitiveColumnContainer<sbyte> newColumnContainer = _columnContainer.CloneAsSByteContainer(); 553PrimitiveColumnContainer<double> newColumnContainer = _columnContainer.CloneAsDoubleContainer(); 559PrimitiveColumnContainer<decimal> newColumnContainer = _columnContainer.CloneAsDecimalContainer(); 565PrimitiveColumnContainer<short> newColumnContainer = _columnContainer.CloneAsShortContainer(); 572PrimitiveColumnContainer<ushort> newColumnContainer = _columnContainer.CloneAsUShortContainer(); 578PrimitiveColumnContainer<int> newColumnContainer = _columnContainer.CloneAsIntContainer(); 584PrimitiveColumnContainer<uint> newColumnContainer = _columnContainer.CloneAsUIntContainer(); 590PrimitiveColumnContainer<long> newColumnContainer = _columnContainer.CloneAsLongContainer(); 596PrimitiveColumnContainer<ulong> newColumnContainer = _columnContainer.CloneAsULongContainer(); 602PrimitiveColumnContainer<float> newColumnContainer = _columnContainer.CloneAsFloatContainer(); 619for (int b = 0; b < _columnContainer.Buffers.Count; b++) 621ReadOnlyDataFrameBuffer<T> buffer = _columnContainer.Buffers[b]; 623ReadOnlySpan<byte> nullBitMapSpan = _columnContainer.NullBitMapBuffers[b].ReadOnlySpan; 659public void ApplyElementwise(Func<T?, long, T?> func) => _columnContainer.ApplyElementwise(func); 684_columnContainer.Apply(func, resultColumn._columnContainer); 966newColumn._columnContainer.HandleOperation(operation, column._columnContainer); 980newColumn._columnContainer.HandleOperation(operation, column._columnContainer); 990decimalColumn._columnContainer.HandleOperation(operation, column.CloneAsDecimalColumn()._columnContainer); 1015newColumn._columnContainer.HandleOperation(operation, column._columnContainer); 1027decimalColumn._columnContainer.HandleOperation(operation, (column as PrimitiveDataFrameColumn<decimal>)._columnContainer); 1033doubleColumn._columnContainer.HandleOperation(operation, column.CloneAsDoubleColumn()._columnContainer); 1058newColumn._columnContainer.HandleOperation(operation, Unsafe.As<U, T>(ref value)); 1068decimalColumn._columnContainer.HandleOperation(operation, DecimalConverter<U>.Instance.GetDecimal(value)); 1093newColumn._columnContainer.HandleOperation(operation, Unsafe.As<U, T>(ref value)); 1105decimalColumn._columnContainer.HandleOperation(operation, DecimalConverter<U>.Instance.GetDecimal(value)); 1111doubleColumn._columnContainer.HandleOperation(operation, DoubleConverter<U>.Instance.GetDouble(value)); 1135newColumn._columnContainer.HandleReverseOperation(operation, Unsafe.As<U, T>(ref value)); 1145clonedDecimalColumn._columnContainer.HandleReverseOperation(operation, DecimalConverter<U>.Instance.GetDecimal(value)); 1169newColumn._columnContainer.HandleReverseOperation(operation, Unsafe.As<U, T>(ref value)); 1181decimalColumn._columnContainer.HandleReverseOperation(operation, DecimalConverter<U>.Instance.GetDecimal(value)); 1187clonedDoubleColumn._columnContainer.HandleReverseOperation(operation, DoubleConverter<U>.Instance.GetDouble(value)); 1207retColumn._columnContainer.HandleOperation(operation, Unsafe.As<U, bool>(ref value)); 1224newbyteColumn._columnContainer.HandleOperation(operation, value); 1229newcharColumn._columnContainer.HandleOperation(operation, value); 1240newintColumn._columnContainer.HandleOperation(operation, value); 1245newlongColumn._columnContainer.HandleOperation(operation, value); 1250newsbyteColumn._columnContainer.HandleOperation(operation, value); 1255newshortColumn._columnContainer.HandleOperation(operation, value); 1260newuintColumn._columnContainer.HandleOperation(operation, value); 1265newulongColumn._columnContainer.HandleOperation(operation, value); 1270newushortColumn._columnContainer.HandleOperation(operation, value); 1293return new BooleanDataFrameColumn(Name, (this as PrimitiveDataFrameColumn<U>)._columnContainer.HandleOperation(operation, column._columnContainer)); 1303return new BooleanDataFrameColumn(Name, primitiveColumn._columnContainer.HandleOperation(operation, column._columnContainer)); 1308return new BooleanDataFrameColumn(Name, decimalColumn._columnContainer.HandleOperation(operation, column.CloneAsDecimalColumn()._columnContainer)); 1315return new BooleanDataFrameColumn(Name, (this as PrimitiveDataFrameColumn<U>)._columnContainer.HandleOperation(operation, column._columnContainer)); 1335return new BooleanDataFrameColumn(Name, primitiveColumn._columnContainer.HandleOperation(operation, column._columnContainer)); 1342return new BooleanDataFrameColumn(Name, decimalColumn._columnContainer.HandleOperation(operation, (column as PrimitiveDataFrameColumn<decimal>)._columnContainer)); 1347return new BooleanDataFrameColumn(Name, doubleColumn._columnContainer.HandleOperation(operation, column.CloneAsDoubleColumn()._columnContainer)); 1364return new BooleanDataFrameColumn(Name, (this as PrimitiveDataFrameColumn<bool>)._columnContainer.HandleOperation(operation, Unsafe.As<U, bool>(ref value))); 1374return new BooleanDataFrameColumn(Name, primitiveColumn._columnContainer.HandleOperation(operation, Unsafe.As<U, T>(ref value))); 1379return new BooleanDataFrameColumn(Name, decimalColumn._columnContainer.HandleOperation(operation, DecimalConverter<U>.Instance.GetDecimal(value))); 1386return new BooleanDataFrameColumn(Name, (this as PrimitiveDataFrameColumn<DateTime>)._columnContainer.HandleOperation(operation, Unsafe.As<U, DateTime>(ref value))); 1406return new BooleanDataFrameColumn(Name, primitiveColumn._columnContainer.HandleOperation(operation, Unsafe.As<U, T>(ref value))); 1413return new BooleanDataFrameColumn(Name, decimalColumn._columnContainer.HandleOperation(operation, DecimalConverter<U>.Instance.GetDecimal(value))); 1418return new BooleanDataFrameColumn(Name, doubleColumn._columnContainer.HandleOperation(operation, DoubleConverter<U>.Instance.GetDouble(value)));

25List<List<int>> bufferSortIndices = new List<List<int>>(_columnContainer.Buffers.Count); 29for (int b = 0; b < _columnContainer.Buffers.Count; b++) 31ReadOnlyDataFrameBuffer<T> buffer = _columnContainer.Buffers[b]; 32ReadOnlySpan<byte> nullBitMapSpan = _columnContainer.NullBitMapBuffers[b].ReadOnlySpan; 50columnNullIndices[nullIndicesSlot] = localSortIndex + b * _columnContainer.Buffers[0].Length; 62ReadOnlyMemory<byte> buffer = _columnContainer.Buffers[bufferIndex].ReadOnlyBuffer; 72value = _columnContainer.Buffers[bufferIndex][index]; 76value = _columnContainer.Buffers[bufferIndex][index]; 82IList<ReadOnlyDataFrameBuffer<T>> buffers = _columnContainer.Buffers;