DICE API Documentation/com.embabel.dice.projection.graph/GraphProjectionService

GraphProjectionService

class GraphProjectionService(graphProjector: GraphProjector, persister: GraphRelationshipPersister, schema: <Error class: unknown class>, recordStore: ProjectionRecordStore? = null, reconciler: Reconciler = AlwaysCreateReconciler)

Bundles a GraphProjector, GraphRelationshipPersister, and DataDictionary together so you can project propositions to graph relationships and persist them in one call.

Parameters

graphProjector

converts propositions to relationships

persister

writes those relationships to the graph

schema

data dictionary used for relationship validation

recordStore

optional lineage store; when supplied, one ProjectionRecord is written per result (PROJECTED / ADOPTED / SKIPPED / FAILED). Nothing is recorded when null.

reconciler

decides per successful projection whether to create a new artifact (PROJECTED) or align with an existing one (ADOPTED). Defaults to AlwaysCreateReconciler. Only consulted when a recordStore is present. Node-level de-duplication on the graph side is a planned follow-up.

Constructors

Link copied to clipboard
constructor(graphProjector: GraphProjector, persister: GraphRelationshipPersister, schema: <Error class: unknown class>, recordStore: ProjectionRecordStore? = null, reconciler: Reconciler = AlwaysCreateReconciler)

Types

Link copied to clipboard
object Companion

Functions

Link copied to clipboard
fun projectAndPersist(propositions: List<Proposition>): <Error class: unknown class><ProjectionResults<ProjectedRelationship>, RelationshipPersistenceResult>

Projects the given propositions to graph relationships and persists them. When a recordStore is configured, one ProjectionRecord is emitted per result, all sharing a single run ID for the batch.