List of all items

Structs

• adaptive_compression::CompressionResult
• adaptive_compression::DataProfile
• advanced_coordinator::types::AdvancedCoordinator
• advanced_coordinator::types::DomainLearningResult
• advanced_coordinator::types::EvolutionResult
• advanced_coordinator::types_2::AdaptiveImprovements
• advanced_coordinator::types_2::AdvancedProcessingResult
• advanced_coordinator::types_2::AdvancedStatistics
• advanced_coordinator::types_2::AppliedOptimization
• advanced_coordinator::types_2::EvolutionSummary
• advanced_coordinator::types_2::KnowledgeTransferResult
• advanced_coordinator::types_2::PerformanceIntelligenceStats
• advanced_coordinator::types_2::ProcessingResult
• advanced_coordinator::types_2::QualityMetrics
• advanced_coordinator::types_2::SystemImprovement
• advanced_coordinator::types_2::WorkflowOptimizationResult
• arff::ArffData
• arff::sparse::SparseArffData
• arff::sparse::SparseInstance
• arrow_ipc::ArrowField
• arrow_ipc::ArrowSchema
• arrow_ipc::ArrowStreamWriter
• arrow_ipc::RecordBatch
• arrow_streaming::ArrowStreamReader
• arrow_streaming::ArrowStreamWriter
• arrow_streaming::WriterStats
• async_io::AsyncChunkedReader
• async_io::AsyncLineReader
• async_io::AsyncStreamingConfig
• async_io::AsyncStreamingStats
• async_io::CancellationToken
• binary_format::BinaryReader
• binary_format::BinaryWriter
• binary_format::ScirsDataFile
• binary_formats::BinaryArrayFile
• binary_formats::ColumnarFile
• bmp::BmpImage
• cloud::AzureBlobStore
• cloud::GcsStore
• cloud::InstrumentedStore
• cloud::LocalObjectStore
• cloud::MemoryObjectStore
• cloud::MultipartUpload
• cloud::ObjectKey
• cloud::ObjectMetadata
• cloud::S3Store
• cloud::StorageConfig
• cloud::StorageStats
• cloud::UploadResult
• cloud::azure_sas::AzureSasParams
• cloud::azure_sas::SasPermissions
• cloud::gcs::GcsResumableUpload
• columnar::dictionary::DictionaryEncoder
• columnar::fsst::FsstColumnEncoder
• columnar::fsst::FsstSymbol
• columnar::fsst::FsstSymbolTable
• columnar::rle::RleEncoder
• columnar::rle::RleRun
• columnar::statistics::ColumnStats
• columnar::statistics::RowGroup
• columnar::statistics::RowGroupConfig
• columnar::statistics::TableStats
• columnar::types::Column
• columnar::types::ColumnarTable
• columnar::writer::ColumnarWriteOptions
• compression::CompressionBenchmarkResult
• compression::CompressionInfo
• compression::FileCompressionInfo
• compression::ParallelCompressionConfig
• compression::ParallelCompressionStats
• compression::TransparentFileHandler
• compression::advanced::BenchmarkResult
• compression::advanced::CompressionBenchmark
• compression::advanced::DeltaEncoding
• compression::advanced::FrameCompressor
• compression::advanced::LZ4Compressor
• compression::advanced::RunLengthEncoding
• compression::advanced::ZstdCompressor
• compression::ndarray::CompressedArray
• compression::ndarray::CompressedArrayMetadata
• csv::ColumnSpec
• csv::ColumnStats
• csv::CsvReaderConfig
• csv::CsvWriterConfig
• csv::MissingValueOptions
• csv::StreamingCsvConfig
• csv::StreamingCsvReader
• csv::StreamingStats
• database::ColumnDef
• database::DatabaseConfig
• database::DatabaseConnector
• database::Index
• database::QueryBuilder
• database::ResultSet
• database::TableSchema
• database::bulk::BulkInsertConfig
• database::mysql::MySQLConnection
• database::pool::ConnectionPool
• database::postgres::PostgreSQLConnection
• database::sqlite::SQLiteConnection
• database::table::ColumnSchema
• database::table::GroupBy
• database::table::InMemoryTable
• database::table::SortKey
• database::table::TableFilter
• database::table::TableJoin
• database::table::TableProjection
• database::table::TableSort
• database::timeseries::TimePoint
• database::timeseries::TimeSeries
• datafusion_provider::ColumnDef
• datafusion_provider::MemTableProvider
• datafusion_provider::RecordBatch
• datafusion_provider::TableSchema
• delta::log::TransactionLog
• delta::table::DeltaTableReader
• delta::table::DeltaTableWriter
• delta::types::ColumnSchema
• delta::types::DeltaConfig
• delta::types::DeltaTable
• delta::types::DeltaTransaction
• delta::types::DeltaVersion
• delta::types::FileInfo
• delta::types::Schema
• distributed::DistributedArray
• distributed::DistributedReader
• distributed::DistributedWriter
• distributed::FileMetadata
• distributed::LocalFileSystem
• distributed::WorkerInfo
• distributed::sharding::HashSharding
• distributed::sharding::RangeSharding
• distributed::sharding::RoundRobinSharding
• distributed::sharding::ShardConfig
• distributed::sharding::ShardReader
• distributed::sharding::ShardWriter
• distributed::sharding::ShardedArray
• distributed::sharding::ShardedArrayMeta
• distributed::sharding::VirtualConcatenation
• enhanced_algorithms::AdvancedPatternAnalysis
• enhanced_algorithms::AdvancedPatternRecognizer
• enhanced_algorithms::DataCharacteristics
• enhanced_algorithms::EmergentPattern
• enhanced_algorithms::MetaPattern
• enhanced_algorithms::OptimizationRecommendation
• exactly_once::ExactlyOnceSink
• exactly_once::WriteAheadLog
• format_detect::FormatDetection
• formats::astronomical::FitsFile
• formats::astronomical::FitsHeader
• formats::astronomical::FitsTableReader
• formats::astronomical::FitsWriter
• formats::astronomical::GeoTransform
• formats::astronomical::HDU
• formats::astronomical::HeaderCard
• formats::astronomical::VOTable
• formats::astronomical::VOTableColumn
• formats::astronomical::WCSTransform
• formats::avro::AvroField
• formats::avro::AvroReader
• formats::avro::AvroWriter
• formats::bioinformatics::FastaReader
• formats::bioinformatics::FastaRecord
• formats::bioinformatics::FastaRecordIterator
• formats::bioinformatics::FastaWriter
• formats::bioinformatics::FastqReader
• formats::bioinformatics::FastqRecord
• formats::bioinformatics::FastqRecordIterator
• formats::bioinformatics::FastqWriter
• formats::bioinformatics::analysis::Orf
• formats::bioinformatics::analysis::QualityStats
• formats::bioinformatics::analysis::SequenceStats
• formats::cbor::CborDecoder
• formats::cbor::CborEncoder
• formats::feather::FeatherColumn
• formats::feather::FeatherFile
• formats::geospatial::CRS
• formats::geospatial::Feature
• formats::geospatial::GeoJson
• formats::geospatial::GeoJsonFeature
• formats::geospatial::GeoJsonGeometry
• formats::geospatial::GeoTiff
• formats::geospatial::GeoTiffWriter
• formats::geospatial::GeoTransform
• formats::geospatial::KMLDocument
• formats::geospatial::KMLFeature
• formats::geospatial::KMLFolder
• formats::geospatial::KMLStyle
• formats::geospatial::Shapefile
• formats::msgpack::MsgPackReader
• formats::msgpack::MsgPackStreamReader
• formats::msgpack::MsgPackWriter
• formats::orc::ORCColumn
• formats::orc::ORCReader
• formats::orc::ORCStripe
• formats::orc::ORCWriter
• formats::orc_lite::IntRleV2
• formats::orc_lite::OrcLiteReader
• formats::orc_lite::OrcLiteWriter
• formats::orc_lite::StripeMetadata
• formats::protobuf::ProtoDecoder
• formats::protobuf::ProtoDescriptor
• formats::protobuf::ProtoField
• formats::protobuf::ProtoFieldDescriptor
• formats::protobuf::ProtoMessageBuilder
• formats::protobuf::VarintDecoder
• formats::protobuf::VarintEncoder
• fortran::FortranConfig
• fortran::FortranFile
• gpu::GpuBenchmarkResults
• gpu::GpuCapabilities
• gpu::MaintenanceReport
• gpu::UnifiedGpuProcessor
• gpu::UnifiedGpuStats
• gpu::backend_management::BackendCapabilities
• gpu::backend_management::BackendPerformanceProfile
• gpu::backend_management::GpuIoProcessor
• gpu::compression::CompressionStats
• gpu::compression::GpuCompressionProcessor
• gpu::memory_management::AdvancedGpuMemoryPool
• gpu::memory_management::AllocationStats
• gpu::memory_management::BufferMetadata
• gpu::memory_management::FragmentationManager
• gpu::memory_management::GlobalPoolStats
• gpu::memory_management::GpuMemoryPoolManager
• gpu::memory_management::PoolConfig
• gpu::memory_management::PoolStats
• gpu::memory_management::PooledBuffer
• harwell_boeing::HBHeader
• harwell_boeing::HBSparseMatrix
• hdf5::enhanced::AccessPattern
• hdf5::enhanced::AccessPatternAnalyzer
• hdf5::enhanced::AccessPatternStats
• hdf5::enhanced::CalibrationInfo
• hdf5::enhanced::CompressionStats
• hdf5::enhanced::EnhancedHDF5File
• hdf5::enhanced::HDF5PerformanceMonitor
• hdf5::enhanced::MemoryStats
• hdf5::enhanced::OptimizedHDF5File
• hdf5::enhanced::ParallelConfig
• hdf5::enhanced::PerformanceSummary
• hdf5::enhanced::ProvenanceInfo
• hdf5::enhanced::ScientificMetadata
• hdf5::enhanced::TransferStats
• hdf5::types_2::HDF5File
• hdf5::types_3::CompressionOptions
• hdf5::types_3::Dataset
• hdf5::types_3::DatasetOptions
• hdf5::types_3::FileStats
• hdf5::types_3::Group
• hdf5_lite::Hdf5Attribute
• hdf5_lite::Hdf5Dataset
• hdf5_lite::Hdf5Group
• hdf5_lite::Hdf5Node
• hdf5_lite::Hdf5Reader
• iceberg::IcebergField
• iceberg::IcebergSchema
• iceberg::IcebergSnapshot
• iceberg::IcebergTable
• iceberg::IcebergTableMetadata
• idl::IdlObject
• idl::IdlReader
• idl::IdlStructure
• idl::IdlWriter
• image::AnimationData
• image::CameraSettings
• image::ExifMetadata
• image::GpsCoordinates
• image::ImageData
• image::ImageMetadata
• image::enhanced::CompressionOptions
• image::enhanced::EnhancedImageProcessor
• image::enhanced::ImagePyramid
• image::enhanced::PyramidConfig
• jsonl::JsonlReader
• jsonl::JsonlStreamIter
• jsonl::JsonlWriter
• lance::types::LanceBatch
• lance::types::LanceField
• lance::types::LanceSchema
• lance::writer::LanceReader
• lance::writer::LanceWriter
• lineage::DataLineage
• lineage::DataNode
• lineage::NodeId
• lineage::Transformation
• matlab::enhanced::EnhancedMatFile
• matlab::enhanced::MatFileConfig
• matlab::enhanced::MatV73Features
• matlab::enhanced::MatV73Sparse
• matlab::v73_enhanced::CategoricalArray
• matlab::v73_enhanced::DateTimeArray
• matlab::v73_enhanced::FunctionHandle
• matlab::v73_enhanced::MatlabObject
• matlab::v73_enhanced::MatlabTable
• matlab::v73_enhanced::PartialIoSupport
• matlab::v73_enhanced::V73Features
• matlab::v73_enhanced::V73MatFile
• matrix_market::IOStats
• matrix_market::MMDenseMatrix
• matrix_market::MMHeader
• matrix_market::MMSparseMatrix
• matrix_market::ParallelConfig
• matrix_market::SparseEntry
• metadata::Metadata
• metadata::MetadataDiff
• metadata::MetadataExtractor
• metadata::MetadataIndex
• metadata::MetadataProvenance
• metadata::MetadataReferenceResolver
• metadata::MetadataRepository
• metadata::MetadataSchema
• metadata::MetadataTemplate
• metadata::MetadataTransformer
• metadata::MetadataVersion
• metadata::MetadataVersionControl
• metadata::ProcessingHistoryEntry
• metadata::ProvenanceEntry
• minibatch::BatchSampler
• minibatch::BatchSamplerConfig
• ml_framework::batch_processing::BatchProcessor
• ml_framework::batch_processing::DataLoader
• ml_framework::converters::coreml::CoreMLConverter
• ml_framework::converters::huggingface::HuggingFaceConverter
• ml_framework::converters::jax::JAXConverter
• ml_framework::converters::mxnet::MXNetConverter
• ml_framework::converters::onnx::ONNXConverter
• ml_framework::converters::pytorch::PyTorchConverter
• ml_framework::converters::safetensors::SafeTensorsConverter
• ml_framework::converters::tensorflow::TensorFlowConverter
• ml_framework::datasets::MLDataset
• ml_framework::optimization::ModelOptimizer
• ml_framework::quantization::ModelQuantizer
• ml_framework::quantization::QuantizationInfo
• ml_framework::quantization::QuantizedModel
• ml_framework::quantization::QuantizedTensor
• ml_framework::serving::ApiConfig
• ml_framework::serving::BatchStats
• ml_framework::serving::HealthChecker
• ml_framework::serving::InferenceRequest
• ml_framework::serving::InferenceResponse
• ml_framework::serving::LoadBalancer
• ml_framework::serving::ModelInfo
• ml_framework::serving::ModelServer
• ml_framework::serving::RateLimit
• ml_framework::serving::ServerConfig
• ml_framework::serving::ServerMetrics
• ml_framework::serving::grpc::GrpcPredictRequest
• ml_framework::serving::grpc::GrpcPredictResponse
• ml_framework::serving::grpc::GrpcStatus
• ml_framework::serving::grpc::GrpcTensor
• ml_framework::serving::rest::BatchPredictRequest
• ml_framework::serving::rest::BatchPredictResponse
• ml_framework::serving::rest::HealthResponse
• ml_framework::serving::rest::MetricsResponse
• ml_framework::serving::rest::PredictRequest
• ml_framework::serving::rest::PredictResponse
• ml_framework::types::MLModel
• ml_framework::types::MLTensor
• ml_framework::types::ModelMetadata
• ml_framework::types::TensorMetadata
• ml_framework::utils::SafeTensorsHeader
• ml_framework::utils::TensorInfo
• ml_framework::validation::BatchValidator
• ml_framework::validation::ConversionPath
• ml_framework::validation::ConversionStep
• ml_framework::validation::ModelValidator
• ml_framework::validation::ValidationConfig
• ml_framework::validation::ValidationError
• ml_framework::validation::ValidationRecommendation
• ml_framework::validation::ValidationReport
• ml_framework::validation::ValidationWarning
• mmap::MmapArray
• mmap::MmapArrayBuilder
• mmap::MmapArrayMut
• mmap::MmapConfig
• mqtt_broker::broker::BrokerHandle
• mqtt_broker::broker::InProcessBroker
• mqtt_broker::types::BrokerConfig
• mqtt_broker::types::MqttMessage
• ndjson_streaming::CsvStreamReader
• ndjson_streaming::NdjsonReader
• ndjson_streaming::NdjsonWriter
• netcdf::NetCDFFile
• netcdf::NetCDFOptions
• netcdf_lite::NcDimension
• netcdf_lite::NcFile
• netcdf_lite::NcVariable
• network::NetworkClient
• network::NetworkConfig
• network::cloud::AzureConfig
• network::cloud::FileMetadata
• network::cloud::GcsConfig
• network::cloud::S3Config
• network::http::HttpClient
• network::http::HttpResponse
• network::streaming::ChunkedReader
• network::streaming::ChunkedWriter
• network::streaming::ProgressReader
• network::streaming::ProgressWriter
• network::streaming::StreamConfig
• network::streaming::StreamProgress
• neural_adaptive_io::AdamOptimizer
• neural_adaptive_io::AdaptationStats
• neural_adaptive_io::AdvancedIoProcessor
• neural_adaptive_io::ConcreteOptimizationParams
• neural_adaptive_io::EnsembleNeuralNetwork
• neural_adaptive_io::EnsembleStats
• neural_adaptive_io::NeuralAdaptiveIoController
• neural_adaptive_io::NeuralIoNetwork
• neural_adaptive_io::OptimizationDecisions
• neural_adaptive_io::PerformanceFeedback
• neural_adaptive_io::ReinforcementLearningAgent
• neural_adaptive_io::ReinforcementLearningStats
• neural_adaptive_io::SystemMetrics
• npy::npz::NpzArchive
• npy::types::NpyHeader
• out_of_core::OutOfCoreArray
• out_of_core::OutOfCoreConfig
• out_of_core::OutOfCoreSorter
• out_of_core::SlidingWindow
• out_of_core::VirtualArray
• parquet::options::ParquetWriteOptions
• parquet::predicates::FilterConfig
• parquet::predicates::PredicateAnalysis
• parquet::reader::ParquetChunkIterator
• parquet::reader::ParquetData
• parquet::reader::ParquetReader
• parquet::schema::ParquetSchema
• parquet::statistics::ColumnStatistics
• parquet::statistics::ParquetFileStatistics
• parquet::writer::ParquetWriter
• parquet_lite::ParquetReader
• parquet_lite::ParquetSchema
• parquet_lite::ParquetWriter
• pipeline::AdaptationEvent
• pipeline::AggregateTransform
• pipeline::AggregationStage
• pipeline::Alert
• pipeline::AsyncExecutor
• pipeline::AutoTuner
• pipeline::AutoTuningParameters
• pipeline::BackpressureStreamingExecutor
• pipeline::BranchingPipelineBuilder
• pipeline::CacheConfiguration
• pipeline::CachePerformance
• pipeline::CacheStage
• pipeline::CachedExecutor
• pipeline::CheckpointedExecutor
• pipeline::ConsciousnessConfig
• pipeline::DataLineage
• pipeline::DistributedExecutor
• pipeline::EncodingTransform
• pipeline::EnrichmentStage
• pipeline::ErrorHandlingStage
• pipeline::EventDrivenExecutor
• pipeline::ExecutionRecord
• pipeline::ExecutorFactory
• pipeline::FallbackErrorHandler
• pipeline::FeatureEngineeringTransform
• pipeline::FileReadStage
• pipeline::FileWriteStage
• pipeline::FilterStage
• pipeline::ImputeTransform
• pipeline::MemoryUsage
• pipeline::MonitoringExecutor
• pipeline::MonitoringStage
• pipeline::MonitoringThresholds
• pipeline::NeuromorphicConfig
• pipeline::NeuromorphicMemory
• pipeline::NeuromorphicOptimizer
• pipeline::NormalizeTransform
• pipeline::NumaNode
• pipeline::NumaTopology
• pipeline::OptimizationReport
• pipeline::OptimizationSuggestion
• pipeline::OptimizedPipelineConfig
• pipeline::OutlierTransform
• pipeline::PCATransform
• pipeline::ParallelPipelineBuilder
• pipeline::ParallelStageExecutor
• pipeline::PerformanceHistory
• pipeline::PerformancePredictor
• pipeline::PerformanceTrend
• pipeline::Pipeline
• pipeline::PipelineBuilder
• pipeline::PipelineComposer
• pipeline::PipelineConfig
• pipeline::PipelineContext
• pipeline::PipelineData
• pipeline::PipelineMetrics
• pipeline::PipelineMonitor
• pipeline::PipelineOptimizer
• pipeline::PipelinePerformanceMetrics
• pipeline::PipelineProfile
• pipeline::PipelineStats
• pipeline::QuantumAnnealer
• pipeline::QuantumOptimizationConfig
• pipeline::QuantumOptimizer
• pipeline::QuantumState
• pipeline::RegressionDetector
• pipeline::ReshapeTransform
• pipeline::ResourceMonitor
• pipeline::RetryErrorHandler
• pipeline::RetryExecutor
• pipeline::SequentialExecutor
• pipeline::SerializedPipeline
• pipeline::SerializedStage
• pipeline::SkipErrorHandler
• pipeline::SpikePattern
• pipeline::SpikingNeuralNetwork
• pipeline::SpikingNeuron
• pipeline::StageMetrics
• pipeline::StreamingExecutor
• pipeline::SynapticConnection
• pipeline::SystemMetrics
• pipeline::TextProcessingTransform
• pipeline::TransformStage
• pipeline::TransformationRecord
• pipeline::TypeConvertTransform
• pipeline::ValidationStage
• pipeline::backpressure::BatchCollector
• pipeline::backpressure::BoundedBuffer
• pipeline::backpressure::FlowController
• pipeline::backpressure::FlowStats
• pipeline::backpressure::ThrottleTransform
• pipeline::config::AutoTuningParameters
• pipeline::config::CacheConfiguration
• pipeline::config::CachePerformance
• pipeline::config::ConsciousnessConfig
• pipeline::config::ExecutionRecord
• pipeline::config::MemoryUsage
• pipeline::config::NeuromorphicConfig
• pipeline::config::NumaNode
• pipeline::config::NumaTopology
• pipeline::config::OptimizedPipelineConfig
• pipeline::config::PipelinePerformanceMetrics
• pipeline::config::QuantumOptimizationConfig
• pipeline::config::RegressionDetector
• pipeline::config::SystemMetrics
• pipeline::monitoring::ResourceMonitor
• pipeline::neuromorphic::AdaptationEvent
• pipeline::neuromorphic::AdaptationHistory
• pipeline::neuromorphic::BioinspiredAdaptationEngine
• pipeline::neuromorphic::NetworkResponse
• pipeline::neuromorphic::NetworkState
• pipeline::neuromorphic::NeuromorphicMemory
• pipeline::neuromorphic::NeuromorphicOptimizationProblem
• pipeline::neuromorphic::NeuromorphicOptimizationResult
• pipeline::neuromorphic::NeuromorphicOptimizer
• pipeline::neuromorphic::NeuromorphicSolution
• pipeline::neuromorphic::NeuronState
• pipeline::neuromorphic::OptimizationVariable
• pipeline::neuromorphic::PlasticityProfile
• pipeline::neuromorphic::SpikePattern
• pipeline::neuromorphic::SpikeTrain
• pipeline::neuromorphic::SpikingNeuralNetwork
• pipeline::neuromorphic::SpikingNeuron
• pipeline::neuromorphic::SynapticConnection
• pipeline::neuromorphic::SynapticPlasticityManager
• pipeline::performance::AutoTuner
• pipeline::performance::PerformanceHistory
• pipeline::performance::PerformancePredictor
• pipeline::performance::PerformanceTrend
• pipeline::performance::PipelineProfile
• pipeline::quantum::EntanglementAnalysis
• pipeline::quantum::QuantumAnnealer
• pipeline::quantum::QuantumAnnealingResult
• pipeline::quantum::QuantumConstraint
• pipeline::quantum::QuantumConvergenceInfo
• pipeline::quantum::QuantumOptimizationResult
• pipeline::quantum::QuantumOptimizer
• pipeline::quantum::QuantumState
• pipeline::quantum::QuantumStateInfo
• pipeline::quantum::Qubit
• pipeline::sinks::AggregationSink
• pipeline::sinks::FieldStats
• pipeline::sinks::FileSink
• pipeline::sinks::MemorySink
• pipeline::sinks::MultiSink
• pipeline::sources::DatabaseSource
• pipeline::sources::FileSource
• pipeline::sources::GeneratorSource
• pipeline::sources::StreamSource
• pipeline::typed_transforms::AggregateTransform
• pipeline::typed_transforms::FilterTransform
• pipeline::typed_transforms::FlatMapTransform
• pipeline::typed_transforms::JoinTransform
• pipeline::typed_transforms::MapTransform
• pipeline::typed_transforms::TimedTransform
• pipeline::typed_transforms::TypedPipeline
• pipeline::typed_transforms::WindowTransform
• protobuf_lite::MessageBuilder
• quantum_inspired_io::QuantumAnnealingOptimizer
• quantum_inspired_io::QuantumErrorCorrection
• quantum_inspired_io::QuantumIoParams
• quantum_inspired_io::QuantumParallelProcessor
• quantum_inspired_io::QuantumPerformanceStats
• quantum_inspired_io::QuantumState
• query::Aggregations
• query::DataQuery
• query::GroupedResult
• query::QueryResult
• query::Row
• realtime::AggregationResult
• realtime::BackoffConfig
• realtime::BufferStats
• realtime::StreamAggregator
• realtime::StreamClient
• realtime::StreamClientBuilder
• realtime::StreamConfig
• realtime::StreamMetrics
• realtime::StreamProcessor
• realtime::StreamSynchronizer
• realtime::TimeSeriesBuffer
• s3_multipart::MultipartConfig
• s3_multipart::MultipartUpload
• s3_multipart::UploadedPart
• schema_registry::registry::SchemaRegistry
• schema_registry::types::FieldDescriptor
• schema_registry::types::MessageDescriptor
• schema_registry::types::RegistryConfig
• schema_registry::types::Schema
• schema_registry::types::SchemaId
• schema_registry::types::SchemaVersion
• schema_registry::wire::ProtoDecoder
• schema_registry::wire::ProtoEncoder
• serialize::ArrayMetadata
• serialize::SerializedArray
• serialize::SparseMatrix
• serialize::SparseMatrixCOO
• serialize::SparseMatrixCSC
• serialize::SparseMatrixCSR
• simd_io::AdvancedSimdProcessor
• simd_io::SimdIoAccelerator
• simd_io::SimdIoProcessor
• simd_io::SimdOptimizationInfo
• simd_io::matrix_simd::CacheOptimizedMatrixProcessor
• sparse::SparseMatrix
• sparse::SparseStats
• streaming::ChunkedReader
• streaming::LineChunkedReader
• streaming::StreamingConfig
• streaming::StreamingCsvReader
• streaming::StreamingStats
• streaming::cdc::CdcColumnarSnapshot
• streaming::cdc::CdcEvent
• streaming::cdc::CdcLog
• streaming::checkpoint::CheckpointBarrier
• streaming::checkpoint::CheckpointConfig
• streaming::checkpoint::CheckpointManager
• streaming::log_parsing::AggregationConfig
• streaming::log_parsing::CommonLogParser
• streaming::log_parsing::JsonLogFieldMap
• streaming::log_parsing::JsonLogParser
• streaming::log_parsing::LogAggregator
• streaming::log_parsing::LogEntry
• streaming::log_parsing::LogSummary
• streaming::log_parsing::SyslogParser
• streaming::relational::CountAggregate
• streaming::relational::MaxAggregate
• streaming::relational::MinAggregate
• streaming::relational::StreamingDeduplicate
• streaming::relational::StreamingFilter
• streaming::relational::StreamingGroupBy
• streaming::relational::StreamingPipeline
• streaming::relational::StreamingProject
• streaming::relational::StreamingRename
• streaming::relational::StreamingSort
• streaming::relational::SumAggregate
• streaming::time_series_ingestion::CsvIngestionConfig
• streaming::time_series_ingestion::CsvIngestionResult
• streaming::time_series_ingestion::DataPoint
• streaming::time_series_ingestion::FlushPolicy
• streaming::time_series_ingestion::Gap
• streaming::time_series_ingestion::GapDetectionConfig
• streaming::time_series_ingestion::MonotonicityReport
• streaming::time_series_ingestion::MonotonicityViolation
• streaming::time_series_ingestion::TimeSeriesIngester
• streaming::watermark::TimestampedRecord
• streaming::watermark::WatermarkGenerator
• streaming::windows::SessionWindowAssigner
• streaming::windows::SlidingWindowAssigner
• streaming::windows::TumblingWindowAssigner
• streaming::windows::WindowAggregator
• streaming::windows::WindowBound
• streaming::windows::WindowBuffer
• streaming_csv::CsvStreamReader
• streaming_json::JsonLinesReader
• table_provider::ColumnBatch
• table_provider::CsvTableProvider
• table_provider::Field
• table_provider::InMemoryTable
• table_provider::RecordBatch
• table_provider::Schema
• tensors::onnx_proto::OnnxAttributeProto
• tensors::onnx_proto::OnnxGraphProto
• tensors::onnx_proto::OnnxModelProto
• tensors::onnx_proto::OnnxModelSummary
• tensors::onnx_proto::OnnxNodeProto
• tensors::onnx_proto::OnnxOperatorSetIdProto
• tensors::onnx_proto::OnnxTensorProto
• tensors::onnx_proto::OnnxValueInfoProto
• tensors::safetensors::SafeTensors
• tensors::safetensors::SafeTensorsHeader
• tensors::safetensors::TensorMeta
• tensors::tfrecord::Example
• tensors::tfrecord::TfRecord
• tensors::tfrecord::TfRecordReader
• thread_pool::ThreadPool
• thread_pool::ThreadPoolConfig
• thread_pool::ThreadPoolStats
• thread_pool::WorkItem
• tiledb::array::TileDBArray
• tiledb::types::Attribute
• tiledb::types::Dimension
• tiledb::types::TileDBConfig
• toml_ext::TomlConfig
• toml_ext::TomlFieldRule
• toml_ext::TomlSchema
• universal_reader::DataTable
• universal_reader::ReadOptions
• universal_reader::StreamingReader
• validation::DirectoryManifest
• validation::FormatValidator
• validation::FormatValidatorRegistry
• validation::IntegrityMetadata
• validation::ManifestEntry
• validation::ManifestVerificationReport
• validation::SchemaDefinition
• validation::SchemaValidationError
• validation::SchemaValidationResult
• validation::SchemaValidator
• validation::ValidationReport
• validation::formats::FormatValidationResult
• visualization::AnimatedVisualization
• visualization::AnimationConfig
• visualization::AnimationFrame
• visualization::Annotation
• visualization::AxisConfig
• visualization::CameraConfig
• visualization::DashboardBuilder
• visualization::DashboardConfig
• visualization::DashboardLayout
• visualization::DashboardPlot
• visualization::DataSeries
• visualization::DataSeries3D
• visualization::GridPosition
• visualization::LightingConfig
• visualization::Plot3DConfig
• visualization::PlotConfig
• visualization::PlotUpdate
• visualization::SeriesStyle
• visualization::Visualization3DBuilder
• visualization::VisualizationBuilder
• visualization::VisualizationServer
• visualization::external::JupyterIntegration
• visualization::external::PlotlyCloud
• wavfile::WavHeader
• wavfile::WavWriteConfig
• wavfile::resample::SincConfig
• workflow::functions::monitoring::TaskMetrics
• workflow::functions::monitoring::WorkflowMetrics
• workflow::functions::scheduling::ComplexSchedule
• workflow::functions::scheduling::WorkflowScheduler
• workflow::functions::tasks::TaskBuilder
• workflow::functions_2::dynamic::DynamicWorkflowGenerator
• workflow::functions_2::dynamic::ParameterDef
• workflow::functions_2::dynamic::WorkflowTemplate
• workflow::functions_2::engines::AirflowAdapter
• workflow::functions_2::engines::DagsterAdapter
• workflow::functions_2::engines::PrefectAdapter
• workflow::functions_3::distributed::DistributedExecutor
• workflow::functions_3::distributed::DistributedTask
• workflow::functions_3::distributed::WorkerCapabilities
• workflow::functions_3::distributed::WorkerNode
• workflow::functions_3::distributed::WorkerPool
• workflow::functions_3::events::EventDrivenExecutor
• workflow::functions_3::events::EventRule
• workflow::functions_3::versioning::WorkflowDiff
• workflow::functions_3::versioning::WorkflowVersion
• workflow::functions_3::versioning::WorkflowVersionControl
• workflow::functions_4::visualization::WorkflowVisualizer
• workflow::types::ExecutorConfig
• workflow::types::GpuRequirement
• workflow::types::NotificationConfig
• workflow::types::ResourceRequirements
• workflow::types::RetryPolicy
• workflow::types::ScheduleConfig
• workflow::types::Task
• workflow::types::TaskState
• workflow::types::Workflow
• workflow::types::WorkflowBuilder
• workflow::types::WorkflowConfig
• workflow::types::WorkflowExecutor
• workflow::types::WorkflowState
• zarr::ArrayMetadataV2
• zarr::ArrayMetadataV3
• zarr::BytesCodec
• zarr::ChunkGrid
• zarr::CodecMetadata
• zarr::CodecPipeline
• zarr::ConsolidatedMetadata
• zarr::DirectoryStore
• zarr::GroupMetadataV2
• zarr::GroupMetadataV3
• zarr::ShuffleCodec
• zarr::TransposeCodec
• zarr::ZarrArray
• zarr::ZstdCodec
• zarr::group::FsStore
• zarr::group::MemoryStore
• zarr::group::ZarrGroup
• zarr::types::ZarrArray
• zarr::types::ZarrArrayMeta
• zero_copy::AsyncConfig
• zero_copy::AsyncZeroCopyProcessor
• zero_copy::NumaTopologyInfo
• zero_copy::ZeroCopyArrayView
• zero_copy::ZeroCopyArrayViewMut
• zero_copy::ZeroCopyBinaryReader
• zero_copy::ZeroCopyCsvReader
• zero_copy::ZeroCopyLineIterator
• zero_copy::ZeroCopyReader
• zero_copy::ZeroCopyStreamProcessor
• zero_copy::ZeroCopyWriter
• zero_copy::simd_zero_copy::SimdZeroCopyOpsF32
• zero_copy::simd_zero_copy::SimdZeroCopyOpsF64

