org.apache.flink.connector.pulsar.sink.writer.context

Interface PulsarSinkContext

All Known Implementing Classes:

PulsarSinkContextImpl

@PublicEvolving
public interface PulsarSinkContext

This context provides information on the pulsar record target location.

Method Summary

Modifier and Type	Method and Description
int	getNumberOfParallelInstances()
int	getParallelInstanceId() Get the number of the subtask that PulsarSink is running on.
boolean	isEnableSchemaEvolution() Pulsar can check the schema and upgrade the schema automatically.
long	processTime() Returns the current process time in flink.

Method Detail

getParallelInstanceId

int getParallelInstanceId()

Get the number of the subtask that PulsarSink is running on. The numbering starts from 0 and goes up to parallelism-1. (parallelism as returned by getNumberOfParallelInstances()

Returns:

number of subtask

getNumberOfParallelInstances

int getNumberOfParallelInstances()

Returns:

number of parallel PulsarSink tasks.

isEnableSchemaEvolution

boolean isEnableSchemaEvolution()

Pulsar can check the schema and upgrade the schema automatically. If you enable this option, we wouldn't serialize the record into bytes, we send and serialize it in the client.

processTime

long processTime()

Returns the current process time in flink.