MCPcopy Create free account
hub / github.com/apache/datafusion / index

Method index

datafusion/physical-plan/src/test/exec.rs:85–87  ·  view source on GitHub ↗

Return a handle to the index counter for this stream

(&self)

Source from the content-addressed store, hash-verified

83
84 /// Return a handle to the index counter for this stream
85 pub fn index(&self) -> BatchIndex {
86 self.index.clone()
87 }
88}
89
90impl Stream for TestStream {

Callers 15

compute_propertiesMethod · 0.45
collect_equality_columnsFunction · 0.45
limit_early_shutdownFunction · 0.45
limit_equals_batch_sizeFunction · 0.45
limit_no_columnFunction · 0.45
try_pushdown_sortMethod · 0.45
is_projection_removableFunction · 0.45
new_join_childrenFunction · 0.45
join_table_bordersFunction · 0.45
try_unifying_projectionsFunction · 0.45
collect_column_indicesFunction · 0.45

Calls 1

cloneMethod · 0.45

Tested by

no test coverage detected