The Computation pattern with a Log implementation.
Interface Summary Interface Description ComputationComputation receives records from input streams one at a time, it can produce record on its output streams. ComputationContext RecordFilterRecord filtering enables to modify/skip record while it is append or read from a stream. RecordFilterChainA chain of record filters. StreamManagerGives access to StreamProcessor and appender for source provider. StreamProcessorRun a topology of computations according to some settings.
Class Summary Class Description AbstractBatchComputationAn abstract
Computationthat processes records by batch.
Computationthat manages the metadata init.
ComputationMetadataThe metadata defining a computation. ComputationMetadataMappingExtend the metadata to add a mapping for the input and output stream. ComputationPolicyDefines how a computation should handle the retries, fallback and batching if any. ComputationPolicyBuilderBuilder to create a ComputationPolicy. RecordBasic data object that contains: key, watermark, flag and data. SettingsSettings defines stream's partitions and computation's concurrency and policy. TopologyRepresent a Directed Acyclic Graph (DAG) of computations. Topology.Builder Topology.Vertex WatermarkWatermark represents a point in time.
Enum Summary Enum Description Record.Flag Topology.VertexType