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.Basic information about a Pulsar function.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.