Class PulsarClientOp

java.lang.Object
io.nosqlbench.adapter.pulsar.ops.PulsarOp
io.nosqlbench.adapter.pulsar.ops.PulsarClientOp
All Implemented Interfaces:
CycleOp<Object>, LongFunction<Object>
Direct Known Subclasses:
MessageConsumerOp, MessageProducerOp, MessageReaderOp
public abstract class PulsarClientOp extends PulsarOp

  • Field Details

    • pulsarClient

      protected final org.apache.pulsar.client.api.PulsarClient pulsarClient

    • pulsarSchema

      protected final org.apache.pulsar.client.api.Schema<?> pulsarSchema

    • messageSizeHistogram

      protected final com.codahale.metrics.Histogram messageSizeHistogram

    • payloadRttHistogram

      protected final com.codahale.metrics.Histogram payloadRttHistogram

    • e2eMsgProcLatencyHistogram

      protected final com.codahale.metrics.Histogram e2eMsgProcLatencyHistogram

    • transactionCommitTimer

      protected final com.codahale.metrics.Timer transactionCommitTimer

  • Constructor Details

    • PulsarClientOp

      public PulsarClientOp(PulsarAdapterMetrics pulsarAdapterMetrics, org.apache.pulsar.client.api.PulsarClient pulsarClient, org.apache.pulsar.client.api.Schema<?> pulsarScheam, boolean asyncApi)

  • Method Details

    • getAvroSchemaFromConfiguration

      protected org.apache.avro.Schema getAvroSchemaFromConfiguration()

    • getKeyAvroSchemaFromConfiguration

      protected org.apache.avro.Schema getKeyAvroSchemaFromConfiguration()