Enums

• adaptive_compression::CompressionAlgo
• advanced_coordinator::types_2::IntelligenceLevel
• advanced_coordinator::types_2::StrategyType
• arff::ArffValue
• arff::AttributeType
• arrow_ipc::ArrowColumn
• arrow_ipc::ArrowDataType
• arrow_streaming::StreamingCompression
• binary_format::DataRecord
• binary_formats::ColumnData
• cloud::StoreProviderType
• cloud::azure_sas::AzureError
• cloud::azure_sas::SasResource
• cloud::gcs::GcsError
• cloud::gcs::UploadStatus
• columnar::dictionary::UnknownPolicy
• columnar::statistics::Predicate
• columnar::types::ColumnData
• columnar::types::ColumnTypeTag
• columnar::types::EncodingType
• compression::CompressionAlgorithm
• compression::advanced::FrameCodec
• csv::ColumnType
• csv::DataValue
• csv::LineEnding
• database::DataType
• database::DatabaseType
• database::bulk::ConflictStrategy
• database::table::AggFunc
• database::table::ColumnType
• database::table::ColumnValue
• database::table::JoinType
• database::table::Predicate
• database::table::SortDirection
• datafusion_provider::BinaryOperator
• datafusion_provider::ColumnData
• datafusion_provider::DataType
• datafusion_provider::Expr
• datafusion_provider::LiteralValue
• datafusion_provider::TableProviderError
• delta::types::DeltaAction
• delta::types::DeltaError
• distributed::Distribution
• distributed::MergeStrategy
• distributed::PartitionStrategy
• distributed::WorkerStatus
• distributed::sharding::ElementType
• distributed::sharding::ShardingStrategy
• enhanced_algorithms::SynergyType
• error::IoError
• exactly_once::ExactlyOnceError
• format_detect::DataFormat
• format_detect::DetectionMethod
• formats::astronomical::CardValue
• formats::astronomical::FitsDataType
• formats::astronomical::HDUType
• formats::astronomical::VOTableValue
• formats::avro::AvroSchema
• formats::avro::AvroValue
• formats::bioinformatics::QualityEncoding
• formats::bson::BsonValue
• formats::cbor::CborValue
• formats::feather::FeatherData
• formats::geospatial::AttributeValue
• formats::geospatial::GeoTiffDataType
• formats::geospatial::Geometry
• formats::msgpack::MsgPackValue
• formats::orc::ORCType
• formats::orc_lite::ColumnEncoding
• formats::orc_lite::OrcColumnData
• formats::protobuf::ProtoType
• formats::protobuf::ProtoValue
• fortran::AccessMode
• fortran::EndianMode
• fortran::FortranType
• fortran::RecordMarkerSize
• fortran::RecordType
• gpu::backend_management::GpuWorkloadType
• gpu::memory_management::FragmentationTrend
• gpu::memory_management::MemoryType
• harwell_boeing::HBMatrixType
• hdf5::enhanced::AttributeValue
• hdf5::enhanced::ExtendedDataType
• hdf5::enhanced::LayoutOptimization
• hdf5::types::AttributeValue
• hdf5::types::DataArray
• hdf5::types_3::FileMode
• hdf5::types_3::HDF5DataType
• hdf5::types_3::StringEncoding
• hdf5_lite::Hdf5DataType
• hdf5_lite::Hdf5NodeType
• hdf5_lite::Hdf5Value
• iceberg::IcebergError
• iceberg::IcebergType
• iceberg::IcebergValue
• idl::IdlType
• image::ColorMode
• image::ImageFormat
• image::enhanced::CompressionQuality
• image::enhanced::InterpolationMethod
• joins::JoinType
• lance::types::LanceColumn
• lance::types::LanceDataType
• lineage::ColumnType
• lineage::DataSource
• matlab::MatType
• matlab::v73_enhanced::ExtendedMatType
• matrix_market::MMDataType
• matrix_market::MMFormat
• matrix_market::MMSymmetry
• metadata::MetadataConstraint
• metadata::MetadataFieldType
• metadata::MetadataFormat
• metadata::MetadataValue
• ml_framework::optimization::OptimizationTechnique
• ml_framework::quantization::QuantizationMethod
• ml_framework::serving::HealthStatus
• ml_framework::serving::LoadBalancingStrategy
• ml_framework::serving::ResponseStatus
• ml_framework::types::DataType
• ml_framework::types::MLFramework
• ml_framework::validation::ConversionComplexity
• ml_framework::validation::ConversionOperation
• ml_framework::validation::ErrorCategory
• ml_framework::validation::ErrorSeverity
• ml_framework::validation::EstimatedEffort
• ml_framework::validation::RecommendationCategory
• ml_framework::validation::RecommendationPriority
• ml_framework::validation::WarningCategory
• ml_framework::validation::WarningImpact
• mqtt_broker::types::QosLevel
• msgpack::MsgpackValue
• ndjson_streaming::CsvValue
• netcdf::NetCDFDataType
• netcdf::NetCDFFormat
• netcdf_lite::NcDataType
• netcdf_lite::NcValue
• network::cloud::CloudProvider
• network::http::HttpMethod
• npy::types::ByteOrder
• npy::types::NpyArray
• npy::types::NpyDtype
• parquet::options::CompressionCodec
• parquet::options::ParquetVersion
• parquet::predicates::ParquetPredicate
• parquet::predicates::PredicateValue
• parquet_lite::ColumnData
• parquet_lite::ColumnType
• pipeline::AggregationMethod
• pipeline::AlertSeverity
• pipeline::BatchProcessingMode
• pipeline::BinningStrategy
• pipeline::CacheReplacementPolicy
• pipeline::EncodingMethod
• pipeline::Event
• pipeline::FeatureOperation
• pipeline::FileFormat
• pipeline::ImputationStrategy
• pipeline::MemoryStrategy
• pipeline::NormalizationMethod
• pipeline::OutlierMethod
• pipeline::PipelineError
• pipeline::PlasticityRule
• pipeline::PrefetchStrategy
• pipeline::TextOperation
• pipeline::TrendDirection
• pipeline::config::BatchProcessingMode
• pipeline::config::CacheReplacementPolicy
• pipeline::config::MemoryStrategy
• pipeline::config::PrefetchStrategy
• pipeline::neuromorphic::AdaptationType
• pipeline::neuromorphic::PlasticityRule
• pipeline::performance::TrendDirection
• pipeline::quantum::QuantumConstraintType
• pipeline::quantum::QuantumGate
• pipeline::sinks::FileSinkFormat
• pipeline::sources::FileSourceFormat
• protobuf_lite::ProtobufField
• quantum_inspired_io::QuantumGate
• query::ColumnValue
• query::DataSource
• realtime::DataFormat
• realtime::Protocol
• realtime::SyncStrategy
• s3_multipart::UploadState
• schema_registry::types::FieldType
• schema_registry::types::FieldValue
• schema_registry::types::SchemaRegistryError
• schema_registry::wire::WireType
• schema_registry::wire::WireValue
• serialize::SerializationFormat
• serialize::SparseFormat
• sparse::SparseFormat
• streaming::cdc::CdcOperation
• streaming::cdc::CdcValue
• streaming::log_parsing::LogLevel
• streaming::time_series_ingestion::DeduplicationPolicy
• streaming::time_series_ingestion::DownsamplingMethod
• streaming::watermark::LateElementPolicy
• streaming::watermark::WatermarkStrategy
• streaming::windows::WindowType
• streaming_csv::ColumnType
• streaming_csv::TypedValue
• streaming_json::JsonValue
• table_provider::ColumnValues
• table_provider::DataType
• tensors::onnx_proto::WireType
• tensors::safetensors::DType
• tensors::tfrecord::Feature
• thread_pool::WorkType
• tiledb::types::ArraySchema
• tiledb::types::Compression
• tiledb::types::DataType
• tiledb::types::TileDBError
• tiledb::types::TileOrder
• toml_ext::TomlValueType
• universal_reader::DataColumn
• validation::ChecksumAlgorithm
• validation::SchemaConstraint
• validation::SchemaDataType
• validation::ValidationSource
• validation::formats::DataFormat
• visualization::LoopMode
• visualization::PlotType
• visualization::PlotType3D
• visualization::ScaleType
• visualization::TransitionType
• visualization::UpdateAction
• visualization::VisualizationFormat
• wavfile::WavFormat
• wavfile::WavOutputFormat
• wavfile::resample::ResampleQuality
• wavfile::resample::WindowFunction
• workflow::functions::scheduling::ScheduleDependency
• workflow::functions::scheduling::WorkflowSchedule
• workflow::functions_2::dynamic::ParameterType
• workflow::functions_2::dynamic::TaskGenerator
• workflow::functions_3::distributed::WorkerStatus
• workflow::functions_3::events::EventPattern
• workflow::functions_3::events::LogicalOperator
• workflow::functions_3::events::WorkflowEvent
• workflow::functions_3::versioning::DependencyChange
• workflow::types::NotificationChannel
• workflow::types::TaskStatus
• workflow::types::TaskType
• workflow::types::WorkflowStatus
• zarr::DataType
• zarr::Endian
• zarr::ZarrVersion
• zarr::types::ZarrCompressor
• zarr::types::ZarrDataType
• zero_copy::MemoryAdvice
• zero_copy::NumaMemoryPolicy

