Unify and manage your data

Streaming table fields in Reltio Data Sharing with Databricks

Learn more about the fields available in Reltio Data Sharing with Databricks streaming tables.

Databricks streaming-table data shares provide type-specific tables for entities, relations, and interactions, and fixed-name streaming tables for matches, merges, links, workflows, and activities.

Entity fields

Reltio writes entity records to a streaming table named entity_{entityType}.

In a hierarchical schema, attributes stores the entity attributes in a single STRUCT. In a simplified schema, Reltio replaces the attributes structure with separate fields based on the attributes defined in your entity model.

The entity streaming tables contain the following fields:

FieldData typeDescription
objectTypeSTRINGType of Reltio object represented by the record.
idSTRINGUnique identifier for the entity.
uriSTRINGUnique URI for the entity.
versionBIGINTVersion of the entity.
timestampBIGINTTime when Reltio recorded the entity event.
typeSTRINGEntity type defined in your tenant business model.
attributesSTRUCTEntity attributes in a hierarchical schema.
crosswalksARRAY<STRUCT>Source records associated with the entity.
analyticsAttributesSTRINGAnalytical attributes associated with the entity.
createdBySTRINGIdentifier of the user who created the entity.
createdTimeBIGINTTime when the source system created the entity.
updatedBySTRINGIdentifier of the user who last updated the entity.
updatedTimeBIGINTTime when the source system last updated the entity.
commitTimeBIGINTTime when the entity version was committed in Reltio.
deletedBOOLEANIndicates whether the entity is deleted. Always false because deleted entities are not included.
labelSTRINGDisplay label that Reltio generates from the configured label pattern.
linkedBOOLEANIndicates whether the entity is linked to another object.
secondaryLabelSTRINGAdditional display label that Reltio generates from the configured secondary label pattern.
tagsARRAYTags associated with the entity.
startDateBIGINTDate and time from which Reltio considers the entity active. Before this time, the entity is inactive. If null, no date is specified for the active period to begin.
endDateBIGINTDate and time through which Reltio considers the entity active. After this time, the entity is inactive. If null, no date is specified for the active period to end.
ingestTimeTIMESTAMPTime when Databricks ingested the entity record from staging storage into the entity table.
insertedTimeBIGINTTime when the record was written to staging storage. Available only in simplified schema.
eventTimeBIGINTTime when the entity event occurred. Available only in simplified schema.
deletedTimeBIGINTAlways null because deleted entities are not included. Available only in simplified schema.

Relation fields

Reltio writes relation records to a streaming table named relation_{relationshipType}.

In a hierarchical schema, attributes contains the relation attributes as a STRUCT. In a simplified schema, fields derived from the relation model replace attributes.

The relation streaming tables contain the following fields:

FieldData typeDescription
objectTypeSTRINGType of Reltio object represented by the record.
idSTRINGUnique identifier for the relation.
uriSTRINGUnique URI for the relation.
typeSTRINGRelation type defined in your tenant business model.
attributesSTRUCTRelation attributes in a hierarchical schema.
commitTimeBIGINTTime when the relation version was committed in Reltio.
createdBySTRINGIdentifier of the user who created the relation.
createdTimeBIGINTTime when the source system created the relation.
crosswalksARRAY<STRUCT>Source records associated with the relation.
deletedBOOLEANIndicates whether the relation is deleted. Always false because deleted relations are not included.
linkedBOOLEANIndicates whether the relation is linked to another object.
timestampBIGINTTime when Reltio recorded the relation event.
updatedBySTRINGIdentifier of the user who last updated the relation.
updatedTimeBIGINTTime when the source system last updated the relation.
versionBIGINTVersion of the relation.
startObjectSTRUCTEntity assigned to the start of the relationship. Includes the entity URI and crosswalks.
endObjectSTRUCTEntity assigned to the end of the relationship. Includes the entity URI and crosswalks.
startRefIgnoredBOOLEANIndicates whether the start-object reference is ignored.
startRefPinnedBOOLEANIndicates whether the start-object reference is pinned.
endRefIgnoredBOOLEANIndicates whether the end-object reference is ignored.
endRefPinnedBOOLEANIndicates whether the end-object reference is pinned.
startDateBIGINTDate and time from which the relation connects its start and end objects. Before this time, the relation is inactive. If null, no date is specified for the active period to begin.
endDateBIGINTDate and time through which the relation connects its start and end objects. After this time, the relation is inactive. If null, no date is specified for the active period to end.
ingestTimeTIMESTAMPTime when Databricks ingested the relation record from staging storage into the relation table.
insertedTimeBIGINTTime when the record was written to staging storage. Available only in simplified schema.
eventTimeBIGINTTime when the relation event occurred. Available only in simplified schema.
deletedTimeBIGINTAlways null because deleted relations are not included. Available only in simplified schema.

Interaction fields

Reltio writes interaction records to a streaming table named interaction_{interactionType}.

In a hierarchical schema, attributes contains the interaction attributes as a STRUCT. In a simplified schema, fields derived from the interaction model replace attributes.

The interaction streaming tables contain the following fields:

