Skip to content

Commit

Permalink
reorder
Browse files Browse the repository at this point in the history
  • Loading branch information
ahmedabu98 committed Feb 19, 2025
1 parent 0e98be1 commit f412d3b
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -60,11 +60,11 @@ public static void main(String[] args) throws IOException {

// ======== experiment with these numbers ===========
int numShards = 1;
long numRecords = 5_000_000L;
long payloadSize = 1 << 10; // 1KB
int numIcebergPartitions = 0;
// ==================================================

long numRecords = 5_000_000L;
int initialSplits = 20;
long recordsPerSecond = 1_000;
long mbps = Math.round((double) payloadSize * recordsPerSecond / (1 << 20));
Expand Down

0 comments on commit f412d3b

Please sign in to comment.