Traits

• cloud::ObjectStore
• database::DatabaseConnection
• datafusion_provider::TableProvider
• distributed::DistributedFileSystem
• formats::astronomical::FitsNumeric
• formats::geospatial::GeoTiffNumeric
• formats::protobuf::ProtoMessage
• ml_framework::converters::MLFrameworkConverter
• out_of_core::ArraySource
• out_of_core::ChunkProcessor
• parquet::conversion::FromArrowArray
• parquet::conversion::ToArrowArray
• parquet::schema::InferArrowType
• pipeline::DataEnricher
• pipeline::DataTransformer
• pipeline::ErrorHandler
• pipeline::Monitor
• pipeline::PipelineExecutor
• pipeline::PipelineStage
• pipeline::Validator
• pipeline::sinks::DataSink
• pipeline::sources::DataSource
• pipeline::typed_transforms::Transform
• streaming::checkpoint::CheckpointableState
• streaming::relational::StreamingAggregate
• streaming::relational::StreamingOp
• streaming::windows::WindowAssigner
• table_provider::TableProvider
• workflow::functions_2::engines::WorkflowEngineAdapter
• zarr::Codec
• zarr::group::ZarrKvStore

Macros

• pipeline
• stage

Functions

• adaptive_compression::auto_compress
• adaptive_compression::auto_decompress
• adaptive_compression::compress_adaptive
• adaptive_compression::compress_delta
• adaptive_compression::compress_huffman
• adaptive_compression::compress_lz77
• adaptive_compression::compress_oxi_brotli
• adaptive_compression::compress_oxi_lz4
• adaptive_compression::compress_oxi_zstd
• adaptive_compression::compress_rle
• adaptive_compression::decompress_adaptive
• adaptive_compression::decompress_delta
• adaptive_compression::decompress_huffman
• adaptive_compression::decompress_lz77
• adaptive_compression::decompress_oxi_brotli
• adaptive_compression::decompress_oxi_lz4
• adaptive_compression::decompress_oxi_zstd
• adaptive_compression::decompress_rle
• adaptive_compression::estimate_entropy
• adaptive_compression::profile_data
• adaptive_compression::recommend_algorithm
• adaptive_compression::select_oxi_algorithm
• arff::get_numeric_matrix
• arff::numeric_matrix_to_arff
• arff::read_arff
• arff::sparse::read_sparse_arff
• arff::sparse::write_sparse_arff
• arff::write_arff
• arrow_ipc::read_arrow_ipc
• arrow_ipc::read_arrow_ipc_bytes
• arrow_ipc::read_arrow_ipc_file
• arrow_ipc::read_arrow_ipc_stream
• arrow_ipc::write_arrow_ipc
• arrow_ipc::write_arrow_ipc_bytes
• arrow_ipc::write_arrow_ipc_file
• arrow_streaming::read_next_batch
• arrow_streaming::write_record_batch
• async_io::process_csv_async
• async_io::process_file_async
• binary_format::read_scirs
• binary_format::write_scirs
• binary_formats::msgpack_decode
• binary_formats::msgpack_encode
• bmp::read_bmp
• bmp::write_bmp
• cloud::azure_sas::build_sas_url
• cloud::azure_sas::generate_sas_token
• cloud::azure_sas::is_sas_valid
• cloud::azure_sas::parse_sas_token
• cloud::from_url
• cloud::parse_store_url
• columnar::delta::delta_decode_f64
• columnar::delta::delta_decode_i64
• columnar::delta::delta_encode_f64
• columnar::delta::delta_encode_i64
• columnar::delta::delta_plus_varint_decode
• columnar::delta::delta_plus_varint_encode
• columnar::delta::varint_decode
• columnar::delta::varint_encode
• columnar::delta::zigzag_decode
• columnar::delta::zigzag_encode
• columnar::encoding::decode_column
• columnar::encoding::encode_column
• columnar::encoding::read_delta_f64
• columnar::encoding::read_delta_i64
• columnar::encoding::read_dict_str
• columnar::encoding::read_plain_bool
• columnar::encoding::read_plain_f64
• columnar::encoding::read_plain_i64
• columnar::encoding::read_plain_str
• columnar::encoding::read_rle_bool
• columnar::encoding::read_rle_f64
• columnar::encoding::read_rle_i64
• columnar::encoding::read_rle_str
• columnar::encoding::write_delta_f64
• columnar::encoding::write_delta_i64
• columnar::encoding::write_dict_str
• columnar::encoding::write_plain_bool
• columnar::encoding::write_plain_f64
• columnar::encoding::write_plain_i64
• columnar::encoding::write_plain_str
• columnar::encoding::write_rle_bool
• columnar::encoding::write_rle_f64
• columnar::encoding::write_rle_i64
• columnar::encoding::write_rle_str
• columnar::reader::read_columnar
• columnar::statistics::extract_row_group
• columnar::statistics::filter_table
• columnar::statistics::read_columnar_with_columns
• columnar::statistics::select_columns
• columnar::statistics::split_into_row_groups
• columnar::writer::write_columnar
• columnar::writer::write_columnar_with_options
• compression::algorithm_info
• compression::benchmark_compression_algorithms
• compression::compress_data
• compression::compress_data_parallel
• compression::compress_file
• compression::compress_file_parallel
• compression::compression_ratio
• compression::copy_file_transparent
• compression::decompress_data
• compression::decompress_data_parallel
• compression::decompress_file
• compression::decompress_file_parallel
• compression::detect_compression_from_bytes
• compression::file_info_transparent
• compression::global_handler
• compression::init_global_handler
• compression::ndarray::compare_compression_algorithms
• compression::ndarray::compress_array
• compression::ndarray::compress_array_chunked
• compression::ndarray::compress_array_zero_copy
• compression::ndarray::decompress_array
• compression::ndarray::decompress_array_chunked
• compression::ndarray::decompress_array_zero_copy
• compression::read_file_transparent
• compression::write_file_transparent
• compression_utils::decode_varint_slice
• compression_utils::delta_decode_f64
• compression_utils::delta_decode_i64
• compression_utils::delta_encode_f64
• compression_utils::delta_encode_i64
• compression_utils::encode_varint_slice
• compression_utils::gzip_compress
• compression_utils::gzip_decompress
• compression_utils::lz4_compress
• compression_utils::lz4_decompress
• compression_utils::read_gzip
• compression_utils::rle_decode
• compression_utils::rle_encode
• compression_utils::varint_decode
• compression_utils::varint_encode
• compression_utils::write_gzip
• csv::aggregate_csv_statistics
• csv::detect_column_types
• csv::process_csv_streaming
• csv::process_csv_streaming_parallel
• csv::read_csv
• csv::read_csv_chunked
• csv::read_csv_numeric
• csv::read_csv_numeric_streaming
• csv::read_csv_typed
• csv::streaming_reader_from_file
• csv::write_csv
• csv::write_csv_columns
• csv::write_csv_typed
• database::bulk::bulk_insert
• database::bulk::bulk_update
• delta::log::parse_action_line
• delta::log::serialize_action
• delta::table::add_column
• delta::table::rename_column
• format_detect::detect_format
• format_detect::detect_format_detailed
• format_detect::detect_format_detailed_from_bytes
• format_detect::detect_format_from_bytes
• formats::avro::decode_int
• formats::avro::decode_long
• formats::avro::decode_value
• formats::avro::decode_varuint
• formats::avro::encode_int
• formats::avro::encode_long
• formats::avro::encode_value
• formats::avro::encode_varuint
• formats::avro::parse_schema_json
• formats::avro::read_avro_file
• formats::avro::schema_to_json
• formats::avro::write_avro_file
• formats::bioinformatics::analysis::find_orfs
• formats::bioinformatics::analysis::gc_content
• formats::bioinformatics::analysis::nucleotide_composition
• formats::bioinformatics::analysis::quality_stats
• formats::bioinformatics::analysis::reverse_complement
• formats::bioinformatics::analysis::sequence_stats
• formats::bioinformatics::analysis::translate_dna
• formats::bioinformatics::count_fastasequences
• formats::bioinformatics::count_fastqsequences
• formats::bson::decode_bson
• formats::bson::encode_bson
• formats::bson::read_bson_file
• formats::bson::write_bson_file
• formats::cbor::decode_cbor
• formats::cbor::encode_cbor
• formats::cbor::read_cbor_file
• formats::cbor::write_cbor_file
• formats::geospatial::geo_utils::bearing
• formats::geospatial::geo_utils::haversine_distance
• formats::geospatial::geo_utils::point_inpolygon
• formats::geospatial::geo_utils::polygon_area
• formats::geospatial::geo_utils::polygon_centroid
• formats::geospatial::geo_utils::transform_coordinates
• formats::msgpack::msgpack_decode
• formats::msgpack::msgpack_encode
• formats::msgpack::roundtrip
• formats::orc_lite::read_orc_lite
• formats::orc_lite::write_orc_lite
• formats::protobuf::decode_proto_fields
• formats::protobuf::zigzag_decode
• formats::protobuf::zigzag_encode
• fortran::detect_fortran_format
• fortran::read_fortran_file
• gpu::utils::benchmark_gpu_performance
• gpu::utils::create_optimized_processor
• gpu::utils::get_best_backend_for_workload
• gpu::utils::is_gpu_available
• harwell_boeing::ccs_to_hb
• harwell_boeing::ccs_to_hb_with_rhs
• harwell_boeing::hb_to_ccs
• harwell_boeing::read_harwell_boeing
• harwell_boeing::write_harwell_boeing
• hdf5::enhanced::create_optimal_compression_options
• hdf5::enhanced::read_hdf5_enhanced
• hdf5::enhanced::write_hdf5_enhanced
• hdf5::functions::create_hdf5_with_structure
• hdf5::functions::read_hdf5
• hdf5::functions::write_hdf5
• idl::read_idl
• idl::write_idl
• image::batch_process_images
• image::convert_image
• image::enhanced::batch_convert_with_compression
• image::enhanced::create_image_pyramid
• image::enhanced::save_high_quality
• image::enhanced::save_lossless
• image::find_images
• image::get_image_info
• image::load_animation
• image::load_image
• image::read_exif_metadata
• image::resize_image
• image::save_image
• joins::hash_join
• joins::merge_join
• joins::nested_loop_join
• jsonl::read_jsonl
• jsonl::stream_jsonl
• jsonl::write_jsonl
• lineage::export_lineage_dot
• lineage::get_provenance
• lineage::lineage_to_json
• lineage::record_transformation
• matlab::enhanced::create_cell_array
• matlab::enhanced::create_complex_array
• matlab::enhanced::create_struct
• matlab::enhanced::read_mat_enhanced
• matlab::enhanced::write_mat_enhanced
• matlab::read_mat
• matlab::write_extended::write_mat_extended
• matlab::write_extended::write_variable_compressed
• matlab::write_extended::write_variable_extended
• matlab::write_mat
• matrix_market::coo_to_sparse
• matrix_market::create_optimal_parallel_config
• matrix_market::read_dense_matrix
• matrix_market::read_sparse_matrix
• matrix_market::read_sparse_matrix_parallel
• matrix_market::sparse_to_coo
• matrix_market::write_dense_matrix
• matrix_market::write_sparse_matrix
• matrix_market::write_sparse_matrix_parallel
• metadata::schemas::geospatial_schema
• metadata::schemas::image_schema
• metadata::schemas::time_series_schema
• minibatch::train_val_test_split
• ml_framework::converters::get_converter
• ml_framework::serving::grpc::grpc_to_tensor
• ml_framework::serving::grpc::tensor_to_grpc
• ml_framework::serving::rest::rest_to_tensor
• ml_framework::serving::rest::tensor_to_rest
• ml_framework::utils::python_dict_to_tensor
• ml_framework::utils::read_safetensors_header
• ml_framework::utils::tensor_to_python_dict
• ml_framework::utils::write_safetensors_header
• ml_framework::validation::utils::find_best_conversion_path
• ml_framework::validation::utils::generate_compatibility_matrix
• ml_framework::validation::utils::quick_compatibility_check
• mmap::create_mmap_array
• mmap::read_mmap_array
• msgpack::decode
• msgpack::encode
• msgpack::from_msgpack
• msgpack::json_value_to_msgpack
• msgpack::msgpack_to_json_value
• msgpack::read_msgpack
• msgpack::to_msgpack
• msgpack::write_msgpack
• ndjson_streaming::append_ndjson_file
• ndjson_streaming::create_ndjson_file
• ndjson_streaming::open_ndjson_file
• ndjson_streaming::read_tsv
• ndjson_streaming::write_tsv
• netcdf::create_netcdf4_with_data
• netcdf::read_netcdf
• network::batch_download
• network::batch_upload_to_cloud
• network::cloud::create_mock_metadata
• network::cloud::generate_signed_url
• network::cloud::validate_config
• network::create_cloud_client
• network::download_file
• network::download_with_cache
• network::http::calculate_speed
• network::http::download_concurrent
• network::http::format_file_size
• network::http::format_speed
• network::streaming::async_copy_with_progress
• network::streaming::copy_with_progress
• network::upload_file
• npy::npy_reader::read_npy
• npy::npy_reader::read_npy_from_reader
• npy::npy_writer::write_npy
• npy::npy_writer::write_npy_f32
• npy::npy_writer::write_npy_f64
• npy::npy_writer::write_npy_f64_2d
• npy::npy_writer::write_npy_i32
• npy::npy_writer::write_npy_i64
• npy::npy_writer::write_npy_to_writer
• npy::npz::read_npz
• npy::npz::write_npz
• npy::types::parse_header_dict
• parquet::conversion::arrow_to_ndarray
• parquet::conversion::ndarray_to_arrow
• parquet::predicates::analyze_predicate_effectiveness
• parquet::predicates::read_parquet_filtered
• parquet::predicates::read_parquet_filtered_chunked
• parquet::reader::read_parquet
• parquet::reader::read_parquet_chunked
• parquet::reader::read_parquet_chunked_columns
• parquet::reader::read_parquet_columns
• parquet::schema::infer_arrow_schema
• parquet::statistics::read_parquet_statistics
• parquet::writer::write_parquet
• parquet::writer::write_parquet_batches
• parquet::writer::write_parquet_with_name
• pipeline::function_stage
• pipeline::sources::drain_source
• protobuf_lite::decode_fields
• protobuf_lite::decode_varint
• protobuf_lite::decode_zigzag_i64
• protobuf_lite::encode_field
• protobuf_lite::encode_fields
• protobuf_lite::encode_varint
• protobuf_lite::encode_zigzag_i64
• query::execute
• schema_registry::registry::is_compatible
• schema_registry::validation::validate_descriptor
• schema_registry::validation::validate_field_value
• schema_registry::wire::decode_message
• schema_registry::wire::decode_varint
• schema_registry::wire::encode_field
• schema_registry::wire::encode_message
• schema_registry::wire::encode_varint
• serialize::deserialize_array
• serialize::deserialize_array_with_metadata
• serialize::deserialize_array_zero_copy
• serialize::deserialize_enhanced_sparse_matrix
• serialize::deserialize_sparse_matrix
• serialize::deserialize_struct
• serialize::from_matrix_market
• serialize::read_array_binary
• serialize::read_array_json
• serialize::read_array_messagepack
• serialize::serialize_array
• serialize::serialize_array_with_metadata
• serialize::serialize_array_zero_copy
• serialize::serialize_enhanced_sparse_matrix
• serialize::serialize_sparse_matrix
• serialize::serialize_struct
• serialize::sparse_ops::add_coo
• serialize::sparse_ops::csr_matvec
• serialize::sparse_ops::transpose_coo
• serialize::to_matrix_market
• serialize::write_array_binary
• serialize::write_array_json
• serialize::write_array_messagepack
• simd_io::binary_simd::fast_memcopy
• simd_io::binary_simd::find_pattern_simd
• simd_io::binary_simd::popcount_simd
• simd_io::binary_simd::xor_simd
• simd_io::compression_simd::delta_decode_simd
• simd_io::compression_simd::delta_encode_simd
• simd_io::compression_simd::rle_encode_simd
• simd_io::csv_simd::find_delimiters_simd
• simd_io::csv_simd::parse_floats_simd
• simd_io::matrix_simd::elementwise_add_simd
• simd_io::matrix_simd::matmul_simd
• simd_io::matrix_simd::transpose_simd
• simd_io::stats_simd::mean_simd
• simd_io::stats_simd::minmax_simd
• simd_io::stats_simd::quantile_simd
• simd_io::stats_simd::variance_simd
• sparse::ops::spmm
• sparse::ops::spmv
• streaming::cdc::cdc_to_parquet
• streaming::cdc::debezium_json_parser
• streaming::cdc::parse_debezium_log
• streaming::cdc::replay_cdc
• streaming::log_parsing::parse_timestamp
• streaming::process_csv_chunked
• streaming::process_file_chunked
• streaming::relational::sort_jsonl_file
• streaming::time_series_ingestion::downsample
• streaming::time_series_ingestion::downsampling_writer
• streaming::time_series_ingestion::gap_detection
• streaming::time_series_ingestion::ingest_csv_reader
• streaming::time_series_ingestion::ingest_csv_stream
• streaming::time_series_ingestion::monotonic_check
• streaming_csv::infer_schema
• streaming_csv::read_typed_row
• streaming_json::extract_field
• streaming_json::flatten_json
• streaming_json::parse_json
• table_provider::filter_batch
• table_provider::project_batch
• table_provider::project_batch_by_indices
• tensors::onnx_proto::create_minimal_onnx
• tensors::onnx_proto::decode_field
• tensors::onnx_proto::decode_varint
• tensors::onnx_proto::encode_varint
• tensors::onnx_proto::write_field_tag
• tensors::tfrecord::build_example_floats
• tensors::tfrecord::build_example_int64
• tensors::tfrecord::crc32c
• tensors::tfrecord::encode_tfrecord
• tensors::tfrecord::masked_crc32c
• tensors::tfrecord::parse_example
• tensors::tfrecord::read_all_records
• thread_pool::execute
• thread_pool::global_thread_pool
• thread_pool::init_global_thread_pool
• thread_pool::optimal_config
• toml_ext::flatten_toml
• toml_ext::merge_tomls
• toml_ext::validate_toml_schema
• universal_reader::read_data
• validation::add_integrity_metadata
• validation::calculate_checksum
• validation::calculate_crc32
• validation::calculate_file_checksum
• validation::calculate_sha256
• validation::create_checksum_file
• validation::create_directory_manifest
• validation::formats::detect_file_format
• validation::formats::get_scientific_format_validators
• validation::formats::validate_file_format
• validation::formats::validate_format
• validation::generate_file_integrity_metadata
• validation::generate_validation_report
• validation::load_integrity_metadata
• validation::save_integrity_metadata
• validation::schema_from_json_schema
• validation::schema_helpers::array
• validation::schema_helpers::boolean
• validation::schema_helpers::date
• validation::schema_helpers::email
• validation::schema_helpers::integer
• validation::schema_helpers::non_negative_number
• validation::schema_helpers::number
• validation::schema_helpers::object
• validation::schema_helpers::positive_integer
• validation::schema_helpers::string
• validation::schema_helpers::union
• validation::schema_helpers::uuid
• validation::validate_file_exists_with_size
• validation::validate_file_integrity
• validation::verify_array_integrity
• validation::verify_checksum
• validation::verify_checksum_file
• validation::verify_file_checksum
• vectorized_eval::apply_mask
• vectorized_eval::eval_filter
• vectorized_eval::eval_projection
• visualization::quick::plot_heatmap
• visualization::quick::plot_histogram
• visualization::quick::plot_line
• visualization::quick::plot_scatter
• wavfile::read_wav
• wavfile::resample::resample
• wavfile::resample::resample_linear
• wavfile::resample::resample_sinc
• wavfile::resample::resampled_length
• wavfile::resample::sample_rate_ratio
• wavfile::write_wav
• wavfile::write_wav_config
• workflow::functions::monitoring::collect_metrics
• workflow::functions::tasks::data_ingestion
• workflow::functions::tasks::export
• workflow::functions::tasks::transform
• workflow::functions::tasks::validation
• workflow::functions::templates::batch_processing
• workflow::functions::templates::etlworkflow