FieldData typeDescription
objectTypeSTRINGType of Reltio object represented by the record.
idSTRINGUnique identifier for the interaction.
linkedBOOLEANIndicates whether the interaction was replaced as part of an entity or relation merge.
uriSTRINGUnique URI for the interaction.
versionBIGINTVersion of the interaction.
timestampBIGINTTime when Reltio recorded the interaction event.
typeSTRINGInteraction type defined in your tenant business model.
deletedBOOLEANIndicates whether the interaction is deleted. Always false because deleted interactions are not included.
attributesSTRUCTInteraction attributes in a hierarchical schema.
crosswalksARRAY<STRUCT>Source records associated with the interaction.
membersMAP<STRING, STRUCT>Interaction roles and the entities assigned to each role.
createdBySTRINGIdentifier of the user who created the interaction.
createdTimeBIGINTTime when the source system created the interaction.
updatedBySTRINGIdentifier of the user who last updated the interaction.
updatedTimeBIGINTTime when the source system last updated the interaction.
commitTimeBIGINTTime when the interaction version was committed in Reltio.
ingestTimeTIMESTAMPTime when Databricks ingested the interaction record from staging storage into the interaction table.
insertedTimeBIGINTTime when the record was written to staging storage. Available only in simplified schema.
eventTimeBIGINTTime when the interaction event occurred. Available only in simplified schema.
deletedTimeBIGINTAlwaysnullbecause deleted interactions are not included. Available only in simplified schema.

Match fields

Reltio writes match records to the matches streaming table.

The match streaming tables contain the following fields:

FieldData typeDescription
objectTypeSTRINGType of Reltio object represented by the record.
insertedTimeBIGINTTime when the match record was written to staging storage.
entityIdSTRINGIdentifier of the entity for which match information is recorded.
manual_matchesARRAY<STRUCT>Entity identifiers manually confirmed as matches to entityId.
not_matchesARRAY<STRUCT>Entity identifiers marked as not matching entityId.
potential_matchesARRAY<STRUCT>Entities identified as possible matches to entityId, including the applicable match rules and match score.
versionBIGINTVersion of the match record.
deletedBOOLEANIndicates whether the match record is deleted. Always false because deleted match records are not included.
timestampBIGINTTime when Reltio recorded the match event.
ingestTimeTIMESTAMPTime when Databricks ingested the match record from staging storage into the matches table.

Merge fields

Reltio writes merge records to the merges streaming table.

The merge streaming tables contain the following fields.

FieldData typeDescription
objectTypeSTRINGType of Reltio object represented by the record.
directWinnerSTRINGIdentifier of the object that directly won the merge.
insertedTimeBIGINTTime when the merge record was written to staging storage.
winnerIdSTRINGIdentifier of the entity that remains after the merge.
loserIdSTRINGIdentifier of the entity merged into the winning entity.
mergeKeySTRINGIdentifier used to track the merge. The value matches loserId.
typeSTRINGMethod used to merge the entities: MANUAL, AUTO, ON_THE_FLY, or GROUP_MERGE.
deletedBOOLEANIndicates whether the merge record is deleted. Always false because deleted merge records are not included.
mergeRulesUrisARRAYURIs of the merge rules applied to the entities.
matchRulesARRAYLabels of the match rules that identified the entities as matches before the merge.
versionBIGINTVersion of the merge record.
timestampBIGINTTime when Reltio recorded the merge event.
ingestTimeTIMESTAMPTime when Databricks ingested the match record from staging storage into the matches table.

Workflow fields

Reltio writes workflow records to the workflows streaming table.

The workflow streaming tables contain the following fields.

FieldData typeDescription
objectTypeSTRINGType of Reltio object represented by the record.
uriSTRINGUnique URI for the workflow record.
timestampBIGINTTime when Reltio recorded the workflow event.
environmentNameSTRINGReltio environment in which the workflow activity occurred.
tenantIdSTRINGIdentifier of the Reltio tenant in which the workflow activity occurred.
objectURIsSTRINGURIs of the Reltio objects associated with the workflow, such as entities or relations.
resourceURIsSTRINGURIs of the resources associated with the workflow.
processInstanceIdSTRINGUnique identifier for an execution of the workflow process.
taskIdSTRINGUnique identifier for the task within the process instance.
processTypeSTRINGType of workflow process being executed.
taskTypeSTRINGType of task defined in the workflow process.
processInstanceCreateTimeBIGINTTime when the workflow process instance was created.
taskCreateTimeBIGINTTime when the workflow task was created.
usernameSTRINGIdentifier of the user associated with the workflow activity.
assigneeSTRINGIdentifier of the user assigned to the workflow task.
processInstanceDueDateBIGINTDate and time when the workflow process instance is due.
decisionSTRINGDecision submitted for the workflow task, such as approve or reject.
userActivityTimeBIGINTTime when the user performed the workflow action.
processInstanceCompleteBOOLEANIndicates whether the workflow process instance is complete.
processInstanceCompletionTimeBIGINTTime when the workflow process instance completed.
processSuspendedBOOLEANIndicates whether the workflow process instance is suspended.
commentSTRINGComment entered for the workflow activity.
ingestTimeTIMESTAMPTime when Databricks ingested the workflow record from staging storage into the workflows table.

Activity fields

The activities streaming table stores metadata from the Reltio activity log.

The activity streaming table contains the following fields.

FieldData typeDescription
objectTypeSTRINGType of Reltio object represented by the record.
activityClientTypeSTRINGType of client that submitted the request, such as the Reltio UI or API. If the globalId header does not specify a client type, the value is UNKNOWN.
activityIdSTRINGUnique identifier for the activity log record.
activityMethodSTRINGHTTP method used in the request.
activitySourceSTRINGSource recorded for the activity.
activityTimestampBIGINTTime when the activity occurred.
activityUrlSTRINGURL of the REST API request associated with the activity.
activityUserSTRINGIdentifier of the user who performed the activity.
activityDescriptionSTRINGDetailed description of the activity.
activityLabelSTRINGShort label describing the activity, such as USERSEARCH, USERPROFILEVIEW, or USERLOGIN.
itemsARRAY<STRUCT>Objects affected by the activity and details of the action performed on each object.
ingestTimeTIMESTAMPTime when Databricks ingested the activity record from staging storage into the activities table.