in docker/data-generator/src/main/java/org/apache/flink/playground/datagen/model/TransactionSupplier.java [45:52]
public Transaction get() {
Transaction transaction = new Transaction();
transaction.accountId = accounts.next();
transaction.amount = generator.nextInt(1000);
transaction.timestamp = timestamps.next();
return transaction;
}