Dataspine core
Defines the core DSL surface (com.dataspine and related namespaces): scalars, text, collections, errors, data-stream transforms, integrations, and JSON helpers used by every data product runtime.
- Library id:
dataspine-core - Namespace:
com.dataspine - Version:
1 - Crate:
dataspine-data-plane-runtime@0.1.100 - Stability:
stable - Since:
0.1.0
Types
AggregateByDataStream— Keyed aggregation over a data stream.AggregateChange— Change event for an aggregate bucket.AggregateUpdate— Aggregate update payload.AnnotationInstance— Runtime annotation marker.Boolean— True or false flag.Byte— 8-bit signed integer.Bytes— Immutable byte buffer.Character— Single text code unit.Class— Reference to a DSL class.DataStream— Typed stream of records.Exception— Structured failure value.FailureCause— Machine-readable failure reason.FailureStrategy— How to react to a failure.FilteringDataStream— Stream with a filter stage.Float32— 32-bit IEEE floating point.Float64— 64-bit IEEE floating point.Flow— Control-flow graph node.ForEachDataStream— Per-element stream expansion.IndexByDataStream— Stream materialized as an index.IndexCommand— Command to mutate an index.IndexOperationResult— Outcome of an index command.Ingest— Inbound data source handle.Integer16— 16-bit signed integer.Integer32— 32-bit signed integer.Integer64— 64-bit signed integer.JoinResult— Matched join rows.JoinTrigger— Join evaluation trigger.JsonParsingError— JSON text did not match the expected shape.KeyValueApi— Typed key-value RPC facade.KeyValueApiCommand— Serialized key-value API command.KeyValueStore— Durable key-value abstraction.Lambda— AWS Lambda integration handle.List— Ordered homogeneous collection.LocalDate— Calendar date without time.LocalDateTime— Local civil date and time.LookupResult— Single-key lookup outcome.Map— Associative key-value mapping.MapDataStream— Stream mapped per element.Number— Lossless numeric tower.NumberParsingError— Text could not be parsed as a number.NumericConversionError— Numeric formatting or conversion failed.Option— Optional value.Outlet— Downstream publish target.PublishDataStream— Stream bound for publishing.RawHttpResponse— HTTP response snapshot.RegularExpression— Compiled regex pattern.Result— Success or failure value.RpcApi— Outbound RPC client.String— Unicode text.StructInstance— Runtime struct value.TypedRuntimeObject— Erased runtime object reference.Uuid— 128-bit universally unique identifier.Value— Dynamic JSON value.Void— Unit type.
Namespace functions
error— —innerJoin— —interleave— —leftJoin— —log— —lookup— —max— —min— —parseFloat64— —parseInteger32— —parseInteger64— —serialize— —