Get Transform Checkpoints

Get checkpoint statistics and state size information for a transform job.

Returns checkpoint counts, summary statistics (state size, duration, etc.), latest checkpoint details, and checkpoint history.

Args: transform_id: The transform ID

Returns: TransformCheckpointsInfo: Checkpoint statistics and history None: If transform job not found or no checkpoints available

GET /transforms/{transform_id}/checkpoints

Get Transform Checkpoints

cURL

curl --request GET \
  --url https://api.streamkap.com/transforms/{transform_id}/checkpoints \
  --header 'Authorization: Bearer <token>'

200

{
  "job_id": "<string>",
  "counts": {},
  "summary": {},
  "latest": {
    "id": 123,
    "status": "<string>",
    "is_savepoint": true,
    "trigger_timestamp": 123,
    "latest_ack_timestamp": 123,
    "state_size": 123,
    "end_to_end_duration": 123,
    "alignment_buffered": 123,
    "num_subtasks": 123,
    "num_acknowledged_subtasks": 123
  },
  "history": [],
  "operator_breakdown": []
}

Authorizations

Authorization · string · header · required

Bearer authentication header of the form Bearer <token>, where <token> is your auth token.

Path Parameters

transform_id · string · required

Query Parameters

include_operator_breakdown · boolean · default: true

Response

200

application/json

TransformCheckpointsInfo · object | null

Successful Response

Checkpoint statistics and latest checkpoint information for a transform.

job_id · string · required

counts · Counts · object · required

summary · Summary · object · required

latest · TransformCheckpointHistory · object

Individual checkpoint history entry.

Show child attributes

history · TransformCheckpointHistory · object[]

Show child attributes

operator_breakdown · TransformOperatorState · object[]

Show child attributes