Expand description
Simple iterator over batches for use in testing
Structs§
- Barrier
Exec - A Mock ExecutionPlan that does not start producing input until a barrier is called
- Batch
Index - Index into the data that has been returned so far
- Blocking
Exec - Execution plan that emits streams that block forever.
- Blocking
Stream - A
RecordBatchStreamthat is pending forever. - Error
Exec - A mock execution plan that errors on a call to execute
- Mock
Exec - A Mock ExecutionPlan that can be used for writing tests of other ExecutionPlans
- Panic
Exec - Execution plan that emits streams that panics.
- Panic
Stream 🔒 - A
RecordBatchStreamthat yields every other batch and panics afterbatches_until_panicbatches have been produced. - Statistics
Exec - A mock execution plan that simply returns the provided statistics
- Test
Stream - Iterator over batches
Functions§
- assert_
strong_ count_ converges_ to_ zero - Asserts that the strong count of the given
Weakpointer converges to zero. - clone_
error 🔒