▼ doc | |
► images | |
exec-profile.html | |
▼ examples | |
► bfs | |
100.graph | |
110.graph | |
bfs.cpp | |
bfs.hpp | |
► k-means | |
k-means.hpp | |
k-means_run.cpp | |
► logistic_regression | |
logistic_regression.cpp | |
logistic_regression.hpp | |
UNFINISHED | |
► page_rank | |
page_rank.hpp | |
page_rank_run.cpp | |
zipf_graph_gen.cpp | |
zipf_graph_gen.hpp | |
► percentiles | |
percentiles.cpp | |
► select | |
select.hpp | |
select_run.cpp | |
► sleep | |
sleep.cpp | |
► stochastic_gradient_descent | |
gen_data.py | |
stochastic_gradient_descent.hpp | |
stochastic_gradient_descent_run.cpp | |
► suffix_sorting | |
check_sa.hpp | |
construct_bwt.hpp | |
construct_lcp.hpp | |
construct_wt.hpp | |
dc3.cpp | |
dc3.hpp | |
dc7.cpp | |
dc7.hpp | |
just_sort.cpp | |
prefix_doubling.cpp | |
prefix_doubling.hpp | |
prefix_quadrupling.cpp | |
prefix_quadrupling.hpp | |
rl_bwt.cpp | |
suffix_sorting.cpp | |
suffix_sorting.hpp | |
wavelet_tree.cpp | |
wavelet_tree2.cpp | |
wavelet_tree3.cpp | |
► terasort | |
terasort.cpp | |
► tpch | |
tpch_run.cpp | |
► triangles | |
triangles.hpp | |
triangles_run.cpp | |
► tutorial | |
k-means_step1.cpp | |
k-means_step2.cpp | |
k-means_step3.cpp | |
k-means_step4.cpp | |
k-means_step5.cpp | |
k-means_step6.cpp | |
► vfs_tool | |
vfs_tool.cpp | |
► word_count | |
line_count.cpp | |
random_text_writer.cpp | |
random_text_writer.hpp | |
word_count.hpp | |
word_count_run.cpp | |
word_count_sequential.cpp | |
word_count_simple.cpp | |
▼ extlib | |
► foxxll | |
► foxxll | |
► common | |
addressable_queues.hpp | |
aligned_alloc.hpp | |
error_handling.hpp | |
exceptions.hpp | |
exithandler.cpp | |
exithandler.hpp | |
new_alloc.hpp | |
onoff_switch.hpp | |
shared_state.hpp | |
timer.hpp | |
tmeta.hpp | |
types.hpp | |
uint_types.hpp | |
utils.hpp | |
version.cpp | |
► io | |
create_file.cpp | |
create_file.hpp | |
disk_queued_file.cpp | |
disk_queued_file.hpp | |
disk_queues.cpp | |
disk_queues.hpp | |
file.cpp | |
file.hpp | |
fileperblock_file.cpp | |
fileperblock_file.hpp | |
iostats.cpp | |
iostats.hpp | |
linuxaio_file.cpp | |
linuxaio_file.hpp | |
linuxaio_queue.cpp | |
linuxaio_queue.hpp | |
linuxaio_request.cpp | |
linuxaio_request.hpp | |
memory_file.cpp | |
memory_file.hpp | |
mmap_file.cpp | |
mmap_file.hpp | |
request.cpp | |
request.hpp | |
request_interface.hpp | |
request_operations.hpp | |
request_queue.hpp | |
request_queue_impl_1q.cpp | |
request_queue_impl_1q.hpp | |
request_queue_impl_qwqr.cpp | |
request_queue_impl_qwqr.hpp | |
request_queue_impl_worker.cpp | |
request_queue_impl_worker.hpp | |
request_with_state.cpp | |
request_with_state.hpp | |
request_with_waiters.cpp | |
request_with_waiters.hpp | |
serving_request.cpp | |
serving_request.hpp | |
syscall_file.cpp | |
syscall_file.hpp | |
ufs_file_base.cpp | |
ufs_file_base.hpp | |
ufs_platform.hpp | |
wfs_file_base.cpp | |
wfs_file_base.hpp | |
wincall_file.cpp | |
wincall_file.hpp | |
► mng | |
async_schedule.cpp | |
async_schedule.hpp | |
bid.hpp | |
block_alloc_strategy.hpp | |
block_alloc_strategy_interleaved.hpp | |
block_manager.cpp | |
block_manager.hpp | |
block_prefetcher.hpp | |
block_scheduler.hpp | |
buf_istream.hpp | |
buf_istream_reverse.hpp | |
buf_ostream.hpp | |
buf_writer.hpp | |
config.cpp | |
config.hpp | |
disk_block_allocator.cpp | |
disk_block_allocator.hpp | |
prefetch_pool.hpp | |
read_write_pool.hpp | |
typed_block.hpp | |
write_pool.hpp | |
config.hpp.in | |
defines.hpp | |
io.hpp | |
libfoxxll.hpp | |
mng.hpp | |
singleton.hpp | |
version.hpp | |
► tlx | |
► tlx | |
► algorithm | |
exclusive_scan.hpp | |
is_sorted_cmp.hpp | |
merge_advance.hpp | |
merge_combine.hpp | |
multisequence_partition.hpp | |
multisequence_selection.hpp | |
multiway_merge.hpp | |
multiway_merge_splitting.hpp | |
parallel_multiway_merge.cpp | |
parallel_multiway_merge.hpp | |
random_bipartition_shuffle.hpp | |
► container | |
btree.hpp | |
btree_map.hpp | |
btree_multimap.hpp | |
btree_multiset.hpp | |
btree_set.hpp | |
d_ary_addressable_int_heap.hpp | |
d_ary_heap.hpp | |
loser_tree.hpp | |
lru_cache.hpp | |
radix_heap.hpp | |
ring_buffer.hpp | |
simple_vector.hpp | |
splay_tree.hpp | |
string_view.hpp | |
► define | |
attribute_always_inline.hpp | |
attribute_fallthrough.hpp | |
attribute_format_printf.hpp | |
attribute_packed.hpp | |
attribute_warn_unused_result.hpp | |
deprecated.hpp | |
endian.hpp | |
likely.hpp | |
► die | |
core.cpp | |
core.hpp | |
► digest | |
md5.cpp | |
md5.hpp | |
sha1.cpp | |
sha1.hpp | |
sha256.cpp | |
sha256.hpp | |
sha512.cpp | |
sha512.hpp | |
► logger | |
all.hpp | |
array.hpp | |
core.cpp | |
core.hpp | |
deque.hpp | |
map.hpp | |
set.hpp | |
tuple.hpp | |
unordered_map.hpp | |
unordered_set.hpp | |
wrap_unprintable.hpp | |
► math | |
abs_diff.hpp | |
aggregate.hpp | |
aggregate_min_max.hpp | |
bswap.hpp | |
bswap_be.hpp | |
bswap_le.hpp | |
clz.hpp | |
ctz.hpp | |
div_ceil.hpp | |
ffs.hpp | |
integer_log2.hpp | |
is_power_of_two.hpp | |
polynomial_regression.hpp | |
popcount.hpp | |
power_to_the.hpp | |
rol.hpp | |
ror.hpp | |
round_to_power_of_two.hpp | |
round_up.hpp | |
sgn.hpp | |
► meta | |
apply_tuple.hpp | |
call_for_range.hpp | |
call_foreach.hpp | |
call_foreach_tuple.hpp | |
call_foreach_tuple_with_index.hpp | |
call_foreach_with_index.hpp | |
enable_if.hpp | |
fold_left.hpp | |
fold_left_tuple.hpp | |
fold_right.hpp | |
fold_right_tuple.hpp | |
function_chain.hpp | |
function_stack.hpp | |
has_member.hpp | |
has_method.hpp | |
index_sequence.hpp | |
is_std_array.hpp | |
is_std_pair.hpp | |
is_std_tuple.hpp | |
is_std_vector.hpp | |
log2.hpp | |
no_operation.hpp | |
static_index.hpp | |
vexpand.hpp | |
vmap_for_range.hpp | |
vmap_foreach.hpp | |
vmap_foreach_tuple.hpp | |
vmap_foreach_tuple_with_index.hpp | |
vmap_foreach_with_index.hpp | |
► port | |
setenv.cpp | |
setenv.hpp | |
► sort | |
► strings | |
insertion_sort.hpp | |
multikey_quicksort.hpp | |
parallel_sample_sort.hpp | |
radix_sort.hpp | |
sample_sort_tools.hpp | |
string_ptr.hpp | |
string_set.hpp | |
parallel_mergesort.hpp | |
strings.hpp | |
strings_parallel.hpp | |
► string | |
appendline.cpp | |
appendline.hpp | |
base64.cpp | |
base64.hpp | |
bitdump.cpp | |
bitdump.hpp | |
compare_icase.cpp | |
compare_icase.hpp | |
contains.cpp | |
contains.hpp | |
contains_word.cpp | |
contains_word.hpp | |
ends_with.cpp | |
ends_with.hpp | |
equal_icase.cpp | |
equal_icase.hpp | |
erase_all.cpp | |
erase_all.hpp | |
escape_html.cpp | |
escape_html.hpp | |
escape_uri.cpp | |
escape_uri.hpp | |
expand_environment_variables.cpp | |
expand_environment_variables.hpp | |
extract_between.cpp | |
extract_between.hpp | |
format_iec_units.hpp | |
format_si_iec_units.cpp | |
format_si_iec_units.hpp | |
format_si_units.hpp | |
hash_djb2.hpp | |
hash_sdbm.hpp | |
hexdump.cpp | |
hexdump.hpp | |
index_of.cpp | |
index_of.hpp | |
join.cpp | |
join.hpp | |
join_generic.hpp | |
join_quoted.cpp | |
join_quoted.hpp | |
less_icase.cpp | |
less_icase.hpp | |
levenshtein.hpp | |
pad.cpp | |
pad.hpp | |
parse_si_iec_units.cpp | |
parse_si_iec_units.hpp | |
replace.cpp | |
replace.hpp | |
split.cpp | |
split.hpp | |
split_quoted.cpp | |
split_quoted.hpp | |
split_view.hpp | |
split_words.cpp | |
split_words.hpp | |
ssprintf.cpp | |
ssprintf.hpp | |
ssprintf_generic.hpp | |
starts_with.cpp | |
starts_with.hpp | |
to_lower.cpp | |
to_lower.hpp | |
to_upper.cpp | |
to_upper.hpp | |
trim.cpp | |
trim.hpp | |
union_words.cpp | |
union_words.hpp | |
word_wrap.cpp | |
word_wrap.hpp | |
algorithm.hpp | |
allocator_base.hpp | |
backtrace.cpp | |
backtrace.hpp | |
cmdline_parser.cpp | |
cmdline_parser.hpp | |
container.hpp | |
counting_ptr.hpp | |
define.hpp | |
delegate.hpp | |
die.hpp | |
digest.hpp | |
logger.hpp | |
math.hpp | |
meta.hpp | |
multi_timer.cpp | |
multi_timer.hpp | |
port.hpp | |
semaphore.hpp | |
simple_vector.hpp | |
siphash.hpp | |
sort.hpp | |
stack_allocator.hpp | |
string.hpp | |
thread_barrier_mutex.hpp | |
thread_barrier_spin.hpp | |
thread_pool.cpp | |
thread_pool.hpp | |
timestamp.cpp | |
timestamp.hpp | |
unused.hpp | |
vector_free.hpp | |
version.hpp | |
▼ thrill | |
► api | |
action_node.hpp | |
all_gather.hpp | |
all_reduce.hpp | |
bernoulli_sample.hpp | |
cache.hpp | |
collapse.hpp | |
concat.hpp | |
concat_to_dia.hpp | |
context.cpp | |
context.hpp | |
dia.hpp | |
dia_base.cpp | |
dia_base.hpp | |
dia_node.hpp | |
distribute.hpp | |
dop_node.hpp | |
equal_to_dia.hpp | |
ex_prefix_sum.hpp | |
gather.hpp | |
generate.hpp | |
group_by_iterator.hpp | |
group_by_key.hpp | |
group_to_index.hpp | |
hyperloglog.hpp | |
inner_join.hpp | |
max.hpp | |
merge.hpp | |
min.hpp | |
prefix_sum.hpp | |
print.hpp | |
read_binary.hpp | |
read_lines.hpp | |
rebalance.hpp | |
reduce_by_key.hpp | |
reduce_to_index.hpp | |
sample.hpp | |
size.hpp | |
sort.hpp | |
source_node.hpp | |
sum.hpp | |
union.hpp | |
window.hpp | |
write_binary.hpp | |
write_lines.hpp | |
write_lines_one.hpp | |
zip.hpp | |
zip_window.hpp | |
zip_with_index.hpp | |
► common | |
aggregate.hpp | |
atomic_movable.hpp | |
binary_heap.hpp | |
concurrent_bounded_queue.hpp | |
concurrent_queue.hpp | |
config.hpp | |
defines.hpp | |
function_traits.hpp | |
functional.hpp | |
hash.cpp | |
hash.hpp | |
hypergeometric_distribution.hpp | |
item_serialization_tools.hpp | |
json_logger.cpp | |
json_logger.hpp | |
linux_proc_stats.cpp | |
linux_proc_stats.hpp | |
logger.cpp | |
logger.hpp | |
math.hpp | |
matrix.hpp | |
porting.cpp | |
porting.hpp | |
profile_task.hpp | |
profile_thread.cpp | |
profile_thread.hpp | |
qsort.hpp | |
radix_sort.hpp | |
reservoir_sampling.hpp | |
ring_buffer.hpp | |
sampling.hpp | |
shared_state.hpp | |
singleton.hpp | |
stats_counter.hpp | |
stats_timer.hpp | |
string.hpp | |
system_exception.hpp | |
thread_barrier.hpp | |
timed_counter.hpp | |
uint_types.hpp | |
vector.hpp | |
zipf_distribution.hpp | |
► core | |
bit_stream.hpp | |
buffered_multiway_merge.hpp | |
delta_stream.hpp | |
duplicate_detection.hpp | |
golomb_bit_stream.hpp | |
hyperloglog.cpp | |
hyperloglog.hpp | |
location_detection.hpp | |
multiway_merge.hpp | |
reduce_bucket_hash_table.hpp | |
reduce_by_hash_post_phase.hpp | |
reduce_by_index_post_phase.hpp | |
reduce_functional.hpp | |
reduce_old_probing_hash_table.hpp | |
reduce_pre_phase.hpp | |
reduce_probing_hash_table.hpp | |
reduce_table.hpp | |
► data | |
block.cpp | |
block.hpp | |
block_pool.cpp | |
block_pool.hpp | |
block_queue.cpp | |
block_queue.hpp | |
block_reader.hpp | |
block_sink.hpp | |
block_writer.hpp | |
byte_block.cpp | |
byte_block.hpp | |
cat_block_source.hpp | |
cat_stream.cpp | |
cat_stream.hpp | |
discard_sink.hpp | |
dyn_block_reader.hpp | |
file.cpp | |
file.hpp | |
mix_block_queue.cpp | |
mix_block_queue.hpp | |
mix_stream.cpp | |
mix_stream.hpp | |
multiplexer.cpp | |
multiplexer.hpp | |
multiplexer_header.hpp | |
serialization.hpp | |
serialization_cereal.hpp | |
serialization_fwd.hpp | |
stream.cpp | |
stream.hpp | |
stream_data.cpp | |
stream_data.hpp | |
stream_sink.cpp | |
stream_sink.hpp | |
► mem | |
aligned_allocator.hpp | |
allocator.hpp | |
allocator_base.hpp | |
malloc_tracker.cpp | |
malloc_tracker.hpp | |
manager.cpp | |
manager.hpp | |
pool.cpp | |
pool.hpp | |
► net | |
► mock | |
group.cpp | |
group.hpp | |
► mpi | |
dispatcher.cpp | |
dispatcher.hpp | |
group.cpp | |
group.hpp | |
► tcp | |
connection.hpp | |
construct.cpp | |
construct.hpp | |
group.cpp | |
group.hpp | |
select.hpp | |
select_dispatcher.cpp | |
select_dispatcher.hpp | |
socket.cpp | |
socket.hpp | |
socket_address.cpp | |
socket_address.hpp | |
buffer.hpp | |
buffer_builder.hpp | |
buffer_reader.hpp | |
buffer_ref.hpp | |
collective.hpp | |
connection.hpp | |
dispatcher.hpp | |
dispatcher_thread.cpp | |
dispatcher_thread.hpp | |
exception.hpp | |
fixed_buffer_builder.hpp | |
flow_control_channel.cpp | |
flow_control_channel.hpp | |
flow_control_manager.hpp | |
group.cpp | |
group.hpp | |
manager.hpp | |
► vfs | |
bzip2_filter.cpp | |
bzip2_filter.hpp | |
file_io.cpp | |
file_io.hpp | |
gzip_filter.cpp | |
gzip_filter.hpp | |
hdfs3_file.cpp | |
hdfs3_file.hpp | |
s3_file.cpp | |
s3_file.hpp | |
simple_glob.hpp | A cross-platform file globbing library providing the ability to expand wildcards in command-line arguments to a list of all matching files. It is designed explicitly to be portable to any platform and has been tested on Windows and Linux. See CSimpleGlobTempl for the class definition |
sys_file.cpp | |
sys_file.hpp | |
temporary_directory.cpp | |
temporary_directory.hpp | |
thrill.hpp | |