PetastormFile Size
| File | # lines | # units |
|---|---|---|
| spark_dataset_converter.py in petastorm/spark |
380 | 36 |
| reader.py in petastorm |
325 | 20 |
| unischema.py in petastorm |
265 | 23 |
| process_pool.py in petastorm/workers_pool |
213 | 14 |
| dataset_metadata.py in petastorm/etl |
200 | 12 |
| arrow_reader_worker.py in petastorm |
183 | 10 |
| tf_utils.py in petastorm |
177 | 17 |
| pytorch.py in petastorm |
171 | 14 |
| namenode.py in petastorm/hdfs |
162 | 16 |
| codecs.py in petastorm |
154 | 24 |
| py_dict_reader_worker.py in petastorm |
147 | 12 |
| throughput.py in petastorm/benchmark |
126 | 8 |
| thread_pool.py in petastorm/workers_pool |
126 | 11 |
| pytorch_shuffling_buffer.py in petastorm/reader_impl |
125 | 23 |
| pytorch_example.py in examples/mnist |
115 | 6 |
| fs_utils.py in petastorm |
115 | 9 |
| pytorch_converter_example.py in examples/spark_dataset_converter |
109 | 6 |
| ngram.py in petastorm |
105 | 15 |
| petastorm_generate_metadata.py in petastorm/etl |
98 | 3 |
| predicates.py in petastorm |
93 | 21 |
| setup.py in null |
86 | - |
| ventilator.py in petastorm/workers_pool |
81 | 12 |
| copy_dataset.py in petastorm/tools |
77 | 4 |
| tf_example.py in examples/mnist |
76 | 2 |
| shuffling_buffer.py in petastorm/reader_impl |
75 | 20 |
| rowgroup_indexing.py in petastorm/etl |
73 | 4 |
| rowgroup_indexers.py in petastorm/etl |
73 | 14 |
| generate_petastorm_imagenet.py in examples/imagenet |
67 | 3 |
| cli.py in petastorm/benchmark |
67 | 3 |
| namedtuple_gt_255_fields.py in petastorm |
65 | 2 |
| generate_petastorm_mnist.py in examples/mnist |
63 | 3 |
| tensorflow_converter_example.py in examples/spark_dataset_converter |
62 | 4 |
| utils.py in petastorm |
62 | 3 |
| dummy_reader.py in petastorm/benchmark |
56 | 6 |
| gcsfs_wrapper.py in petastorm/gcsfs_helpers |
49 | 3 |
| compat.py in petastorm |
48 | 7 |
| selectors.py in petastorm |
46 | 11 |
| metadata_util.py in petastorm/etl |
45 | - |
| weighted_sampling_reader.py in petastorm |
44 | 8 |
| dummy_pool.py in petastorm/workers_pool |
38 | 7 |
| transform.py in petastorm |
32 | 3 |
| generate_petastorm_dataset.py in examples/hello_world/petastorm_dataset |
31 | 2 |
| exec_in_new_process.py in petastorm/workers_pool |
31 | 1 |
| batching_table_queue.py in petastorm/pyarrow_helpers |
30 | 4 |
| spark_session_cli.py in petastorm/tools |
28 | 3 |
| local_disk_cache.py in petastorm |
26 | 3 |
| pyspark_hello_world.py in examples/hello_world/petastorm_dataset |
21 | 1 |
| __init__.py in petastorm/etl |
21 | 6 |
| tensorflow_hello_world.py in examples/hello_world/petastorm_dataset |
19 | 1 |
| tensorflow_hello_world.py in examples/hello_world/external_dataset |
19 | 1 |
| File | # lines | # units |
|---|---|---|
| spark_dataset_converter.py in petastorm/spark |
380 | 36 |
| codecs.py in petastorm |
154 | 24 |
| pytorch_shuffling_buffer.py in petastorm/reader_impl |
125 | 23 |
| unischema.py in petastorm |
265 | 23 |
| predicates.py in petastorm |
93 | 21 |
| shuffling_buffer.py in petastorm/reader_impl |
75 | 20 |
| reader.py in petastorm |
325 | 20 |
| tf_utils.py in petastorm |
177 | 17 |
| namenode.py in petastorm/hdfs |
162 | 16 |
| ngram.py in petastorm |
105 | 15 |
| rowgroup_indexers.py in petastorm/etl |
73 | 14 |
| pytorch.py in petastorm |
171 | 14 |
| process_pool.py in petastorm/workers_pool |
213 | 14 |
| dataset_metadata.py in petastorm/etl |
200 | 12 |
| py_dict_reader_worker.py in petastorm |
147 | 12 |
| ventilator.py in petastorm/workers_pool |
81 | 12 |
| selectors.py in petastorm |
46 | 11 |
| thread_pool.py in petastorm/workers_pool |
126 | 11 |
| arrow_reader_worker.py in petastorm |
183 | 10 |
| fs_utils.py in petastorm |
115 | 9 |
| throughput.py in petastorm/benchmark |
126 | 8 |
| weighted_sampling_reader.py in petastorm |
44 | 8 |
| compat.py in petastorm |
48 | 7 |
| dummy_pool.py in petastorm/workers_pool |
38 | 7 |
| pytorch_example.py in examples/mnist |
115 | 6 |
| pytorch_converter_example.py in examples/spark_dataset_converter |
109 | 6 |
| dummy_reader.py in petastorm/benchmark |
56 | 6 |
| __init__.py in petastorm/etl |
21 | 6 |
| tensorflow_converter_example.py in examples/spark_dataset_converter |
62 | 4 |
| copy_dataset.py in petastorm/tools |
77 | 4 |
| rowgroup_indexing.py in petastorm/etl |
73 | 4 |
| pyarrow_serializer.py in petastorm/reader_impl |
19 | 4 |
| batching_table_queue.py in petastorm/pyarrow_helpers |
30 | 4 |
| generate_petastorm_mnist.py in examples/mnist |
63 | 3 |
| generate_petastorm_imagenet.py in examples/imagenet |
67 | 3 |
| cli.py in petastorm/benchmark |
67 | 3 |
| spark_session_cli.py in petastorm/tools |
28 | 3 |
| gcsfs_wrapper.py in petastorm/gcsfs_helpers |
49 | 3 |
| local_disk_cache.py in petastorm |
26 | 3 |
| petastorm_generate_metadata.py in petastorm/etl |
98 | 3 |
| utils.py in petastorm |
62 | 3 |
| transform.py in petastorm |
32 | 3 |
| worker_base.py in petastorm/workers_pool |
11 | 3 |
| tf_example.py in examples/mnist |
76 | 2 |
| utils.py in examples/spark_dataset_converter |
16 | 2 |
| generate_petastorm_dataset.py in examples/hello_world/petastorm_dataset |
31 | 2 |
| generate_external_dataset.py in examples/hello_world/external_dataset |
18 | 2 |
| cache.py in petastorm |
9 | 2 |
| pickle_serializer.py in petastorm/reader_impl |
6 | 2 |
| arrow_table_serializer.py in petastorm/reader_impl |
12 | 2 |