Package org.apache.pulsar.common.functions
package org.apache.pulsar.common.functions
Implementation of policies.
-
ClassDescriptionConfiguration to aggregate various authentication params.Configuration of a consumer.Configuration of the producer inside the function.Configuration of Pulsar Function.Definition of possible processing guarantees.Definition of possible runtime environments.Function state.Configuration of the producer inside the function.Class representing resources, such as CPU, RAM, and disk size.Configuration of a windowing function.This is a semantic option that windows can provide, forcing the semantics of the
FunctionConfig.ProcessingGuarantees
to be equal to MANUAL, and then letting the windows function handle the semantic timing by itself.Worker information.