OUT
- The output type of the source.@PublicEvolving public final class PulsarSource<OUT> extends Object implements Source<OUT,PulsarPartitionSplit,PulsarSourceEnumState>, ResultTypeQueryable<OUT>
PulsarSourceBuilder
to construct a
PulsarSource
. The following example shows how to create a PulsarSource emitting records
of String
type.
PulsarSource<String> source = PulsarSource
.builder()
.setTopics(TOPIC1, TOPIC2)
.setServiceUrl(getServiceUrl())
.setAdminUrl(getAdminUrl())
.setSubscriptionName("test")
.setDeserializationSchema(PulsarDeserializationSchema.flinkSchema(new SimpleStringSchema()))
.setBounded(StopCursor::defaultStopCursor)
.build();
See PulsarSourceBuilder
for more details.
public static <OUT> PulsarSourceBuilder<OUT> builder()
PulsarSource
.public Boundedness getBoundedness()
Source
getBoundedness
in interface Source<OUT,PulsarPartitionSplit,PulsarSourceEnumState>
public SourceReader<OUT,PulsarPartitionSplit> createReader(SourceReaderContext readerContext) throws Exception
Source
createReader
in interface Source<OUT,PulsarPartitionSplit,PulsarSourceEnumState>
readerContext
- The context
for the source reader.Exception
- The implementor is free to forward all exceptions directly. Exceptions
thrown from this method cause task failure/recovery.public SplitEnumerator<PulsarPartitionSplit,PulsarSourceEnumState> createEnumerator(SplitEnumeratorContext<PulsarPartitionSplit> enumContext)
Source
createEnumerator
in interface Source<OUT,PulsarPartitionSplit,PulsarSourceEnumState>
enumContext
- The context
for the split enumerator.public SplitEnumerator<PulsarPartitionSplit,PulsarSourceEnumState> restoreEnumerator(SplitEnumeratorContext<PulsarPartitionSplit> enumContext, PulsarSourceEnumState checkpoint)
Source
restoreEnumerator
in interface Source<OUT,PulsarPartitionSplit,PulsarSourceEnumState>
enumContext
- The context
for the restored split
enumerator.checkpoint
- The checkpoint to restore the SplitEnumerator from.public SimpleVersionedSerializer<PulsarPartitionSplit> getSplitSerializer()
Source
getSplitSerializer
in interface Source<OUT,PulsarPartitionSplit,PulsarSourceEnumState>
public SimpleVersionedSerializer<PulsarSourceEnumState> getEnumeratorCheckpointSerializer()
Source
SplitEnumerator
checkpoint. The serializer is used for
the result of the SplitEnumerator#snapshotState()
method.getEnumeratorCheckpointSerializer
in interface Source<OUT,PulsarPartitionSplit,PulsarSourceEnumState>
public TypeInformation<OUT> getProducedType()
ResultTypeQueryable
TypeInformation
) produced by this function or input format.getProducedType
in interface ResultTypeQueryable<OUT>
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.