List of all items

Structs

• ArrowData
• DataSample
• DoraNode
• EventScheduler
• EventStream
• Metadata
• Receiver
• integration_testing::IntegrationTestInput
• integration_testing::TestingOptions
• integration_testing::integration_testing_format::IntegrationTestInput
• integration_testing::integration_testing_format::TimedIncomingEvent

Enums

• Event
• Parameter
• StopCause
• TryRecvError
• integration_testing::TestingInput
• integration_testing::TestingOutput
• integration_testing::integration_testing_format::IncomingEvent
• integration_testing::integration_testing_format::InputData
• merged::Either
• merged::MergedEvent

Traits

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

Functions

• arrow_utils::buffer_into_arrow_array
• arrow_utils::copy_array_into_sample
• arrow_utils::required_data_size
• init_tracing
• integration_testing::setup_integration_testing
• into_vec

Type Aliases

• DataflowId
• MetadataParameters

Constants

• ZERO_COPY_THRESHOLD