Modifier and Type | Method and Description |
---|---|
<T extends OUT> |
PulsarSourceBuilder.setDeserializationSchema(PulsarDeserializationSchema<T> deserializationSchema)
DeserializationSchema is required for getting the
Schema for deserialize message from
pulsar and getting the TypeInformation for message serialization in flink. |
Modifier and Type | Method and Description |
---|---|
static <OUT> SourceReader<OUT,PulsarPartitionSplit> |
PulsarSourceReaderFactory.create(SourceReaderContext readerContext,
PulsarDeserializationSchema<OUT> deserializationSchema,
Configuration configuration,
SourceConfiguration sourceConfiguration) |
Modifier and Type | Class and Description |
---|---|
class |
PulsarTypeInformationWrapper<T>
Wrap the flink TypeInformation into a
PulsarDeserializationSchema . |
Modifier and Type | Method and Description |
---|---|
static <T> PulsarDeserializationSchema<T> |
PulsarDeserializationSchema.flinkSchema(DeserializationSchema<T> deserializationSchema)
Create a PulsarDeserializationSchema by using the flink's
DeserializationSchema . |
static <T> PulsarDeserializationSchema<T> |
PulsarDeserializationSchema.flinkTypeInfo(TypeInformation<T> information,
ExecutionConfig config)
Create a PulsarDeserializationSchema by using the given
TypeInformation . |
static <K,V> PulsarDeserializationSchema<org.apache.pulsar.common.schema.KeyValue<K,V>> |
PulsarDeserializationSchema.pulsarSchema(org.apache.pulsar.client.api.Schema<org.apache.pulsar.common.schema.KeyValue<K,V>> schema,
Class<K> keyClass,
Class<V> valueClass)
Create a PulsarDeserializationSchema by using the Pulsar
Schema instance. |
static <T> PulsarDeserializationSchema<T> |
PulsarDeserializationSchema.pulsarSchema(org.apache.pulsar.client.api.Schema<T> schema)
Create a PulsarDeserializationSchema by using the Pulsar
Schema instance. |
static <T> PulsarDeserializationSchema<T> |
PulsarDeserializationSchema.pulsarSchema(org.apache.pulsar.client.api.Schema<T> schema,
Class<T> typeClass)
Create a PulsarDeserializationSchema by using the Pulsar
Schema instance. |
Constructor and Description |
---|
PulsarOrderedPartitionSplitReader(org.apache.pulsar.client.api.PulsarClient pulsarClient,
org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin,
Configuration configuration,
SourceConfiguration sourceConfiguration,
PulsarDeserializationSchema<OUT> deserializationSchema) |
PulsarUnorderedPartitionSplitReader(org.apache.pulsar.client.api.PulsarClient pulsarClient,
org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin,
Configuration configuration,
SourceConfiguration sourceConfiguration,
PulsarDeserializationSchema<OUT> deserializationSchema,
org.apache.pulsar.client.api.transaction.TransactionCoordinatorClient coordinatorClient) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.