Workload distribution between edge and core systems

A non-transitory machine-readable medium having instructions stored therein, which when executed by a processor, cause operations for managing data in a distributed system to be performed, the operations comprising:

• obtaining, by an entity that is remote to a data user, a data stream;
• filtering, by the entity, the data stream for relevant content to the data user to obtain a filtered data stream;
• signing, by the entity, the filtered data stream to obtain a signed filtered data stream;
• analyzing, by the entity, the signed filtered data stream to obtain metadata for the signed filtered data stream that is relevant to at least one use of the data stream by the data user;
• packaging, by the entity, the signed filtered data stream with the metadata to obtain an enhanced stream;
• and
• distributing, by the entity, the enhanced stream to facilitate provisioning of computer implemented services by the data user.

A data processing system, comprising:

• a processor;
• and
• a memory coupled to the processor to store instructions, which when executed by the processor, cause operations for managing data in a distributed system to be performed, the operations comprising:
• obtaining, by an entity that is remote to a data user, a data stream;
• filtering, by the entity, the data stream for relevant content to the data user to obtain a filtered data stream;
• signing, by the entity, the filtered data stream to obtain a signed filtered data stream;
• analyzing, by the entity, the signed filtered data stream to obtain metadata for the signed filtered data stream that is relevant to at least one use of the data stream by the data user;
• packaging, by the entity, the signed filtered data stream with the metadata to obtain an enhanced stream;
• and
• distributing, by the entity, the enhanced stream to facilitate provisioning of computer implemented services by the data user.