Type Aliases

• columnar::dictionary::StringDictionaryEncoder
• error::Result
• formats::bson::BsonDocument
• formats::protobuf::ProtoResult
• jsonl::JsonlResult
• mqtt_broker::broker::MessageHandler
• network::http::ProgressCallback
• network::streaming::ProgressCallback
• parquet_lite::ParquetLiteResult
• pipeline::PipelineResult
• pipeline::sources::StreamSender
• protobuf_lite::ProtoResult
• schema_registry::types::SchemaRegistryResult
• streaming::cdc::RowImage
• streaming_csv::TypedRow
• toml_ext::TomlResult

Constants

• columnar::types::COLUMNAR_MAGIC
• columnar::types::FORMAT_VERSION
• lance::writer::LANCE_EOF
• lance::writer::LANCE_MAGIC
• metadata::standard_keys::AUTHOR
• metadata::standard_keys::COORDINATE_SYSTEM
• metadata::standard_keys::CREATION_DATE
• metadata::standard_keys::DESCRIPTION
• metadata::standard_keys::DIMENSIONS
• metadata::standard_keys::EXPERIMENT
• metadata::standard_keys::INSTRUMENT
• metadata::standard_keys::KEYWORDS
• metadata::standard_keys::LICENSE
• metadata::standard_keys::MODIFICATION_DATE
• metadata::standard_keys::PROCESSING_HISTORY
• metadata::standard_keys::PROVENANCE
• metadata::standard_keys::REFERENCES
• metadata::standard_keys::TITLE
• metadata::standard_keys::UNITS
• metadata::standard_keys::VERSION
• npy::types::NPY_MAGIC
• npy::types::NPY_MAJOR_VERSION
• npy::types::NPY_MINOR_VERSION
• schema_registry::validation::MAX_FIELD_NUMBER
• schema_registry::validation::RESERVED_RANGE_END
• schema_registry::validation::RESERVED_RANGE_START