Package org.apache.beam.sdk.io.pulsar

Class PulsarIO.Read

java.lang.Object
org.apache.beam.sdk.transforms.PTransform<PBegin,PCollection<PulsarMessage>>
org.apache.beam.sdk.io.pulsar.PulsarIO.Read
All Implemented Interfaces:
Serializable, HasDisplayData
Enclosing class:
PulsarIO
public abstract static class PulsarIO.Read extends PTransform<PBegin,PCollection<PulsarMessage>>
See Also:

  • Constructor Details

    • Read

      public Read()

  • Method Details

    • withAdminUrl

      public PulsarIO.Read withAdminUrl(String url)

    • withClientUrl

      public PulsarIO.Read withClientUrl(String url)

    • withTopic

      public PulsarIO.Read withTopic(String topic)

    • withStartTimestamp

      public PulsarIO.Read withStartTimestamp(Long timestamp)

    • withEndTimestamp

      public PulsarIO.Read withEndTimestamp(Long timestamp)

    • withEndMessageId

      public PulsarIO.Read withEndMessageId(org.apache.pulsar.client.api.MessageId msgId)

    • withExtractOutputTimestampFn

      public PulsarIO.Read withExtractOutputTimestampFn(SerializableFunction<org.apache.pulsar.client.api.Message<byte[]>,Instant> fn)

    • withPublishTime

      public PulsarIO.Read withPublishTime()

    • withProcessingTime

      public PulsarIO.Read withProcessingTime()

    • withPulsarClient

      public PulsarIO.Read withPulsarClient(SerializableFunction<String,org.apache.pulsar.client.api.PulsarClient> pulsarClientFn)

    • expand

      public PCollection<PulsarMessage> expand(PBegin input)
      Description copied from class: PTransform
      Override this method to specify how this PTransform should be expanded on the given InputT.

      NOTE: This method should not be called directly. Instead apply the PTransform should be applied to the InputT using the apply method.

      Composite transforms, which are defined in terms of other transforms, should return the output of one of the composed transforms. Non-composite transforms, which do not apply any transforms internally, should return a new unbound output and register evaluators (via backend-specific registration methods).

      Specified by:
      expand in class PTransform<PBegin,PCollection<PulsarMessage>>