Home
last modified time | relevance | path

Searched refs:num_record_batches (Results 1 – 25 of 80) sorted by relevance

1234

/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/r/src/
H A Drecordbatchreader.cpp73 return reader->num_record_batches(); in ipc___RecordBatchFileReader__num_record_batches()
79 if (i < 0 && i >= reader->num_record_batches()) { in ipc___RecordBatchFileReader__ReadRecordBatch()
104 int num_batches = reader->num_record_batches(); in Table__from_RecordBatchFileReader()
116 auto n = reader->num_record_batches(); in ipc___RecordBatchFileReader__batches()
/dports/databases/arrow/apache-arrow-6.0.1/r/src/
H A Drecordbatchreader.cpp75 return reader->num_record_batches(); in ipc___RecordBatchFileReader__num_record_batches()
81 if (i < 0 && i >= reader->num_record_batches()) { in ipc___RecordBatchFileReader__ReadRecordBatch()
100 int num_batches = reader->num_record_batches(); in Table__from_RecordBatchFileReader()
112 auto n = reader->num_record_batches(); in ipc___RecordBatchFileReader__batches()
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/r/src/
H A Drecordbatchreader.cpp74 return reader->num_record_batches(); in ipc___RecordBatchFileReader__num_record_batches()
80 if (i < 0 && i >= reader->num_record_batches()) { in ipc___RecordBatchFileReader__ReadRecordBatch()
96 int num_batches = reader->num_record_batches(); in Table__from_RecordBatchFileReader()
122 auto n = reader->num_record_batches(); in ipc___RecordBatchFileReader__batches()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/src/arrow/testing/
H A Djson_integration.cc167 int num_record_batches() const { in num_record_batches() function in arrow::testing::IntegrationJsonReader::Impl
209 int IntegrationJsonReader::num_record_batches() const { in num_record_batches() function in arrow::testing::IntegrationJsonReader
210 return impl_->num_record_batches(); in num_record_batches()
H A Djson_integration_test.cc89 for (int i = 0; i < reader->num_record_batches(); ++i) { in ConvertJsonToArrow()
113 for (int i = 0; i < reader->num_record_batches(); ++i) { in ConvertArrowToJson()
156 const int json_nbatches = json_reader->num_record_batches(); in ValidateArrowVsJson()
157 const int arrow_nbatches = arrow_reader->num_record_batches(); in ValidateArrowVsJson()
972 ASSERT_EQ(nbatches, reader->num_record_batches()); in TEST()
989 ASSERT_EQ(1, reader->num_record_batches()); in ReadOneBatchJson()
1028 ASSERT_EQ(1, reader->num_record_batches()); in TEST()
H A Djson_integration.h112 int num_record_batches() const;
/dports/databases/arrow/apache-arrow-6.0.1/cpp/src/arrow/testing/
H A Djson_integration.cc167 int num_record_batches() const { in num_record_batches() function in arrow::testing::IntegrationJsonReader::Impl
209 int IntegrationJsonReader::num_record_batches() const { in num_record_batches() function in arrow::testing::IntegrationJsonReader
210 return impl_->num_record_batches(); in num_record_batches()
H A Djson_integration_test.cc89 for (int i = 0; i < reader->num_record_batches(); ++i) { in ConvertJsonToArrow()
113 for (int i = 0; i < reader->num_record_batches(); ++i) { in ConvertArrowToJson()
156 const int json_nbatches = json_reader->num_record_batches(); in ValidateArrowVsJson()
157 const int arrow_nbatches = arrow_reader->num_record_batches(); in ValidateArrowVsJson()
971 ASSERT_EQ(nbatches, reader->num_record_batches()); in TEST()
988 ASSERT_EQ(1, reader->num_record_batches()); in ReadOneBatchJson()
1027 ASSERT_EQ(1, reader->num_record_batches()); in TEST()
H A Djson_integration.h112 int num_record_batches() const;
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/cpp/src/arrow/ipc/
H A Djson_integration.cc163 int num_record_batches() const { in num_record_batches() function in arrow::ipc::internal::json::JsonReader::JsonReaderImpl
204 int JsonReader::num_record_batches() const { return impl_->num_record_batches(); } in num_record_batches() function in arrow::ipc::internal::json::JsonReader
H A Djson_integration_test.cc76 for (int i = 0; i < reader->num_record_batches(); ++i) { in ConvertJsonToArrow()
100 for (int i = 0; i < reader->num_record_batches(); ++i) { in ConvertArrowToJson()
143 const int json_nbatches = json_reader->num_record_batches(); in ValidateArrowVsJson()
144 const int arrow_nbatches = arrow_reader->num_record_batches(); in ValidateArrowVsJson()
H A Dfile_to_stream.cc42 for (int i = 0; i < reader->num_record_batches(); ++i) { in ConvertToStream()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/src/arrow/ipc/
H A Dread_write_test.cc1783 EXPECT_EQ(read_stats_.num_record_batches, 2); in TestSameDictPointer()
1797 EXPECT_EQ(read_stats_.num_record_batches, 2); in TestSameDictValues()
1820 EXPECT_EQ(read_stats_.num_record_batches, 4); in TestDeltaDict()
1833 EXPECT_EQ(read_stats_.num_record_batches, 4); in TestDeltaDict()
1845 EXPECT_EQ(read_stats_.num_record_batches, 4); in TestDeltaDict()
1852 EXPECT_EQ(read_stats_.num_record_batches, 4); in TestDeltaDict()
1865 EXPECT_EQ(read_stats_.num_record_batches, 2); in TestSameDictValuesNested()
1889 EXPECT_EQ(read_stats_.num_record_batches, 2); in TestDifferentDictValues()
1963 EXPECT_EQ(read_stats_.num_record_batches, 2); in TestDifferentDictValuesNested()
1972 EXPECT_EQ(read_stats_.num_record_batches, 2); in TestDifferentDictValuesNested()
[all …]
H A Dfile_to_stream.cc44 for (int i = 0; i < reader->num_record_batches(); ++i) { in ConvertToStream()
H A Dreader.h49 int64_t num_record_batches = 0; member
154 virtual int num_record_batches() const = 0;
/dports/databases/arrow/apache-arrow-6.0.1/cpp/src/arrow/ipc/
H A Dread_write_test.cc1842 EXPECT_EQ(read_stats_.num_record_batches, 2); in TestSameDictPointer()
1856 EXPECT_EQ(read_stats_.num_record_batches, 2); in TestSameDictValues()
1879 EXPECT_EQ(read_stats_.num_record_batches, 4); in TestDeltaDict()
1892 EXPECT_EQ(read_stats_.num_record_batches, 4); in TestDeltaDict()
1904 EXPECT_EQ(read_stats_.num_record_batches, 4); in TestDeltaDict()
1911 EXPECT_EQ(read_stats_.num_record_batches, 4); in TestDeltaDict()
1924 EXPECT_EQ(read_stats_.num_record_batches, 2); in TestSameDictValuesNested()
1948 EXPECT_EQ(read_stats_.num_record_batches, 2); in TestDifferentDictValues()
2022 EXPECT_EQ(read_stats_.num_record_batches, 2); in TestDifferentDictValuesNested()
2031 EXPECT_EQ(read_stats_.num_record_batches, 2); in TestDifferentDictValuesNested()
[all …]
H A Dfile_to_stream.cc43 for (int i = 0; i < reader->num_record_batches(); ++i) { in ConvertToStream()
/dports/databases/arrow/apache-arrow-6.0.1/python/pyarrow/
H A Dipc.pxi51 ('num_messages', 'num_record_batches', 'num_dictionary_batches',
61 num_record_batches : number of record batches.
71 return WriteStats(c.num_messages, c.num_record_batches,
78 ('num_messages', 'num_record_batches', 'num_dictionary_batches',
88 num_record_batches : number of record batches.
98 return ReadStats(c.num_messages, c.num_record_batches,
748 def num_record_batches(self): member in _RecordBatchFileReader
749 return self.reader.get().num_record_batches()
754 if i < 0 or i >= self.num_record_batches:
775 nbatches = self.num_record_batches
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/r/R/
H A Drecord-batch-reader.R143 num_record_batches = function() ipc___RecordBatchFileReader__num_record_batches(self), activeBindingFunc in RecordBatchFileReader
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/python/pyarrow/
H A Dipc.pxi51 ('num_messages', 'num_record_batches', 'num_dictionary_batches',
63 return WriteStats(c.num_messages, c.num_record_batches,
70 ('num_messages', 'num_record_batches', 'num_dictionary_batches',
82 return ReadStats(c.num_messages, c.num_record_batches,
717 def num_record_batches(self): member in _RecordBatchFileReader
718 return self.reader.get().num_record_batches()
723 if i < 0 or i >= self.num_record_batches:
744 nbatches = self.num_record_batches
/dports/databases/arrow/apache-arrow-6.0.1/r/R/
H A Drecord-batch-reader.R152 num_record_batches = function() ipc___RecordBatchFileReader__num_record_batches(self), activeBindingFunc in RecordBatchFileReader
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/r/R/
H A Drecord-batch-reader.R142 num_record_batches = function() ipc___RecordBatchFileReader__num_record_batches(self), activeBindingFunc in RecordBatchFileReader
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/r/man/
H A DRecordBatchReader.Rd41 \item \verb{$num_record_batches()}: For \code{RecordBatchFileReader}, see how many batches
70 reader$num_record_batches
/dports/databases/arrow/apache-arrow-6.0.1/r/man/
H A DRecordBatchReader.Rd41 \item \verb{$num_record_batches()}: For \code{RecordBatchFileReader}, see how many batches
70 reader$num_record_batches
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/r/man/
H A DRecordBatchReader.Rd41 \item \verb{$num_record_batches()}: For \code{RecordBatchFileReader}, see how many batches
70 reader$num_record_batches

1234