Apache Arrow

An implementation of Arrow targeting .NET Standard.

This implementation is under development and may not be suitable for use in production environments.

Implementation

• Arrow 0.11 (specification)
• C# 7.2
• .NET Standard 1.3
• Asynchronous I/O
• Uses modern .NET runtime features such as Span<T>, Memory<T>, MemoryManager<T>, and System.Buffers primitives for memory allocation, memory storage, and fast serialization.
• Uses Acyclic Visitor Pattern for array types and arrays to facilitate serialization, record batch traversal, and format growth.

Known Issues

• Can not read Arrow files containing dictionary batches, tensors, or tables.
• Can not easily modify allocation strategy without implementing a custom memory pool. All allocations are currently 64-byte aligned and padded to 8-bytes.
• Default memory allocation strategy uses an over-allocation strategy with pointer fixing, which results in significant memory overhead for small buffers. A buffer that requires a single byte for storage may be backed by an allocation of up to 64-bytes to satisfy alignment requirements.
• There are currently few builder APIs available for specific array types. Arrays must be built manually with an arrow buffer builder abstraction.
• FlatBuffer code generation is not included in the build process.
• Serialization implementation does not perform exhaustive validation checks during deserialization in every scenario.
• Throws exceptions with vague, inconsistent, or non-localized messages in many situations
• Throws exceptions that are non-specific to the Arrow implementation in some circumstances where it probably should (eg. does not throw ArrowException exceptions)
• Lack of code documentation
• Lack of usage examples
• Lack of comprehensive unit tests
• Lack of comprehensive benchmarks

Usage

using System.Diagnostics;
using System.IO;
using System.Threading.Tasks;
using Apache.Arrow;
using Apache.Arrow.Ipc;

public static async Task<RecordBatch> ReadArrowAsync(string filename)
{
    using (var stream = File.OpenRead("test.arrow"))
    using (var reader = new ArrowFileReader(stream))
    {
        var recordBatch = await reader.ReadNextRecordBatchAsync();
        Debug.WriteLine("Read record batch with {0} column(s)", recordBatch.ColumnCount);
        return recordBatch;
    }
}

Status

Memory Management

• Allocations are 64-byte aligned and padded to 8-bytes.
• Allocations are automatically garbage collected

Arrays

Primitive Types

• Int8, Int16, Int32, Int64
• UInt8, UInt16, UInt32, UInt64
• Float, Double
• Binary (variable-length)
• String (utf-8)
• Null

Parametric Types

• Timestamp
• Date32
• Date64
• Time32
• Time64
• Binary (fixed-length)
• List

Type Metadata

• Data Types
• Fields
• Schema

Serialization

• File
• Stream

Not Implemented

• Serialization
  • Exhaustive validation
  • Dictionary Batch
    • Can not serialize or deserialize files or streams containing dictionary batches
  • Dictionary Encoding
  • Schema Metadata
  • Schema Field Metadata
• Types
  • Tensor
  • Table
• Arrays
  • Struct
  • Union
    • Dense
    • Sparse
  • Half-Float
  • Decimal
  • Dictionary
• Array Operations
  • Equality / Comparison
  • Casting
  • Builders
• Compute
  • There is currently no API available for a compute / kernel abstraction.

Build

dotnet build

Docker Build

Build from the Apache Arrow project root.

docker build -f csharp/build/docker/Dockerfile .

Testing

dotnet test test/Apache.Arrow.Tests

All build artifacts are placed in the artifacts folder in the project root.