Home
last modified time | relevance | path

Searched refs:rows_written (Results 1 – 25 of 40) sorted by relevance

12

/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/lib/
H A Dcsv_builder.rb60 if truncated? || rows_written == 0
63 rows_written
70 rows_written: rows_written,
/dports/graphics/dssim/dssim-3.1.2/cargo-crates/mozjpeg-0.9.1/src/
H A Dcompress.rs158 let rows_written = ffi::jpeg_write_scanlines( in write_scanlines() localVariable
163 debug_assert!(rows_left >= rows_written); in write_scanlines()
164 if rows_written == 0 { in write_scanlines()
167 rows_left -= rows_written; in write_scanlines()
168 row_pointers = row_pointers.add(rows_written as usize); in write_scanlines()
235 …let rows_written = ffi::jpeg_write_raw_data(&mut self.cinfo, comp_ptrs.as_ptr(), mcu_height as u32… in write_raw_data() localVariable
236 if 0 == rows_written { in write_raw_data()
239 start_row += rows_written; in write_raw_data()
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/spec/lib/
H A Dcsv_builder_spec.rb34 expect(subject.rows_written).to eq 1
58 expect(subject.rows_written).to eq 2
63 expect(subject.rows_written).to eq 3
/dports/databases/pg_citus/citus-10.2.3/src/test/regress/expected/
H A Dmulti_mx_insert_select_repartition.out90rows_written FROM worker_partition_query_result('repartitioned_results_xxxxx_from_4213581_to','SEL…
91rows_written FROM worker_partition_query_result('repartitioned_results_xxxxx_from_4213583_to','SEL…
H A Dpartitioned_intermediate_results.out10 partition_index | rows_written | bytes_written
66 partition_index | rows_written | bytes_written
119 partition_index | rows_written | bytes_written
143 partition_index | rows_written | bytes_written
306 SELECT array_agg(rows_written::text ORDER BY partition_index),
307 array_agg(partition_index) FILTER (WHERE rows_written > 0)
H A Dcoordinator_shouldhaveshards.out113rows_written FROM worker_partition_query_result('repartitioned_results_xxxxx_from_1503000_to','SEL…
114rows_written FROM worker_partition_query_result('repartitioned_results_xxxxx_from_1503003_to','SEL…
124rows_written FROM worker_partition_query_result('repartitioned_results_xxxxx_from_1503000_to','SEL…
125rows_written FROM worker_partition_query_result('repartitioned_results_xxxxx_from_1503003_to','SEL…
511rows_written FROM worker_partition_query_result('repartitioned_results_xxxxx_from_1503027_to','SEL…
512rows_written FROM worker_partition_query_result('repartitioned_results_xxxxx_from_1503029_to','SEL…
513rows_written FROM worker_partition_query_result('repartitioned_results_xxxxx_from_1503030_to','SEL…
514rows_written FROM worker_partition_query_result('repartitioned_results_xxxxx_from_1503032_to','SEL…
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/spec/mailers/emails/
H A Dissues_spec.rb52 let(:export_status) { { truncated: false, rows_expected: 3, rows_written: 3 } }
80 let(:export_status) { { truncated: true, rows_expected: 12, rows_written: 10 } }
H A Dmerge_requests_spec.rb198 rows_written: 10,
216 rows_written: 10,
/dports/databases/py-tiledb/tiledb-0.8.11/tiledb/
H A Ddataframe_.py834 rows_written = 0
844 tiledb_args["row_start_idx"] = rows_written
849 rows_written += len(df)
855 rows_written = 0
861 tiledb_args["row_start_idx"] = rows_written
866 rows_written += len(df)
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/mroonga/mysql-test/mroonga/storage/r/
H A Di_s.result5 `rows_written` int(11) NOT NULL,
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/mroonga/mysql-test/mroonga/storage/r/
H A Di_s.result5 `rows_written` int(11) NOT NULL,
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/sql/udfs/worker_partition_query_result/
H A D9.2-1.sql10 OUT rows_written bigint,
H A Dlatest.sql10 OUT rows_written bigint,
/dports/databases/pg_citus/citus-10.2.3/src/test/regress/sql/
H A Dpartitioned_intermediate_results.sql226 SELECT array_agg(rows_written::text ORDER BY partition_index),
227 array_agg(partition_index) FILTER (WHERE rows_written > 0)
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/parquet/src/column/
H A Dwriter.rs1116 let (bytes_written, rows_written, metadata) = writer.close().unwrap(); in test_column_writer_boolean_type_does_not_support_dictionary()
1120 assert_eq!(rows_written, 4); in test_column_writer_boolean_type_does_not_support_dictionary()
1389 let (bytes_written, rows_written, metadata) = writer.close().unwrap(); in test_column_writer_check_metadata()
1391 assert_eq!(rows_written, 4); in test_column_writer_check_metadata()
1433 let (bytes_written, rows_written, metadata) = writer.close().unwrap(); in test_column_writer_precalculated_statistics()
1435 assert_eq!(rows_written, 4); in test_column_writer_precalculated_statistics()
1738 let (bytes_written, rows_written, column_metadata) = writer.close().unwrap(); in column_roundtrip()
1786 assert_eq!(actual_rows_written, rows_written); in column_roundtrip()
1788 assert_eq!(levels_read as u64, rows_written); in column_roundtrip()
1790 assert_eq!(values_read as u64, rows_written); in column_roundtrip()
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/rust/parquet/src/column/
H A Dwriter.rs973 let (bytes_written, rows_written, metadata) = writer.close().unwrap(); in test_column_writer_boolean_type_does_not_support_dictionary()
977 assert_eq!(rows_written, 4); in test_column_writer_boolean_type_does_not_support_dictionary()
1246 let (bytes_written, rows_written, metadata) = writer.close().unwrap(); in test_column_writer_check_metadata()
1248 assert_eq!(rows_written, 4); in test_column_writer_check_metadata()
1538 let (bytes_written, rows_written, column_metadata) = writer.close().unwrap(); in column_roundtrip()
1586 assert_eq!(actual_rows_written, rows_written); in column_roundtrip()
1588 assert_eq!(levels_read as u64, rows_written); in column_roundtrip()
1590 assert_eq!(values_read as u64, rows_written); in column_roundtrip()
/dports/databases/arrow/apache-arrow-6.0.1/cpp/src/parquet/
H A Dfile_writer.cc214 int64_t current_col_rows = column_writers_[0]->rows_written(); in CheckRowsWritten()
222 int64_t current_col_rows = column_writers_[0]->rows_written(); in CheckRowsWritten()
224 int64_t current_col_rows_i = column_writers_[i]->rows_written(); in CheckRowsWritten()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/src/parquet/
H A Dfile_writer.cc215 int64_t current_col_rows = column_writers_[0]->rows_written(); in CheckRowsWritten()
223 int64_t current_col_rows = column_writers_[0]->rows_written(); in CheckRowsWritten()
225 int64_t current_col_rows_i = column_writers_[i]->rows_written(); in CheckRowsWritten()
/dports/databases/arrow/apache-arrow-6.0.1/cpp/src/arrow/dataset/
H A Ddataset_writer.cc297 uint64_t rows_written() const { return rows_written_; } in rows_written() function in arrow::dataset::internal::__anoncb863e120111::DatasetWriterDirectoryQueue
410 if (dir_queue.second->rows_written() > largest_num_rows) { in CloseLargestFile()
411 largest_num_rows = dir_queue.second->rows_written(); in CloseLargestFile()
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/cpp/src/parquet/
H A Dfile_writer.cc215 int64_t current_col_rows = column_writers_[0]->rows_written(); in CheckRowsWritten()
223 int64_t current_col_rows = column_writers_[0]->rows_written(); in CheckRowsWritten()
225 int64_t current_col_rows_i = column_writers_[i]->rows_written(); in CheckRowsWritten()
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/rust/parquet/src/file/
H A Dwriter.rs293 let (bytes_written, rows_written, metadata) = match writer { in finalise_column_writer()
308 if rows != rows_written { in finalise_column_writer()
312 rows_written in finalise_column_writer()
316 self.total_rows_written = Some(rows_written); in finalise_column_writer()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/rust/parquet/src/file/
H A Dwriter.rs299 let (bytes_written, rows_written, metadata) = match writer { in finalise_column_writer()
314 if rows != rows_written { in finalise_column_writer()
318 rows_written in finalise_column_writer()
322 self.total_rows_written = Some(rows_written); in finalise_column_writer()
/dports/net/librdkafka/librdkafka-1.8.2/examples/
H A Drdkafka_performance.c496 static int rows_written = 0; in print_stats() local
508 print_header = !rows_written ||(verbosity > 0 && !(rows_written % 20)); in print_stats()
532 rows_written++; \ in print_stats()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/examples/
H A Drdkafka_performance.c463 static int rows_written = 0; in print_stats() local
475 print_header = !rows_written ||(verbosity > 0 && !(rows_written % 20)); in print_stats()
499 rows_written++; \ in print_stats()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/
H A Drdkafka_performance.c496 static int rows_written = 0; in print_stats() local
508 print_header = !rows_written ||(verbosity > 0 && !(rows_written % 20)); in print_stats()
532 rows_written++; \ in print_stats()

12