| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/stores/shipper/ |
| H A D | gateway_client.go | 151 type readBatch struct { struct
152 *indexgatewaypb.QueryIndexResponse
155 func (r *readBatch) Iterator() chunk.ReadBatchIterator {
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/chunk/cassandra/ |
| H A D | storage_client.go | 410 type readBatch struct { struct
411 rangeValue []byte
412 value []byte
415 func (r *readBatch) Iterator() chunk.ReadBatchIterator {
423 *readBatch anonMember
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/chunk/cassandra/ |
| H A D | storage_client.go | 409 type readBatch struct { struct
410 rangeValue []byte
411 value []byte
414 func (r *readBatch) Iterator() chunk.ReadBatchIterator {
422 *readBatch anonMember
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/chunk/cassandra/ |
| H A D | storage_client.go | 409 type readBatch struct { struct
410 rangeValue []byte
411 value []byte
414 func (r *readBatch) Iterator() chunk.ReadBatchIterator {
422 *readBatch anonMember
|
| /dports/misc/libkeduvocdocument/libkeduvocdocument-21.12.3/keduvocdocument/readerwriters/ |
| H A D | keduvocpaukerreader.cpp | 107 void KEduVocPaukerReader::readBatch() in readBatch() function in KEduVocPaukerReader
|
| /dports/lang/gcc10-devel/gcc-10-20211008/libgcc/config/avr/libf7/ |
| H A D | f7renames.sh | 43 done
|
| /dports/devel/folly/folly-2021.12.27.00/folly/logging/test/ |
| H A D | ImmediateFileWriterTest.cpp | 33 TEST(ImmediateFileWriter, readBatch) { in TEST() argument
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/chunk/storage/ |
| H A D | caching_index_client.go | 196 readBatch ReadBatch member
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/chunk/storage/ |
| H A D | caching_index_client.go | 196 readBatch ReadBatch member
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/chunk/storage/ |
| H A D | caching_index_client.go | 249 readBatch ReadBatch member
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/rpc/ |
| H A D | client_test.go | 386 func (r *unsubscribeRecorder) readBatch() ([]*jsonrpcMessage, bool, error) { func
|
| H A D | http.go | 60 func (hc *httpConn) readBatch() ([]*jsonrpcMessage, bool, error) { func
|
| H A D | json.go | 205 func (c *jsonCodec) readBatch() (messages []*jsonrpcMessage, batch bool, err error) { func
|
| /dports/devel/spark/spark-2.1.1/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/ |
| H A D | VectorizedColumnReader.java | 137 void readBatch(int total, ColumnVector column) throws IOException { in readBatch() method in VectorizedColumnReader
|
| /dports/biology/canu/canu-2.2/src/haplotyping/ |
| H A D | splitHaplotype.C | 222 readBatch(uint32 batchSize) { in readBatch() function
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/java/vector/src/test/java/org/apache/arrow/vector/ipc/ |
| H A D | TestArrowReaderWriter.java | 693 ArrowRecordBatch readBatch = MessageSerializer.deserializeRecordBatch(in, allocator); in testLegacyIpcBackwardsCompatibility() local
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/java/vector/src/test/java/org/apache/arrow/vector/ipc/ |
| H A D | TestArrowReaderWriter.java | 791 ArrowRecordBatch readBatch = MessageSerializer.deserializeRecordBatch(in, allocator); in testLegacyIpcBackwardsCompatibility() local
|
| /dports/databases/arrow/apache-arrow-6.0.1/java/vector/src/test/java/org/apache/arrow/vector/ipc/ |
| H A D | TestArrowReaderWriter.java | 791 ArrowRecordBatch readBatch = MessageSerializer.deserializeRecordBatch(in, allocator); in testLegacyIpcBackwardsCompatibility() local
|