@Internal public class PulsarSinkContextImpl extends Object implements PulsarSinkContext
Constructor and Description |
---|
PulsarSinkContextImpl(Sink.InitContext initContext,
SinkConfiguration sinkConfiguration) |
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.
|
public PulsarSinkContextImpl(Sink.InitContext initContext, SinkConfiguration sinkConfiguration)
public int getParallelInstanceId()
PulsarSinkContext
PulsarSinkContext.getNumberOfParallelInstances()
getParallelInstanceId
in interface PulsarSinkContext
public int getNumberOfParallelInstances()
getNumberOfParallelInstances
in interface PulsarSinkContext
public boolean isEnableSchemaEvolution()
PulsarSinkContext
isEnableSchemaEvolution
in interface PulsarSinkContext
public long processTime()
PulsarSinkContext
processTime
in interface PulsarSinkContext
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.