| /dports/www/tusd/google-cloud-go-storage-v1.18.2/dataproc/apiv1/ |
| H A D | batch_controller_client.go | 406 type BatchIterator struct { struct
407 items []*dataprocpb.Batch
408 pageInfo *iterator.PageInfo
409 nextFunc func() error
414 Response interface{}
422 …func(pageSize int, pageToken string) (results []*dataprocpb.Batch, nextPageToken string, err error)
426 func (it *BatchIterator) PageInfo() *iterator.PageInfo {
432 func (it *BatchIterator) Next() (*dataprocpb.Batch, error) {
442 func (it *BatchIterator) bufLen() int {
446 func (it *BatchIterator) takeBuf() interface{} {
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/rust/datafusion/src/execution/physical_plan/ |
| H A D | datasource.rs | 36 partitions: Vec<Arc<Mutex<dyn BatchIterator>>>, in new()
70 fn execute(&self) -> Result<Arc<Mutex<dyn BatchIterator>>> { in execute()
|
| H A D | mod.rs | 41 fn execute(&self) -> Result<Arc<Mutex<dyn BatchIterator>>>; in execute()
45 pub trait BatchIterator: Send + Sync { trait
|
| H A D | limit.rs | 81 fn execute(&self) -> Result<Arc<Mutex<dyn BatchIterator>>> { in execute()
139 it: Arc<Mutex<dyn BatchIterator>>, in collect_with_limit()
|
| H A D | merge.rs | 68 fn execute(&self) -> Result<Arc<Mutex<dyn BatchIterator>>> { in execute()
|
| H A D | hash_aggregate.rs | 154 fn execute(&self) -> Result<Arc<Mutex<dyn BatchIterator>>> { in execute()
259 input: Arc<Mutex<dyn BatchIterator>>, in new()
552 input: Arc<Mutex<dyn BatchIterator>>, in new()
|
| H A D | selection.rs | 90 fn execute(&self) -> Result<Arc<Mutex<dyn BatchIterator>>> { in execute()
|
| H A D | memory.rs | 102 fn execute(&self) -> Result<Arc<Mutex<dyn BatchIterator>>> { in execute()
|
| H A D | projection.rs | 102 fn execute(&self) -> Result<Arc<Mutex<dyn BatchIterator>>> { in execute()
|
| H A D | parquet.rs | 194 fn execute(&self) -> Result<Arc<Mutex<dyn BatchIterator>>> { in execute()
|
| H A D | csv.rs | 226 fn execute(&self) -> Result<Arc<Mutex<dyn BatchIterator>>> { in execute()
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/java/dataset/src/main/java/org/apache/arrow/dataset/scanner/ |
| H A D | ScanTask.java | 39 interface BatchIterator extends Iterator<ArrowRecordBatch>, AutoCloseable { interface
|
| /dports/databases/arrow/apache-arrow-6.0.1/java/dataset/src/main/java/org/apache/arrow/dataset/scanner/ |
| H A D | ScanTask.java | 39 interface BatchIterator extends Iterator<ArrowRecordBatch>, AutoCloseable { interface
|
| /dports/misc/py-xgboost/xgboost-1.5.1/jvm-packages/xgboost4j/src/main/java/ml/dmlc/xgboost4j/java/ |
| H A D | DataBatch.java | 43 static class BatchIterator implements Iterator<DataBatch> { class in DataBatch
47 BatchIterator(Iterator<LabeledPoint> base, int batchSize) { in BatchIterator() method in DataBatch.BatchIterator
|
| /dports/misc/xgboost/xgboost-1.5.1/jvm-packages/xgboost4j/src/main/java/ml/dmlc/xgboost4j/java/ |
| H A D | DataBatch.java | 43 static class BatchIterator implements Iterator<DataBatch> { class in DataBatch
47 BatchIterator(Iterator<LabeledPoint> base, int batchSize) { in BatchIterator() method in DataBatch.BatchIterator
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/cpp/src/arrow/flight/ |
| H A D | test_util.h | 87 BatchIterator(const std::shared_ptr<Schema>& schema, in BatchIterator() function
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/src/arrow/flight/ |
| H A D | test_util.h | 91 BatchIterator(const std::shared_ptr<Schema>& schema, in BatchIterator() function
|
| /dports/databases/arrow/apache-arrow-6.0.1/cpp/src/arrow/flight/ |
| H A D | test_util.h | 92 BatchIterator(const std::shared_ptr<Schema>& schema, in BatchIterator() function
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/julia/Arrow/src/ |
| H A D | table.jl | 17 struct BatchIterator struct
18 bytes::Vector{UInt8}
19 startpos::Int
288 function Base.iterate(x::BatchIterator, (pos, id)=(x.startpos, 0))
|
| /dports/databases/arrow/apache-arrow-6.0.1/julia/Arrow/src/ |
| H A D | table.jl | 17 struct BatchIterator struct
18 bytes::Vector{UInt8}
19 startpos::Int
288 function Base.iterate(x::BatchIterator, (pos, id)=(x.startpos, 0))
|
| /dports/misc/py-xgboost/xgboost-1.5.1/include/xgboost/ |
| H A D | data.h | 421 explicit BatchIterator(BatchIteratorImpl<T>* impl) { impl_.reset(impl); } in BatchIterator() function
422 explicit BatchIterator(std::shared_ptr<BatchIteratorImpl<T>> impl) { impl_ = impl; } in BatchIterator() function
|
| /dports/misc/xgboost/xgboost-1.5.1/include/xgboost/ |
| H A D | data.h | 421 explicit BatchIterator(BatchIteratorImpl<T>* impl) { impl_.reset(impl); } in BatchIterator() function
422 explicit BatchIterator(std::shared_ptr<BatchIteratorImpl<T>> impl) { impl_ = impl; } in BatchIterator() function
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/cpp/src/arrow/testing/ |
| H A D | util.h | 99 BatchIterator(const std::shared_ptr<Schema>& schema, in BatchIterator() function
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/src/arrow/testing/ |
| H A D | util.h | 100 BatchIterator(const std::shared_ptr<Schema>& schema, in BatchIterator() function
|
| /dports/databases/arrow/apache-arrow-6.0.1/cpp/src/arrow/testing/ |
| H A D | util.h | 100 BatchIterator(const std::shared_ptr<Schema>& schema, in BatchIterator() function
|