List of all items

Structs

• ArrowData
• DataSample
• DoraNode
• DoraNodeBuilder
• EventScheduler
• EventStream
• InputTracker
• Metadata
• Receiver
• StreamSegment
• arrow_utils::ipc_encode::InputDecoder
• integration_testing::IntegrationTestInput
• integration_testing::TestingOptions
• integration_testing::integration_testing_format::IntegrationTestInput
• integration_testing::integration_testing_format::TimedIncomingEvent
• metadata::Metadata

Enums

• Event
• InputState
• NodeError
• Parameter
• PatternError
• StopCause
• TryRecvError
• integration_testing::TestingInput
• integration_testing::TestingOutput
• integration_testing::integration_testing_format::IncomingEvent
• integration_testing::integration_testing_format::InputData
• integration_testing::integration_testing_format::RecordingStatus
• merged::Either
• merged::MergedEvent
• metadata::Parameter

Traits

• IntoArrow
• merged::MergeExternal
• merged::MergeExternalSend

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
• get_bool_param
• get_integer_param
• get_string_param
• init_tracing
• integration_testing::setup_integration_testing
• into_vec
• metadata::carries_pattern_correlation
• metadata::fnv1a
• metadata::get_bool_param
• metadata::get_integer_param
• metadata::get_string_param
• metadata::strip_internal_parameters

Type Aliases

• DataflowId
• MetadataParameters
• NodeResult
• metadata::MetadataParameters

Constants

• FIN
• FLUSH
• GOAL_ID
• GOAL_STATUS
• GOAL_STATUS_ABORTED
• GOAL_STATUS_CANCELED
• GOAL_STATUS_SUCCEEDED
• 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::REQUEST_ID
• metadata::SCHEMA_HASH
• metadata::SEGMENT_ID
• metadata::SEQ
• metadata::SESSION_ID