Package org.apache.pulsar.client.api

Interface BatcherBuilder

All Superinterfaces:

Serializable

@Public
@Stable
public interface BatcherBuilder
extends Serializable

Batcher builder.

Field Summary

Fields

Modifier and Type	Field	Description
static final BatcherBuilder	DEFAULT	Default batch message container.
static final BatcherBuilder	KEY_BASED	Key based batch message container.

Method Summary

Modifier and Type	Method	Description
BatchMessageContainer	build()	Build a new batch message container.

Field Details

DEFAULT

static final BatcherBuilder DEFAULT

Default batch message container.

incoming single messages: (k1, v1), (k2, v1), (k3, v1), (k1, v2), (k2, v2), (k3, v2), (k1, v3), (k2, v3), (k3, v3)

batched into single batch message: [(k1, v1), (k2, v1), (k3, v1), (k1, v2), (k2, v2), (k3, v2), (k1, v3), (k2, v3), (k3, v3)]

KEY_BASED

static final BatcherBuilder KEY_BASED

Key based batch message container.

incoming single messages: (k1, v1), (k2, v1), (k3, v1), (k1, v2), (k2, v2), (k3, v2), (k1, v3), (k2, v3), (k3, v3)

batched into multiple batch messages: [(k1, v1), (k1, v2), (k1, v3)], [(k2, v1), (k2, v2), (k2, v3)], [(k3, v1), (k3, v2), (k3, v3)]

Method Details

build

BatchMessageContainer build()

Build a new batch message container.

Returns:

new batch message container