Uses of Package
org.nuxeo.lib.stream.computation
-
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.audit.storage.stream Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.ComputationContext Record Basic data object that contains: key, watermark, flag and data.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.drive.action Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.automation.core.operations.services.bulk Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.automation.core.operations.services.workmanager Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.ComputationContext ComputationPolicy Defines how a computation should handle the retries, fallback and batching if any.Record Basic data object that contains: key, watermark, flag and data.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.action Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.blob.stream Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.ComputationContext Record Basic data object that contains: key, watermark, flag and data.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.bulk Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.StreamProcessor Run a topology of computations according to some settings.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.bulk.action Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.bulk.action.computation Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.ComputationContext Record Basic data object that contains: key, watermark, flag and data. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.bulk.computation Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.ComputationContext Record Basic data object that contains: key, watermark, flag and data. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.bulk.introspection Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.ComputationContext Record Basic data object that contains: key, watermark, flag and data.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.event.stream Class Description Record Basic data object that contains: key, watermark, flag and data. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.migrator Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.model.stream Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.ComputationContext Record Basic data object that contains: key, watermark, flag and data.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.security Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.storage.action Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.storage.dbs.action Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.transientstore.computation Class Description RecordFilter Record filtering enables to modify/skip record while it is append or read from a stream. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.work Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.ComputationContext Record Basic data object that contains: key, watermark, flag and data.RecordFilter Record filtering enables to modify/skip record while it is append or read from a stream.RecordFilterChain A chain of record filters.Settings Settings defines stream's partitions and computation's concurrency and policy.StreamManager Gives access to StreamProcessor and appender for source provider.StreamProcessor Run a topology of computations according to some settings.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.audit.impl Class Description AbstractBatchComputation An abstractComputationthat processes records by batch.AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.ComputationContext Record Basic data object that contains: key, watermark, flag and data.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.audit.listener Class Description Record Basic data object that contains: key, watermark, flag and data.StreamManager Gives access to StreamProcessor and appender for source provider. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.audit.stream Class Description Record Basic data object that contains: key, watermark, flag and data. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.csv.export.action Class Description Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.csv.export.computation Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.ComputationContext -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.picture.recompute Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.routing.core.bulk Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.thumbnail.action Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.video.action Class Description Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.video.computation Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.ComputationContext Record Basic data object that contains: key, watermark, flag and data. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.restapi.server.jaxrs.management Class Description Record Basic data object that contains: key, watermark, flag and data. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.elasticsearch.bulk Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.ComputationContext Record Basic data object that contains: key, watermark, flag and data.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.lib.stream.computation Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.ComputationContext ComputationMetadata The metadata defining a computation.ComputationMetadataMapping Extend the metadata to add a mapping for the input and output stream.ComputationPolicy Defines how a computation should handle the retries, fallback and batching if any.ComputationPolicyBuilder Builder to create a ComputationPolicy.Record Basic data object that contains: key, watermark, flag and data.Record.Flag RecordFilter Record filtering enables to modify/skip record while it is append or read from a stream.RecordFilterChain A chain of record filters.Settings Settings defines stream's partitions and computation's concurrency and policy.StreamProcessor Run a topology of computations according to some settings.Topology Represent a Directed Acyclic Graph (DAG) of computations.Topology.Builder Topology.Vertex Topology.VertexType Watermark Watermark represents a point in time. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.lib.stream.computation.internals Class Description ComputationContext ComputationMetadataMapping Extend the metadata to add a mapping for the input and output stream.ComputationPolicy Defines how a computation should handle the retries, fallback and batching if any.Record Basic data object that contains: key, watermark, flag and data.RecordFilter Record filtering enables to modify/skip record while it is append or read from a stream.RecordFilterChain A chain of record filters.StreamManager Gives access to StreamProcessor and appender for source provider.Watermark Watermark represents a point in time. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.lib.stream.computation.log Class Description Computation Computation receives records from input streams one at a time, it can produce record on its output streams.ComputationMetadataMapping Extend the metadata to add a mapping for the input and output stream.ComputationPolicy Defines how a computation should handle the retries, fallback and batching if any.Record Basic data object that contains: key, watermark, flag and data.RecordFilter Record filtering enables to modify/skip record while it is append or read from a stream.RecordFilterChain A chain of record filters.Settings Settings defines stream's partitions and computation's concurrency and policy.StreamManager Gives access to StreamProcessor and appender for source provider.StreamProcessor Run a topology of computations according to some settings.Topology Represent a Directed Acyclic Graph (DAG) of computations.Topology.Vertex Watermark Watermark represents a point in time. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.lib.stream.tools.command Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.ComputationContext Record Basic data object that contains: key, watermark, flag and data.StreamProcessor Run a topology of computations according to some settings.Topology Represent a Directed Acyclic Graph (DAG) of computations. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.lib.stream.tools.renderer Class Description Record Basic data object that contains: key, watermark, flag and data. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.runtime.codec Class Description Record Basic data object that contains: key, watermark, flag and data. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.runtime.pubsub Class Description Record Basic data object that contains: key, watermark, flag and data. -
Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.runtime.stream Class Description AbstractComputation An abstractComputationthat manages the metadata init.Computation Computation receives records from input streams one at a time, it can produce record on its output streams.ComputationContext ComputationPolicy Defines how a computation should handle the retries, fallback and batching if any.ComputationPolicyBuilder Builder to create a ComputationPolicy.Record Basic data object that contains: key, watermark, flag and data.RecordFilter Record filtering enables to modify/skip record while it is append or read from a stream.Settings Settings defines stream's partitions and computation's concurrency and policy.StreamManager Gives access to StreamProcessor and appender for source provider.Topology Represent a Directed Acyclic Graph (DAG) of computations.