def METHOD_NAME(primary_key_value: Mapping[str, Any], stringified_primary_key: str, primary_key: List[List[str]]):
    processor = initialize_processor()
    record = AirbyteRecordMessage(
        stream="stream1",
        namespace="namespace1",
        data={
            "text": "This is the text and it is long enough to be split into multiple chunks. This is the text and it is long enough to be split into multiple chunks. This is the text and it is long enough to be split into multiple chunks",
            "age": 25,
            **primary_key_value
        },
        emitted_at=1234,
    )
    processor.text_fields = ["text"]
    processor.streams["namespace1_stream1"].destination_sync_mode = DestinationSyncMode.append_dedup
    processor.streams["namespace1_stream1"].primary_key = primary_key
    chunks, id_to_delete = processor.process(record)
    assert len(chunks) > 1
    for chunk in chunks:
        assert chunk.metadata["_record_id"] == stringified_primary_key
    assert id_to_delete == stringified_primary_key