@Internal public final class PulsarSourceReaderFactory extends Object
PulsarOrderedSourceReader
.
PulsarUnorderedSourceReader
.
Modifier and Type | Method and Description |
---|---|
static <OUT> SourceReader<OUT,PulsarPartitionSplit> |
create(SourceReaderContext readerContext,
PulsarDeserializationSchema<OUT> deserializationSchema,
SourceConfiguration sourceConfiguration) |
public static <OUT> SourceReader<OUT,PulsarPartitionSplit> create(SourceReaderContext readerContext, PulsarDeserializationSchema<OUT> deserializationSchema, SourceConfiguration sourceConfiguration)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.