范围中的非重复随机值

import java.util.HashSet;
import java.util.Random;
import java.util.Set;

public class UniqueRandomNumbers {
    public static void main(String[] args) {
        int min = 1;
        int max = 100;
        int count = 10; // 你想生成的随机数的数量
        Set<Integer> uniqueNumbers = new HashSet<>();

        Random random = new Random();
        while (uniqueNumbers.size() < count) {
            int randomNumber = random.nextInt(max - min + 1) + min;
            uniqueNumbers.add(randomNumber);
        }

        System.out.println("Generated unique random numbers: " + uniqueNumbers);
    }
}

import org.apache.beam.sdk.Pipeline;
import org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.options.PipelineOptionsFactory;
import org.apache.beam.sdk.transforms.DoFn;
import org.apache.beam.sdk.transforms.ParDo;
import org.apache.beam.sdk.transforms.Reshuffle;
import org.apache.beam.sdk.values.KV;
import org.apache.beam.sdk.values.PCollection;

public class UniqueRandomNumbersPipeline {
    public static void main(String[] args) {
        PipelineOptions options = PipelineOptionsFactory.create();
        Pipeline pipeline = Pipeline.create(options);

        PCollection<Integer> numbers = pipeline.apply(Create.of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10));

        PCollection<KV<Integer, Integer>> uniqueNumbers = numbers.apply(
            ParDo.of(new DoFn<Integer, KV<Integer, Integer>>() {
                @ProcessElement
                public void processElement(ProcessContext c) {
                    int number = c.element();
                    c.output(KV.of(number, number));
                }
            }))
            .apply(Reshuffle.<Integer, Integer>viaRandomKey())
            .apply(ParDo.of(new DoFn<KV<Integer, Integer>, Integer>() {
                @ProcessElement
                public void processElement(ProcessContext c) {
                    c.output(c.element().getKey());
                }
            }));

        uniqueNumbers.apply(BigQueryIO.writeTableRows()
            .to("your-project-id:your_dataset.unique_random_numbers")
            .withSchema(schema)
            .withWriteDisposition(BigQueryIO.Write.WriteDisposition.WRITE_APPEND)
            .withCreateDisposition(BigQueryIO.Write.CreateDisposition.CREATE_IF_NEEDED));

        pipeline.run().waitUntilFinish();
    }
}