Salesforce CRM Analytics

Use the @bijection/connectors/salesforce-crm-analytics entrypoint to declare Salesforce CRM Analytics resources.

Availability

This page describes the pinned source package. Published availability is unestablished for this artifact. Source build and package availability.

Resources and modes

Resource	Mode	Description
Datasets	`pull`	The datasets the user can see, walked by nextPageUrl
Dataset versions	`pull`	One dataset’s versions, versioned by lastModifiedDate
Dataflow and recipe runs	`pull`	Dataflow job runs with their documented status
SAQL query	`saql`	One fixed SAQL query over pinned dataset versions, paged by offset

Declare a resource in application code, then bind deployment-specific settings and credentials. See typed resources, connections and source inspection.

Datasets

pull: The datasets the user can see, walked by nextPageUrl

The following example matches configuration standard.

import { crmAnalytics } from "@bijection/connectors/salesforce-crm-analytics";
export const datasets = crmAnalytics.datasets.pull();

Inferred record types

Resource without an operational record table

Configuration: standard

Case: salesforce-crm-analytics/datasets/pull/standard. Connection and resource configuration are declared by this exact case. Credential kind: salesforce. Keep credential material in the private credential inventory.

Setting	Type	Required	Owner
`instance`	string	Yes	Shared connection

Complete configuration contract

{
  "setup": [],
  "resource": {
    "access": {},
    "defaults": {},
    "connector": "salesforce",
    "output": {
      "kind": "single",
      "collection": "datasets"
    },
    "credential_kind": "salesforce",
    "connection_fields": [
      "instance"
    ],
    "address": {
      "kind": "setup",
      "field": "instance",
      "prefix": "https://",
      "suffix": ".my.salesforce.com"
    }
  },
  "connection_setup": {
    "type": "object",
    "value": {
      "instance": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      }
    }
  },
  "execution": null
}

Native admission analysis is available for this exact declaration. Collection: datasets

Contract	Meaning
Initial	Enumeration of observed records
Changes	Repeated observations of current records
Deletions	Deletion detection unsupported
Resume	Opaque cursor
Gap	Explicit repair required after a gap
Retention	Unspecified

Complete native profile

{
  "movement": {
    "exchanges": {
      "page": {
        "200": {
          "placement": "retained_bytes",
          "interpretation": "json",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        },
        "403": {
          "placement": "retained_bytes",
          "interpretation": "opaque",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        },
        "404": {
          "placement": "retained_bytes",
          "interpretation": "opaque",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        }
      }
    },
    "nativeInputLimitBytes": null,
    "steps": [
      {
        "id": "acquire.1",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "exchange page",
          "limitBytes": null
        }
      },
      {
        "id": "retain.1",
        "inputs": [
          "acquire.1"
        ],
        "action": {
          "operation": "retain",
          "subject": "acquisition evidence",
          "reason": "recovery",
          "release": "acquisition_custody"
        }
      },
      {
        "id": "interpret.1",
        "inputs": [
          "retain.1"
        ],
        "action": {
          "operation": "interpret",
          "subject": "acquired input",
          "produces": "records"
        }
      },
      {
        "id": "materialize.1",
        "inputs": [
          "interpret.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "source rows",
          "reason": "serving",
          "release": "replacement"
        }
      },
      {
        "id": "publish.1",
        "inputs": [
          "materialize.1"
        ],
        "action": {
          "operation": "publish",
          "subject": "source rows",
          "visibility": "with_acquisition"
        }
      }
    ]
  },
  "initial": "enumeration",
  "changes": "observations",
  "deletions": "unsupported",
  "resume": "opaque_cursor",
  "retentionMs": null,
  "gap": "explicit_repair",
  "limits": {
    "http_response_bytes": "524288"
  },
  "restrictions": [],
  "commands": {}
}

Commands, occurrences and artifacts

{
  "records": {
    "datasets": {
      "protocol": "record_observation",
      "coverage": "records",
      "consistency": "observations",
      "atomicity": "record",
      "history": "observations",
      "recordRefresh": false,
      "reconciliation": false,
      "notifications": false,
      "snapshotMaxRows": null,
      "profile": {
        "movement": {
          "exchanges": {
            "page": {
              "200": {
                "placement": "retained_bytes",
                "interpretation": "json",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              },
              "403": {
                "placement": "retained_bytes",
                "interpretation": "opaque",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              },
              "404": {
                "placement": "retained_bytes",
                "interpretation": "opaque",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              }
            }
          },
          "nativeInputLimitBytes": null,
          "steps": [
            {
              "id": "acquire.1",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "exchange page",
                "limitBytes": null
              }
            },
            {
              "id": "retain.1",
              "inputs": [
                "acquire.1"
              ],
              "action": {
                "operation": "retain",
                "subject": "acquisition evidence",
                "reason": "recovery",
                "release": "acquisition_custody"
              }
            },
            {
              "id": "interpret.1",
              "inputs": [
                "retain.1"
              ],
              "action": {
                "operation": "interpret",
                "subject": "acquired input",
                "produces": "records"
              }
            },
            {
              "id": "materialize.1",
              "inputs": [
                "interpret.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "source rows",
                "reason": "serving",
                "release": "replacement"
              }
            },
            {
              "id": "publish.1",
              "inputs": [
                "materialize.1"
              ],
              "action": {
                "operation": "publish",
                "subject": "source rows",
                "visibility": "with_acquisition"
              }
            }
          ]
        },
        "initial": "enumeration",
        "changes": "observations",
        "deletions": "unsupported",
        "resume": "opaque_cursor",
        "retentionMs": null,
        "gap": "explicit_repair",
        "limits": {
          "http_response_bytes": "524288"
        },
        "restrictions": [],
        "commands": {}
      }
    }
  },
  "occurrences": null,
  "artifacts": {
    "raw_archive": false,
    "native_file_transfer_limit_bytes": null,
    "external_versions": false,
    "files": {}
  },
  "commands": {}
}

