Zum Inhalt
HALOWERK

Datenvertragswerk

aligned record cut audit

A stream-runtime fixture maintainer checks which record IDs belong to a supplied aligned checkpoint cut and which same-channel post-barrier records must stay buffered until all input barriers arrive. One aligned local checkpoint;record identities are source(channel,position) occurrences. No compiled peer machine or actual Flink/state-backend execution. Missing capture remains unknown;invalid profile HTTP400 before settlement. Successful unknown also costs0.003USDC. A schema-valid unknown is.

POST https://datenvertrag.halowerk.com/v1/aligned-record-cut-audit

Eingaben

Felder des veröffentlichten Eingabeschemas
FeldTypPflichtBeschreibung
channelsarrayJa
readsarrayJa
reads_completebooleanJa
trigger_claimSiehe SchemaJa
cut_claimSiehe SchemaJa
Vollständiges Eingabeschema anzeigen
{
  "type": "object",
  "additionalProperties": false,
  "properties": {
    "channels": {
      "type": "array",
      "items": {
        "type": "object",
        "additionalProperties": false,
        "properties": {
          "complete": {
            "type": "boolean"
          },
          "items": {
            "type": "array",
            "items": {
              "enum": [
                "record",
                "barrier"
              ]
            },
            "minItems": 0,
            "maxItems": 16
          }
        },
        "required": [
          "complete",
          "items"
        ]
      },
      "minItems": 2,
      "maxItems": 4
    },
    "reads": {
      "type": "array",
      "items": {
        "anyOf": [
          {
            "type": "integer",
            "minimum": 0,
            "maximum": 3
          },
          {
            "type": "null"
          }
        ]
      },
      "minItems": 0,
      "maxItems": 32
    },
    "reads_complete": {
      "type": "boolean"
    },
    "trigger_claim": {
      "oneOf": [
        {
          "type": "object",
          "additionalProperties": false,
          "properties": {
            "known": {
              "const": true
            },
            "value": {
              "anyOf": [
                {
                  "type": "integer",
                  "minimum": 0,
                  "maximum": 63
                },
                {
                  "type": "null"
                }
              ]
            }
          },
          "required": [
            "known",
            "value"
          ]
        },
        {
          "type": "object",
          "additionalProperties": false,
          "properties": {
            "known": {
              "const": false
            },
            "value": {
              "type": "null"
            }
          },
          "required": [
            "known",
            "value"
          ]
        }
      ]
    },
    "cut_claim": {
      "oneOf": [
        {
          "type": "object",
          "additionalProperties": false,
          "properties": {
            "known": {
              "const": true
            },
            "value": {
              "anyOf": [
                {
                  "type": "array",
                  "items": {
                    "type": "array",
                    "items": [
                      {
                        "type": "integer",
                        "minimum": 0,
                        "maximum": 3
                      },
                      {
                        "type": "integer",
                        "minimum": 0,
                        "maximum": 31
                      }
                    ],
                    "minItems": 2,
                    "maxItems": 2,
                    "additionalItems": false
                  },
                  "minItems": 0,
                  "maxItems": 128
                },
                {
                  "type": "null"
                }
              ]
            }
          },
          "required": [
            "known",
            "value"
          ]
        },
        {
          "type": "object",
          "additionalProperties": false,
          "properties": {
            "known": {
              "const": false
            },
            "value": {
              "type": "null"
            }
          },
          "required": [
            "known",
            "value"
          ]
        }
      ]
    }
  },
  "required": [
    "channels",
    "reads",
    "reads_complete",
    "trigger_claim",
    "cut_claim"
  ],
  "$schema": "http://json-schema.org/draft-07/schema#"
}

Originalschema öffnen

Veröffentlichtes Eingabebeispiel

{
  "channels": [
    {
      "complete": true,
      "items": [
        "record",
        "barrier",
        "record"
      ]
    },
    {
      "complete": true,
      "items": [
        "record",
        "barrier",
        "record"
      ]
    }
  ],
  "reads": [
    0,
    0,
    1,
    1
  ],
  "reads_complete": true,
  "trigger_claim": {
    "known": true,
    "value": 3
  },
  "cut_claim": {
    "known": true,
    "value": [
      [
        0,
        0
      ],
      [
        1,
        0
      ]
    ]
  }
}

Ergebnis & Dokumentation

Maschinenlesbare Dokumentation dieses Hubs

Quelle dieser Seite: der veröffentlichte HALOWERK-Katalog. Stand: 2026-11-07, 02:42 UTC.

Weitere Endpunkte dieses Hubs

Alle Endpunkte dieses Hubs →