List of all items
Structs
- DataSample
- DoraArray
- DoraNode
- DoraNodeBuilder
- EncodedSample
- Metadata
- SampleAllocator
- StreamSegment
- arrow_utils::IpcPayload
- arrow_utils::ipc_encode::InputDecoder
- arrow_utils::ipc_encode::PreparedIpc
- arrow_utils::ipc_encode::PreparedUint8Ipc
- dora_core::config::DataId
- dora_core::config::NodeId
- dora_core::config::OperatorId
- event_stream::EventScheduler
- event_stream::EventStream
- event_stream::input_tracker::InputTracker
- integration_testing::IntegrationTestInput
- integration_testing::OutputReceiver
- integration_testing::OutputSender
- integration_testing::TestingOptions
- integration_testing::integration_testing_format::IntegrationTestInput
- integration_testing::integration_testing_format::TimedIncomingEvent
- metadata::Metadata
Enums
- NodeError
- Parameter
- PatternError
- event_stream::Event
- event_stream::StopCause
- event_stream::TryRecvError
- event_stream::input_tracker::InputState
- event_stream::merged::Either
- event_stream::merged::MergedEvent
- integration_testing::TestingInput
- integration_testing::TestingOutput
- integration_testing::integration_testing_format::IncomingEvent
- integration_testing::integration_testing_format::InputData
- integration_testing::integration_testing_format::RecordingStatus
- metadata::Parameter
Traits
Functions
- arrow_utils::decode_arrow_ipc
- arrow_utils::decode_arrow_ipc_zero_copy
- arrow_utils::encode_arrow_ipc
- arrow_utils::ipc_encode::batch_fast_path_len
- arrow_utils::ipc_encode::batch_slice
- arrow_utils::ipc_encode::encode_batch_into
- arrow_utils::ipc_encode::encode_ipc_into
- arrow_utils::ipc_encode::encode_ipc_to_vec
- arrow_utils::ipc_encode::encode_schema_message
- arrow_utils::ipc_encode::encode_uint8_ipc_header
- arrow_utils::ipc_encode::ipc_fast_path_len
- arrow_utils::ipc_encode::schema_block_and_hash
- arrow_utils::ipc_encode::schema_block_len
- arrow_utils::ipc_encode::uint8_ipc_len
- event_stream::data_to_arrow_array
- event_stream::extensions::drain_dropped_keys
- get_bool_param
- get_integer_param
- get_string_param
- init_tracing
- integration_testing::drain_outputs
- integration_testing::output_channel
- integration_testing::setup_integration_testing
- into_vec
- metadata::carries_pattern_correlation
- metadata::debug_frame_wire_size
- metadata::fnv1a
- metadata::get_bool_param
- metadata::get_integer_param
- metadata::get_string_param
- metadata::strip_internal_parameters
Type Aliases
Constants
- FIN
- FLUSH
- GOAL_ID
- GOAL_STATUS
- GOAL_STATUS_ABORTED
- GOAL_STATUS_CANCELED
- GOAL_STATUS_SUCCEEDED
- OPEN_TELEMETRY_CONTEXT
- REQUEST_ID
- SEGMENT_ID
- SEQ
- SESSION_ID
- ZERO_COPY_THRESHOLD
- metadata::FIN
- metadata::FLUSH
- metadata::FRAMING
- metadata::FRAMING_ARROW_IPC
- metadata::GOAL_ID
- metadata::GOAL_STATUS
- metadata::GOAL_STATUS_ABORTED
- metadata::GOAL_STATUS_CANCELED
- metadata::GOAL_STATUS_SUCCEEDED
- metadata::OPEN_TELEMETRY_CONTEXT
- metadata::REQUEST_ID
- metadata::SCHEMA_HASH
- metadata::SEGMENT_ID
- metadata::SEQ
- metadata::SESSION_ID
- metadata::STARTUP_ACK_CONSUMER_PARAM
- metadata::STARTUP_ACK_INPUT_PARAM
- metadata::STARTUP_ACK_PARAM
- metadata::STARTUP_MARKER_PARAM
- metadata::WIRE_SIZE