Module datafusion::physical_plan::test::exec

Simple iterator over batches for use in testing

Structs

• BarrierExec
  A Mock ExecutionPlan that does not start producing input until a barrier is called
• BatchIndex
  Index into the data that has been returned so far
• BlockingExec
  Execution plan that emits streams that block forever.
• BlockingStream
  A RecordBatchStream that is pending forever.
• ErrorExec
  A mock execution plan that errors on a call to execute
• MockExec
  A Mock ExecutionPlan that can be used for writing tests of other ExecutionPlans
• PanicExec
  Execution plan that emits streams that panics.
• StatisticsExec
  A mock execution plan that simply returns the provided statistics
• TestStream
  Iterator over batches

Functions

• assert_strong_count_converges_to_zero
  Asserts that the strong count of the given Weak pointer converges to zero.