Recorded checks

Requirement	Scope	Evidence	Result
page-publication-recovery	{“kind”:“collection”,“name”:“datasets”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/datasets-page-continues.json	passed (2026-10-24T21:36:12.012Z)
page-publication-recovery	{“kind”:“collection”,“name”:“datasets”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/datasets-last-page.json	passed (2026-10-24T21:36:12.012Z)
page-publication-recovery	{“kind”:“collection”,“name”:“datasets”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/datasets-foreign-next-refused.json	passed (2026-10-24T21:36:12.012Z)
page-publication-recovery	{“kind”:“collection”,“name”:“datasets”}	Native test: integrations/acquisition/acquisition_windows_preserve_sequences_and_restart_fences_old_work (shared_engine)	Execution result unavailable
stated-cursor-empty-page-advances	{“kind”:“collection”,“name”:“datasets”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/datasets-empty-page-advances.json	passed (2026-10-24T21:36:12.013Z)
stated-cursor-repeat-refused	{“kind”:“collection”,“name”:“datasets”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/datasets-repeat-refused.json	passed (2026-10-24T21:36:12.013Z)
identity-account	{“kind”:“connection”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/identity.json	passed (2026-10-24T21:36:12.013Z)

Hosted qualification: unestablished for this catalog configuration. Installed connections report their own identity, authority and current status.

Dataset versions

pull: One dataset’s versions, versioned by lastModifiedDate

The following example matches configuration standard.

import { crmAnalytics } from "@bijection/connectors/salesforce-crm-analytics";
export const versions = crmAnalytics.versions.pull({
  dataset: "0Fb5e000000XyZaCAK",
});

Inferred record types

Resource without an operational record table

Configuration: standard

Case: salesforce-crm-analytics/versions/pull/standard. Connection and resource configuration are declared by this exact case. Credential kind: salesforce. Keep credential material in the private credential inventory.

Setting	Type	Required	Owner
`instance`	string	Yes	Shared connection

Complete configuration contract

{
  "setup": [],
  "resource": {
    "access": {},
    "defaults": {},
    "connector": "salesforce",
    "output": {
      "kind": "single",
      "collection": "versions"
    },
    "credential_kind": "salesforce",
    "connection_fields": [
      "instance"
    ],
    "address": {
      "kind": "setup",
      "field": "instance",
      "prefix": "https://",
      "suffix": ".my.salesforce.com"
    }
  },
  "connection_setup": {
    "type": "object",
    "value": {
      "instance": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      }
    }
  },
  "execution": null
}

Native admission analysis is available for this exact declaration. Collection: versions

Contract	Meaning
Initial	Enumeration of observed records
Changes	Repeated observations of current records
Deletions	Deletion detection unsupported
Resume	No continuation
Gap	Not applicable
Retention	Unspecified

Complete native profile

{
  "movement": {
    "exchanges": {
      "list": {
        "200": {
          "placement": "retained_bytes",
          "interpretation": "json",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        },
        "403": {
          "placement": "retained_bytes",
          "interpretation": "opaque",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        },
        "404": {
          "placement": "retained_bytes",
          "interpretation": "opaque",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        }
      }
    },
    "nativeInputLimitBytes": null,
    "steps": [
      {
        "id": "acquire.1",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "exchange list",
          "limitBytes": null
        }
      },
      {
        "id": "retain.1",
        "inputs": [
          "acquire.1"
        ],
        "action": {
          "operation": "retain",
          "subject": "acquisition evidence",
          "reason": "recovery",
          "release": "acquisition_custody"
        }
      },
      {
        "id": "interpret.1",
        "inputs": [
          "retain.1"
        ],
        "action": {
          "operation": "interpret",
          "subject": "acquired input",
          "produces": "records"
        }
      },
      {
        "id": "materialize.1",
        "inputs": [
          "interpret.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "source rows",
          "reason": "serving",
          "release": "replacement"
        }
      },
      {
        "id": "publish.1",
        "inputs": [
          "materialize.1"
        ],
        "action": {
          "operation": "publish",
          "subject": "source rows",
          "visibility": "with_acquisition"
        }
      }
    ]
  },
  "initial": "enumeration",
  "changes": "observations",
  "deletions": "unsupported",
  "resume": "none",
  "retentionMs": null,
  "gap": "not_applicable",
  "limits": {
    "http_response_bytes": "524288"
  },
  "restrictions": [],
  "commands": {}
}

Commands, occurrences and artifacts

{
  "records": {
    "versions": {
      "protocol": "record_observation",
      "coverage": "records",
      "consistency": "observations",
      "atomicity": "record",
      "history": "observations",
      "recordRefresh": false,
      "reconciliation": false,
      "notifications": false,
      "snapshotMaxRows": null,
      "profile": {
        "movement": {
          "exchanges": {
            "list": {
              "200": {
                "placement": "retained_bytes",
                "interpretation": "json",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              },
              "403": {
                "placement": "retained_bytes",
                "interpretation": "opaque",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              },
              "404": {
                "placement": "retained_bytes",
                "interpretation": "opaque",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              }
            }
          },
          "nativeInputLimitBytes": null,
          "steps": [
            {
              "id": "acquire.1",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "exchange list",
                "limitBytes": null
              }
            },
            {
              "id": "retain.1",
              "inputs": [
                "acquire.1"
              ],
              "action": {
                "operation": "retain",
                "subject": "acquisition evidence",
                "reason": "recovery",
                "release": "acquisition_custody"
              }
            },
            {
              "id": "interpret.1",
              "inputs": [
                "retain.1"
              ],
              "action": {
                "operation": "interpret",
                "subject": "acquired input",
                "produces": "records"
              }
            },
            {
              "id": "materialize.1",
              "inputs": [
                "interpret.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "source rows",
                "reason": "serving",
                "release": "replacement"
              }
            },
            {
              "id": "publish.1",
              "inputs": [
                "materialize.1"
              ],
              "action": {
                "operation": "publish",
                "subject": "source rows",
                "visibility": "with_acquisition"
              }
            }
          ]
        },
        "initial": "enumeration",
        "changes": "observations",
        "deletions": "unsupported",
        "resume": "none",
        "retentionMs": null,
        "gap": "not_applicable",
        "limits": {
          "http_response_bytes": "524288"
        },
        "restrictions": [],
        "commands": {}
      }
    }
  },
  "occurrences": null,
  "artifacts": {
    "raw_archive": false,
    "native_file_transfer_limit_bytes": null,
    "external_versions": false,
    "files": {}
  },
  "commands": {}
}

Recorded checks

Requirement	Scope	Evidence	Result
page-publication-recovery	{“kind”:“collection”,“name”:“versions”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/versions-listed.json	passed (2026-10-24T21:36:12.014Z)
page-publication-recovery	{“kind”:“collection”,“name”:“versions”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/versions-unversioned-refused.json	passed (2026-10-24T21:36:12.014Z)
page-publication-recovery	{“kind”:“collection”,“name”:“versions”}	Native test: integrations/acquisition/acquisition_windows_preserve_sequences_and_restart_fences_old_work (shared_engine)	Execution result unavailable
identity-account	{“kind”:“connection”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/identity.json	passed (2026-10-24T21:36:12.015Z)

Hosted qualification: unestablished for this catalog configuration. Installed connections report their own identity, authority and current status.

Dataflow and recipe runs

pull: Dataflow job runs with their documented status

The following example matches configuration recipes.

import { crmAnalytics } from "@bijection/connectors/salesforce-crm-analytics";
export const recipeRuns = crmAnalytics.jobs.pull({
  jobTypes: ["Recipe", "Recipe_V3"],
});

Inferred record types

Resource without an operational record table

Configuration: standard

Case: salesforce-crm-analytics/jobs/pull/standard. Connection and resource configuration are declared by this exact case. Credential kind: salesforce. Keep credential material in the private credential inventory.

Setting	Type	Required	Owner
`instance`	string	Yes	Shared connection

Complete configuration contract

{
  "setup": [],
  "resource": {
    "access": {},
    "defaults": {},
    "connector": "salesforce",
    "output": {
      "kind": "single",
      "collection": "jobs"
    },
    "credential_kind": "salesforce",
    "connection_fields": [
      "instance"
    ],
    "address": {
      "kind": "setup",
      "field": "instance",
      "prefix": "https://",
      "suffix": ".my.salesforce.com"
    }
  },
  "connection_setup": {
    "type": "object",
    "value": {
      "instance": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      }
    }
  },
  "execution": null
}

Native admission analysis is available for this exact declaration. Collection: jobs

Contract	Meaning
Initial	Enumeration of observed records
Changes	Repeated observations of current records
Deletions	Deletion detection unsupported
Resume	Opaque cursor
Gap	Explicit repair required after a gap
Retention	Unspecified

Complete native profile

{
  "movement": {
    "exchanges": {
      "page": {
        "200": {
          "placement": "retained_bytes",
          "interpretation": "json",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        },
        "403": {
          "placement": "retained_bytes",
          "interpretation": "opaque",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        },
        "404": {
          "placement": "retained_bytes",
          "interpretation": "opaque",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        }
      }
    },
    "nativeInputLimitBytes": null,
    "steps": [
      {
        "id": "acquire.1",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "exchange page",
          "limitBytes": null
        }
      },
      {
        "id": "retain.1",
        "inputs": [
          "acquire.1"
        ],
        "action": {
          "operation": "retain",
          "subject": "acquisition evidence",
          "reason": "recovery",
          "release": "acquisition_custody"
        }
      },
      {
        "id": "interpret.1",
        "inputs": [
          "retain.1"
        ],
        "action": {
          "operation": "interpret",
          "subject": "acquired input",
          "produces": "records"
        }
      },
      {
        "id": "materialize.1",
        "inputs": [
          "interpret.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "source rows",
          "reason": "serving",
          "release": "replacement"
        }
      },
      {
        "id": "publish.1",
        "inputs": [
          "materialize.1"
        ],
        "action": {
          "operation": "publish",
          "subject": "source rows",
          "visibility": "with_acquisition"
        }
      }
    ]
  },
  "initial": "enumeration",
  "changes": "observations",
  "deletions": "unsupported",
  "resume": "opaque_cursor",
  "retentionMs": null,
  "gap": "explicit_repair",
  "limits": {
    "http_response_bytes": "524288"
  },
  "restrictions": [],
  "commands": {}
}

Commands, occurrences and artifacts

{
  "records": {
    "jobs": {
      "protocol": "record_observation",
      "coverage": "records",
      "consistency": "observations",
      "atomicity": "record",
      "history": "observations",
      "recordRefresh": false,
      "reconciliation": false,
      "notifications": false,
      "snapshotMaxRows": null,
      "profile": {
        "movement": {
          "exchanges": {
            "page": {
              "200": {
                "placement": "retained_bytes",
                "interpretation": "json",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              },
              "403": {
                "placement": "retained_bytes",
                "interpretation": "opaque",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              },
              "404": {
                "placement": "retained_bytes",
                "interpretation": "opaque",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              }
            }
          },
          "nativeInputLimitBytes": null,
          "steps": [
            {
              "id": "acquire.1",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "exchange page",
                "limitBytes": null
              }
            },
            {
              "id": "retain.1",
              "inputs": [
                "acquire.1"
              ],
              "action": {
                "operation": "retain",
                "subject": "acquisition evidence",
                "reason": "recovery",
                "release": "acquisition_custody"
              }
            },
            {
              "id": "interpret.1",
              "inputs": [
                "retain.1"
              ],
              "action": {
                "operation": "interpret",
                "subject": "acquired input",
                "produces": "records"
              }
            },
            {
              "id": "materialize.1",
              "inputs": [
                "interpret.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "source rows",
                "reason": "serving",
                "release": "replacement"
              }
            },
            {
              "id": "publish.1",
              "inputs": [
                "materialize.1"
              ],
              "action": {
                "operation": "publish",
                "subject": "source rows",
                "visibility": "with_acquisition"
              }
            }
          ]
        },
        "initial": "enumeration",
        "changes": "observations",
        "deletions": "unsupported",
        "resume": "opaque_cursor",
        "retentionMs": null,
        "gap": "explicit_repair",
        "limits": {
          "http_response_bytes": "524288"
        },
        "restrictions": [],
        "commands": {}
      }
    }
  },
  "occurrences": null,
  "artifacts": {
    "raw_archive": false,
    "native_file_transfer_limit_bytes": null,
    "external_versions": false,
    "files": {}
  },
  "commands": {}
}

Recorded checks

Requirement	Scope	Evidence	Result
page-publication-recovery	{“kind”:“collection”,“name”:“jobs”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/jobs-page-maps-status.json	passed (2026-10-24T21:36:12.015Z)
page-publication-recovery	{“kind”:“collection”,“name”:“jobs”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/jobs-undeclared-status-refused.json	passed (2026-10-24T21:36:12.016Z)
page-publication-recovery	{“kind”:“collection”,“name”:“jobs”}	Native test: integrations/acquisition/acquisition_windows_preserve_sequences_and_restart_fences_old_work (shared_engine)	Execution result unavailable
stated-cursor-empty-page-advances	{“kind”:“collection”,“name”:“jobs”}	No check exercises this packaged CRM Analytics declaration against a Salesforce org; it is declared from the CRM Analytics REST API Developer Guide and has not run or been qualified.	Execution result unavailable
stated-cursor-repeat-refused	{“kind”:“collection”,“name”:“jobs”}	No check exercises this packaged CRM Analytics declaration against a Salesforce org; it is declared from the CRM Analytics REST API Developer Guide and has not run or been qualified.	Execution result unavailable
identity-account	{“kind”:“connection”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/identity.json	passed (2026-10-24T21:36:12.016Z)

Hosted qualification: unestablished for this catalog configuration. Installed connections report their own identity, authority and current status.

Configuration: recipes

Case: salesforce-crm-analytics/jobs/pull/recipes. Connection and resource configuration are declared by this exact case. Credential kind: salesforce. Keep credential material in the private credential inventory.

Setting	Type	Required	Owner
`instance`	string	Yes	Shared connection

Complete configuration contract

{
  "setup": [],
  "resource": {
    "access": {},
    "defaults": {},
    "connector": "salesforce",
    "output": {
      "kind": "single",
      "collection": "jobs"
    },
    "credential_kind": "salesforce",
    "connection_fields": [
      "instance"
    ],
    "address": {
      "kind": "setup",
      "field": "instance",
      "prefix": "https://",
      "suffix": ".my.salesforce.com"
    }
  },
  "connection_setup": {
    "type": "object",
    "value": {
      "instance": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      }
    }
  },
  "execution": null
}

Native admission analysis is available for this exact declaration. Collection: jobs

Contract	Meaning
Initial	Enumeration of observed records
Changes	Repeated observations of current records
Deletions	Deletion detection unsupported
Resume	Opaque cursor
Gap	Explicit repair required after a gap
Retention	Unspecified

Complete native profile

{
  "movement": {
    "exchanges": {
      "page": {
        "200": {
          "placement": "retained_bytes",
          "interpretation": "json",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        },
        "403": {
          "placement": "retained_bytes",
          "interpretation": "opaque",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        },
        "404": {
          "placement": "retained_bytes",
          "interpretation": "opaque",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        }
      }
    },
    "nativeInputLimitBytes": null,
    "steps": [
      {
        "id": "acquire.1",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "exchange page",
          "limitBytes": null
        }
      },
      {
        "id": "retain.1",
        "inputs": [
          "acquire.1"
        ],
        "action": {
          "operation": "retain",
          "subject": "acquisition evidence",
          "reason": "recovery",
          "release": "acquisition_custody"
        }
      },
      {
        "id": "interpret.1",
        "inputs": [
          "retain.1"
        ],
        "action": {
          "operation": "interpret",
          "subject": "acquired input",
          "produces": "records"
        }
      },
      {
        "id": "materialize.1",
        "inputs": [
          "interpret.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "source rows",
          "reason": "serving",
          "release": "replacement"
        }
      },
      {
        "id": "publish.1",
        "inputs": [
          "materialize.1"
        ],
        "action": {
          "operation": "publish",
          "subject": "source rows",
          "visibility": "with_acquisition"
        }
      }
    ]
  },
  "initial": "enumeration",
  "changes": "observations",
  "deletions": "unsupported",
  "resume": "opaque_cursor",
  "retentionMs": null,
  "gap": "explicit_repair",
  "limits": {
    "http_response_bytes": "524288"
  },
  "restrictions": [],
  "commands": {}
}

Commands, occurrences and artifacts

{
  "records": {
    "jobs": {
      "protocol": "record_observation",
      "coverage": "records",
      "consistency": "observations",
      "atomicity": "record",
      "history": "observations",
      "recordRefresh": false,
      "reconciliation": false,
      "notifications": false,
      "snapshotMaxRows": null,
      "profile": {
        "movement": {
          "exchanges": {
            "page": {
              "200": {
                "placement": "retained_bytes",
                "interpretation": "json",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              },
              "403": {
                "placement": "retained_bytes",
                "interpretation": "opaque",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              },
              "404": {
                "placement": "retained_bytes",
                "interpretation": "opaque",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              }
            }
          },
          "nativeInputLimitBytes": null,
          "steps": [
            {
              "id": "acquire.1",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "exchange page",
                "limitBytes": null
              }
            },
            {
              "id": "retain.1",
              "inputs": [
                "acquire.1"
              ],
              "action": {
                "operation": "retain",
                "subject": "acquisition evidence",
                "reason": "recovery",
                "release": "acquisition_custody"
              }
            },
            {
              "id": "interpret.1",
              "inputs": [
                "retain.1"
              ],
              "action": {
                "operation": "interpret",
                "subject": "acquired input",
                "produces": "records"
              }
            },
            {
              "id": "materialize.1",
              "inputs": [
                "interpret.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "source rows",
                "reason": "serving",
                "release": "replacement"
              }
            },
            {
              "id": "publish.1",
              "inputs": [
                "materialize.1"
              ],
              "action": {
                "operation": "publish",
                "subject": "source rows",
                "visibility": "with_acquisition"
              }
            }
          ]
        },
        "initial": "enumeration",
        "changes": "observations",
        "deletions": "unsupported",
        "resume": "opaque_cursor",
        "retentionMs": null,
        "gap": "explicit_repair",
        "limits": {
          "http_response_bytes": "524288"
        },
        "restrictions": [],
        "commands": {}
      }
    }
  },
  "occurrences": null,
  "artifacts": {
    "raw_archive": false,
    "native_file_transfer_limit_bytes": null,
    "external_versions": false,
    "files": {}
  },
  "commands": {}
}

Recorded checks

Requirement	Scope	Evidence	Result
page-publication-recovery	{“kind”:“collection”,“name”:“jobs”}	Native test: integrations/acquisition/acquisition_windows_preserve_sequences_and_restart_fences_old_work (shared_engine)	Execution result unavailable
stated-cursor-empty-page-advances	{“kind”:“collection”,“name”:“jobs”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/jobs-empty-page-advances.json	passed (2026-10-24T21:36:12.017Z)
stated-cursor-repeat-refused	{“kind”:“collection”,“name”:“jobs”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/jobs-repeat-refused.json	passed (2026-10-24T21:36:12.017Z)
identity-account	{“kind”:“connection”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/identity.json	passed (2026-10-24T21:36:12.018Z)

Hosted qualification: unestablished for this catalog configuration. Installed connections report their own identity, authority and current status.

SAQL query

saql: One fixed SAQL query over pinned dataset versions, paged by offset

The following example matches configuration standard.

import { crmAnalytics } from "@bijection/connectors/salesforce-crm-analytics";
export const pipeline = crmAnalytics.query.saql({
  saql: "q = load \"0Fb5e000000XyZaCAK/0Fc5e000000AbCdCAK\"; q = group q by 'StageName'; q = foreach q generate 'StageName' as 'StageName', count() as 'count', sum('Amount') as 'amount'; q = order q by 'StageName' asc;",
  columns: {
    stage: { column: "StageName", type: "text" },
    deals: { column: "count", type: "integer" },
    amount: { column: "amount", type: "number" },
  },
  key: ["stage"],
});

Inferred record types

Resource without an operational record table

Configuration: standard

Case: salesforce-crm-analytics/query/saql/standard. Connection and resource configuration are declared by this exact case. Credential kind: salesforce. Keep credential material in the private credential inventory.

Setting	Type	Required	Owner
`instance`	string	Yes	Shared connection

Complete configuration contract

{
  "setup": [],
  "resource": {
    "access": {},
    "defaults": {},
    "connector": "salesforce",
    "output": {
      "kind": "single",
      "collection": "rows"
    },
    "credential_kind": "salesforce",
    "connection_fields": [
      "instance"
    ],
    "address": {
      "kind": "setup",
      "field": "instance",
      "prefix": "https://",
      "suffix": ".my.salesforce.com"
    }
  },
  "connection_setup": {
    "type": "object",
    "value": {
      "instance": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      }
    }
  },
  "execution": null
}

Native admission analysis is available for this exact declaration. Collection: rows

Contract	Meaning
Initial	Enumeration of observed records
Changes	Repeated observations of current records
Deletions	Deletion detection unsupported
Resume	No continuation
Gap	Not applicable
Retention	Unspecified

Complete native profile

{
  "movement": {
    "exchanges": {
      "query": {
        "200": {
          "placement": "retained_bytes",
          "interpretation": "json",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        },
        "400": {
          "placement": "retained_bytes",
          "interpretation": "opaque",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        },
        "403": {
          "placement": "retained_bytes",
          "interpretation": "opaque",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        }
      }
    },
    "nativeInputLimitBytes": null,
    "steps": [
      {
        "id": "acquire.1",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "exchange query",
          "limitBytes": null
        }
      },
      {
        "id": "retain.1",
        "inputs": [
          "acquire.1"
        ],
        "action": {
          "operation": "retain",
          "subject": "acquisition evidence",
          "reason": "recovery",
          "release": "acquisition_custody"
        }
      },
      {
        "id": "interpret.1",
        "inputs": [
          "retain.1"
        ],
        "action": {
          "operation": "interpret",
          "subject": "acquired input",
          "produces": "records"
        }
      },
      {
        "id": "materialize.1",
        "inputs": [
          "interpret.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "source rows",
          "reason": "serving",
          "release": "replacement"
        }
      },
      {
        "id": "publish.1",
        "inputs": [
          "materialize.1"
        ],
        "action": {
          "operation": "publish",
          "subject": "source rows",
          "visibility": "with_acquisition"
        }
      }
    ]
  },
  "initial": "enumeration",
  "changes": "observations",
  "deletions": "unsupported",
  "resume": "none",
  "retentionMs": null,
  "gap": "not_applicable",
  "limits": {
    "http_response_bytes": "524288"
  },
  "restrictions": [],
  "commands": {}
}

Commands, occurrences and artifacts

{
  "records": {
    "rows": {
      "protocol": "record_observation",
      "coverage": "records",
      "consistency": "observations",
      "atomicity": "record",
      "history": "observations",
      "recordRefresh": false,
      "reconciliation": false,
      "notifications": false,
      "snapshotMaxRows": null,
      "profile": {
        "movement": {
          "exchanges": {
            "query": {
              "200": {
                "placement": "retained_bytes",
                "interpretation": "json",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              },
              "400": {
                "placement": "retained_bytes",
                "interpretation": "opaque",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              },
              "403": {
                "placement": "retained_bytes",
                "interpretation": "opaque",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              }
            }
          },
          "nativeInputLimitBytes": null,
          "steps": [
            {
              "id": "acquire.1",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "exchange query",
                "limitBytes": null
              }
            },
            {
              "id": "retain.1",
              "inputs": [
                "acquire.1"
              ],
              "action": {
                "operation": "retain",
                "subject": "acquisition evidence",
                "reason": "recovery",
                "release": "acquisition_custody"
              }
            },
            {
              "id": "interpret.1",
              "inputs": [
                "retain.1"
              ],
              "action": {
                "operation": "interpret",
                "subject": "acquired input",
                "produces": "records"
              }
            },
            {
              "id": "materialize.1",
              "inputs": [
                "interpret.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "source rows",
                "reason": "serving",
                "release": "replacement"
              }
            },
            {
              "id": "publish.1",
              "inputs": [
                "materialize.1"
              ],
              "action": {
                "operation": "publish",
                "subject": "source rows",
                "visibility": "with_acquisition"
              }
            }
          ]
        },
        "initial": "enumeration",
        "changes": "observations",
        "deletions": "unsupported",
        "resume": "none",
        "retentionMs": null,
        "gap": "not_applicable",
        "limits": {
          "http_response_bytes": "524288"
        },
        "restrictions": [],
        "commands": {}
      }
    }
  },
  "occurrences": null,
  "artifacts": {
    "raw_archive": false,
    "native_file_transfer_limit_bytes": null,
    "external_versions": false,
    "files": {}
  },
  "commands": {}
}

Recorded checks

Requirement	Scope	Evidence	Result
page-publication-recovery	{“kind”:“collection”,“name”:“rows”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/saql-page-continues.json	passed (2026-10-24T21:36:12.020Z)
page-publication-recovery	{“kind”:“collection”,“name”:“rows”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/saql-last-page.json	passed (2026-10-24T21:36:12.021Z)
page-publication-recovery	{“kind”:“collection”,“name”:“rows”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/saql-over-limit-refused.json	passed (2026-10-24T21:36:12.022Z)
page-publication-recovery	{“kind”:“collection”,“name”:“rows”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/saql-warnings-refused.json	passed (2026-10-24T21:36:12.023Z)
page-publication-recovery	{“kind”:“collection”,“name”:“rows”}	Native test: integrations/acquisition/acquisition_windows_preserve_sequences_and_restart_fences_old_work (shared_engine)	Execution result unavailable
identity-account	{“kind”:“connection”}	Fixture: ./src/connectors/salesforce-crm-analytics/fixtures/identity.json	passed (2026-10-24T21:36:12.023Z)

Hosted qualification: unestablished for this catalog configuration. Installed connections report their own identity, authority and current status.

Provider guidance

Compiled declaration examples and configuration details are published in the connector reference. CRM Analytics (formerly Tableau CRM and Einstein Analytics) through the CRM Analytics REST API (/services/data/v67.0/wave/...). It is licensed and documented apart from the core org, like Marketing Cloud Engagement and Account Engagement (Pardot), so it is its own connector. Unlike those, the org itself serves it, so every resource binds the same salesforce connection as @bijection/connectors/salesforce: the org’s My Domain (instance) and crmAnalytics.credential(name) (the same salesforce credential kind, holding the OAuth access_token). The identity is the org’s organization_id from userinfo. The integration user needs the REST API (API Enabled) and a CRM Analytics permission set license with the Use CRM Analytics user permission. The datasets listing returns only the datasets that user can see (“The list of datasets available to the current user”), so share the apps or folders holding them. Seeing dataflow and recipe runs in Data Manager normally takes Manage CRM Analytics or Edit CRM Analytics Dataflows. These permission names come from Salesforce Help and Trailhead, not the REST guide, and have not been checked against an org. A request without the license or permission is refused 403. Nothing here writes: no dataflow, recipe or data sync is started, stopped or scheduled, and no dataset is created or changed.

Datasets and versions

datasets.pull walks GET wave/datasets 50 at a time by the page token in each answer’s nextPageUrl. It reads only that token: a nextPageUrl naming another resource, or any other parameter, is refused. It publishes id, name, label, datasetType, folderId, currentVersionId, currentVersionTotalRowCount, createdDate, lastModifiedDate, lastQueriedDate and dataRefreshDate. Records are unversioned observations, because lastQueriedDate changes with every query while lastModifiedDate stays the same. versions.pull({ dataset }) reads one dataset’s versions by id or API name (GET wave/datasets/{dataset}/versions, unpaged). Each version is versioned by its lastModifiedDate, and a version without one is refused. Archived versions are not requested.

Dataflow and recipe runs

jobs.pull walks GET wave/dataflowjobs by nextPageUrl. You can filter by dataflow (a 02K id; for a recipe, its targetDataflowId) or by documented jobTypes. The walk always sends pageSize: without it the API returns only the last 7 days of runs. Each run publishes its status and an outcome:

`status` (documented values)	`outcome`
`Queued`, `Preprocessing`, `Running`	`pending`
`Success`, `Warning`	`ready`
`Failure`, `Cancelled`	`lost`

A status the guide does not document refuses the page; it is never mapped to an outcome.

SAQL query

query.saql sends one fixed SAQL text to POST wave/query and publishes one record per row of results.records, keyed by the declared key columns. SAQL is synchronous, not a provider job. The guide documents the query resource as a POST that runs the query and returns the rows in the response (Query Resource, Query CRM Analytics Data with the Query API). The query is read a page at a time. The host appends <stream> = offset <stream> <n>; <stream> = limit <stream> <pageSize>; to the declared statements (SAQL requires offset after order and before limit). The declaration must:

load every dataset as "<datasetId>/<versionId>", as the REST API requires;
order the paged stream (order by the key);
leave offset and limit to the page.

Because each load names a fixed dataset version, offsets stay stable across pages, but the result does not follow new dataset versions until the declaration is updated. A page that answers warnings, or more rows than its limit, is refused rather than published in part. A page shorter than pageSize (1 to 128, 100 by default) ends the pass. The host bounds one response at 512 KiB, so wide rows need a smaller pageSize. number columns are JSON doubles. No coverage is claimed, and a row missing from a later pass is not withdrawn.

Not built

Starting a dataflow or recipe as a provider job. The only asynchronous operation in the guide is POST wave/dataflowjobs {dataflowId, command: "start"}, polled at GET wave/dataflowjobs/{id}. Starting a run is a business write:
- it rebuilds the datasets the org’s dashboards read;
- it runs the data sync of the objects the dataflow extracts;
- it spends the org’s run allowance.
A job collection kicks off a run at the start of every pass, as a read step. It has no command’s single-attempt custody, governing rule or idempotency. It would therefore start the recipe on the collection’s cadence, and a lost reply could start a second run. The run’s output is datasets, not records the job names. jobs.pull observes the runs the org’s own schedule starts instead.
SQL for CRM Analytics (queryLanguage: "SQL"), dashboards, lenses, XMD, data connectors and dataset file downloads.

Nothing here has run against a Salesforce org; it is declared from the guide.

Provider references

Provider references and prerequisites are maintained in the connector guidance above. No separate provider-documentation review date is recorded.

Source and evidence

Canonical connector source, native analysis and check receipts. Connector artifact: 905888ea276a2a28e36981a79e8142b2547ea451c3e63162cb6915ad4a7d1305. The resource declaration examples above are compiled and compared with exact catalog declarations. Recorded checks apply only to their source, declaration and runtime identities. Configure a connection and inspect its status to establish deployment-specific readiness.

Get Started

Use-case atlas

Platform

Data and Operations

Guides

Client Libraries

Tools

API Reference

Salesforce CRM Analytics

Availability

Resources and modes

Datasets

pull: The datasets the user can see, walked by nextPageUrl

Configuration: standard

Dataset versions

pull: One dataset’s versions, versioned by lastModifiedDate

Configuration: standard

Dataflow and recipe runs

pull: Dataflow job runs with their documented status

Configuration: standard

Configuration: recipes

SAQL query

saql: One fixed SAQL query over pinned dataset versions, paged by offset

Configuration: standard

Provider guidance

Datasets and versions

Dataflow and recipe runs

SAQL query

Not built

Provider references

Source and evidence

​Availability

​Resources and modes

​Datasets

​pull: The datasets the user can see, walked by nextPageUrl

​Configuration: standard

​Dataset versions

​pull: One dataset’s versions, versioned by lastModifiedDate

​Configuration: standard

​Dataflow and recipe runs

​pull: Dataflow job runs with their documented status

​Configuration: standard

​Configuration: recipes

​SAQL query

​saql: One fixed SAQL query over pinned dataset versions, paged by offset

​Configuration: standard

​Provider guidance

​Datasets and versions

​Dataflow and recipe runs

​SAQL query

​Not built

​Provider references

​Source and evidence

Availability

Resources and modes

Datasets

pull: The datasets the user can see, walked by nextPageUrl

Configuration: standard

Dataset versions

pull: One dataset’s versions, versioned by lastModifiedDate

Configuration: standard

Dataflow and recipe runs

pull: Dataflow job runs with their documented status

Configuration: standard

Configuration: recipes

SAQL query

saql: One fixed SAQL query over pinned dataset versions, paged by offset

Configuration: standard

Provider guidance

Datasets and versions

Dataflow and recipe runs

SAQL query

Not built

Provider references

Source and evidence