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:

java.io.Serializable, HasDisplayData

Enclosing class:

PulsarIO

public abstract static class PulsarIO.Read
extends PTransform<PBegin,PCollection<PulsarMessage>>

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.beam.sdk.transforms.PTransform

name, resourceHints

Constructor Summary

Constructors

Constructor and Description
Read()

Method Summary

Modifier and Type	Method and Description
PCollection<PulsarMessage>	expand(PBegin input) Override this method to specify how this PTransform should be expanded on the given InputT.
PulsarIO.Read	withAdminUrl(java.lang.String url)
PulsarIO.Read	withClientUrl(java.lang.String url)
PulsarIO.Read	withEndMessageId(org.apache.pulsar.client.api.MessageId msgId)
PulsarIO.Read	withEndTimestamp(java.lang.Long timestamp)
PulsarIO.Read	withExtractOutputTimestampFn(SerializableFunction<org.apache.pulsar.client.api.Message<byte[]>,Instant> fn)
PulsarIO.Read	withProcessingTime()
PulsarIO.Read	withPublishTime()
PulsarIO.Read	withPulsarClient(SerializableFunction<java.lang.String,org.apache.pulsar.client.api.PulsarClient> pulsarClientFn)
PulsarIO.Read	withStartTimestamp(java.lang.Long timestamp)
PulsarIO.Read	withTopic(java.lang.String topic)

Methods inherited from class org.apache.beam.sdk.transforms.PTransform

compose, compose, getAdditionalInputs, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setResourceHints, toString, validate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

Read

public Read()

Method Detail

withAdminUrl

public PulsarIO.Read withAdminUrl(java.lang.String url)

withClientUrl

public PulsarIO.Read withClientUrl(java.lang.String url)

withTopic

public PulsarIO.Read withTopic(java.lang.String topic)

withStartTimestamp

public PulsarIO.Read withStartTimestamp(java.lang.Long timestamp)

withEndTimestamp

public PulsarIO.Read withEndTimestamp(java.lang.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<java.lang.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>>