Add FlushStrategy as enum
This commit is contained in:
parent
e8d672d903
commit
c72ecaf219
@ -7,6 +7,7 @@ import {
|
|||||||
TransformOptions,
|
TransformOptions,
|
||||||
WithEncoding,
|
WithEncoding,
|
||||||
JsonParseOptions,
|
JsonParseOptions,
|
||||||
|
FlushStrategy,
|
||||||
} from "./definitions";
|
} from "./definitions";
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -249,7 +250,7 @@ export function parallelMap<T, R>(
|
|||||||
export function accumulator(
|
export function accumulator(
|
||||||
batchSize: number,
|
batchSize: number,
|
||||||
batchRate: number | undefined,
|
batchRate: number | undefined,
|
||||||
flushStrategy: "sliding" | "rolling",
|
flushStrategy: FlushStrategy,
|
||||||
keyBy?: string,
|
keyBy?: string,
|
||||||
) {
|
) {
|
||||||
return baseFunctions.accumulator(
|
return baseFunctions.accumulator(
|
||||||
|
Loading…
Reference in New Issue
Block a user