1. Process Data Streams
  2. Generic Runtime(Alpha)

Generic Runtime Feature Matrix

This section describes the feature matrix of the Generic Runtime.

Input Arguments

InputJavaGoPythonGeneric ExecutableGeneric NodeGeneric Python
Custom SerDe?
Schema - Avro?
Schema - JSON?
Schema - Protobuf?
Schema - KeyValue?
Schema - AutoSchema?
Scehma - Protobuf Native?
e-2-e encryption
maxMessageRetries
dead-letter policy
SubscriptionName
SubscriptionType
SubscriptionInitialPosition
AutoAck

Note

Since the executable function needs to implement the marshal&unmarshal by users, we left a ? for schemas because we are not sure whether it is supported or not.

Output Arguments

OutputJavaGoPythonGeneric ExecutableGeneric NodeGeneric Python
Custom SerDe?
Schema - Avro?
Schema - JSON?
Schema - Protobuf?
Schema - KeyValue?
Schema - AutoSchema?
Schema - Protobuf Native?
useThreadLocalProducers
Key-based Batcher
e-2-e encryption
Compression

Context

ContextJavaGoPythonGeneric NodeGeneric Python
InputTopics
OutputTopic
CurrentRecord
OutputSchemaType
Tenant
Namespace
FunctionName
FunctionId
InstanceId
NumInstances
FunctionVersion
PulsarAdminClient
GetLogger
RecordMetrics
UserConfig
Secrets
State
Publish
ConsumerBuilder
Seek / Pause / Resume
PulsarClient

Note

Since the executable function needs to implement the context by users, we are not sure whether features are supported or not so don't list the features for Executable function.

Other

OtherJavaGoPythonGeneric ExecutableGeneric NodeGeneric Python
Resources
At-most-once
At-least-once
Effectively-once

Note

The Effectively-once is not supported because it may have some problems, still working on it.

Previous
Develop&Deploy Executable Function