@numaproj/numaflow-js

The official JavaScript/TypeScript SDK for Numaflow.

Numaflow is a Kubernetes-native tool for running massively parallel data processing and streaming jobs. This SDK allows you to write User Defined Functions (UDFs) and User Defined Sources/Sinks in JavaScript/TypeScript.

Features

• Map: Transform messages one-to-many
• MapStream: Stream transformed messages
• BatchMap: Process messages in batches
• Reduce: Aggregate messages by key over time windows
• ReduceStream: Stream aggregated messages
• SessionReduce: Session-based aggregation
• Accumulator: Stateful message accumulation
• Source: Custom data sources
• SourceTransform: Transform data at the source
• Sink: Custom data sinks
• SideInput: Side channel inputs

Quick Start

import { map } from '@numaproj/numaflow-js';

const server = new map.AsyncServer(async (datum) => {
  const value = datum.value.toString();
  return [new map.Message(Buffer.from(value.toUpperCase()))];
});

server.start();
Copy