List of all items
Structs
- PluginChannelCaps
- PluginLabel
- PluginModule
- PluginModuleRef
- PluginModule_Prefix
- PluginResult
- PluginRuntimeConfiguration
- PluginSideOutputDescriptor
- PluginStateBackendConfig
- PluginUdfDescriptor
- PreprocessorPluginDispatcher
- SinkPluginDispatcher
- SourcePluginDispatcher
- StateKey
- TransformPluginDispatcher
- api::CheckpointEpoch
- api::PluginStateBackend
- api::PluginStateBackendFactory
- async::DirectTokioProxy
- async::PluginAsyncRuntime_TO
- async::PluginAsyncRuntime_trait::PluginAsyncRuntime_Interface
- async::PluginAsyncRuntime_trait::PluginAsyncRuntime_TO
- ffi::PluginChannel
- ffi::PluginChannels
- ffi::PluginCheckpointEpoch
- ffi::PluginMetric_Interface
- ffi::PluginMetric_NEMarker
- ffi::PluginMetric_Storage
- ffi::PluginMetricsChannel
- ffi::PluginMetricsRecorder
- ffi::PluginMsg_Interface
- ffi::PluginMsg_NEMarker
- ffi::PluginMsg_Storage
- ffi::PluginOptions
- ffi::SafeArrowArray
- ffi::SafeArrowColumn
- ffi::SafeArrowSchema
- ffi::SafeUdfArg
Enums
Traits
- IntoSinkPluginResult
- IntoSourcePluginResult
- IntoTransformPluginResult
- StateOperatorBackend
- api::PreprocessorPlugin
- api::SideOutputPlugin
- api::SinkPlugin
- api::SourcePlugin
- api::SupportsGracefulShutdown
- api::TransformPlugin
- async::PluginAsyncRuntime
- async::PluginAsyncRuntime_trait::PluginAsyncRuntime
- ffi::PluginMetric_Bounds
- ffi::PluginMsg_Bounds
Macros
- init_plugin
- init_plugin_with_async_runtime
- register_plugin_preprocessor
- register_plugin_side_output
- register_plugin_sink
- register_plugin_source
- register_plugin_transform
- register_plugin_udf
- register_plugin_udf_fn
- set_plugin_input_buffer
- set_plugin_output_buffer
Functions
- build_plugin_udf_descriptor
- invoke_plugin_udf
- preprocessor_generator
- sink_generator
- source_generator
- transform_generator
Type Aliases
- async::PluginAsyncRuntimeObj
- async::PluginAsyncRuntime_CTO
- async::PluginAsyncRuntime_trait::PluginAsyncRuntime_Backend
- async::PluginAsyncRuntime_trait::PluginAsyncRuntime_CTO
- ffi::PluginMetric_NE
- ffi::PluginMsg_NE