APISonar


org.apache.beam.sdk.nexmark.NexmarkUtils.SideInputType.CSV

> org > apache > beam > sdk > nexmark > NexmarkUtils > SideInputType > CSV
org APIs apache APIs beam APIs sdk APIs nexmark APIs NexmarkUtils APIs SideInputType APIs CSV APIs

Example 1
public void queryMatchesModelBatchCsv() throws Exception {
    NexmarkConfiguration config = NexmarkConfiguration.DEFAULT.copy();
    config.sideInputType = NexmarkUtils.SideInputType.CSV;
    config.numEventGenerators = 1;
    config.numEvents = 5000;
    config.sideInputRowCount = 10;
    config.sideInputNumShards = 3;

    queryMatchesModel(
        "SqlBoundedSideInputJoinTestBatch",
        config,
        new SqlBoundedSideInputJoin(config),
        new BoundedSideInputJoinModel(config),
        false);
  }