在PipelineOptions中添加calcitePersistentPlannerOptions参数,并与视图名称一起设置。例如,在Java中:
PipelineOptions options = PipelineOptionsFactory.create();
CalcitePipelineOptions calciteOptions = options.as(CalcitePipelineOptions.class);
calciteOptions.setCalcitePersistentPlannerOptions(ImmutableMap.of("default", "default_views"));
在上面的示例中,使用默认数据库和名称为default_views的视图。此参数可用于在Beam DirectRunner Calcite中指定视图名称。