本文整理了Java中org.apache.calcite.rel.core.Project.getInputs()方法的一些代码示例，展示了Project.getInputs()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Project.getInputs()方法的具体详情如下：
包路径：org.apache.calcite.rel.core.Project
类名称：Project
方法名：getInputs

Project.getInputs介绍

暂无

代码示例

代码示例来源：origin: org.apache.samza/samza-sql

@Override
public void init(Context context) {
 this.context = ((SamzaSqlApplicationContext) context.getApplicationTaskContext()).getTranslatorContexts().get(queryId);
 this.project = (Project) this.context.getRelNode(projectId);
 this.expr = this.context.getExpressionCompiler().compile(project.getInputs(), project.getProjects());
}

代码示例来源：origin: apache/samza

/**
 * initializes the ProjectMapFunction before any message is processed
 * @param context the {@link Context} for this task
 */
@Override
public void init(Context context) {
 this.translatorContext = ((SamzaSqlApplicationContext) context.getApplicationTaskContext()).getTranslatorContexts().get(queryId);
 this.project = (Project) this.translatorContext.getRelNode(projectId);
 this.expr = this.translatorContext.getExpressionCompiler().compile(project.getInputs(), project.getProjects());
 ContainerContext containerContext = context.getContainerContext();
 metricsRegistry = containerContext.getContainerMetricsRegistry();
 processingTime = new SamzaHistogram(metricsRegistry, logicalOpId, TranslatorConstants.PROCESSING_TIME_NAME);
 inputEvents = metricsRegistry.newCounter(logicalOpId, TranslatorConstants.INPUT_EVENTS_NAME);
 inputEvents.clear();
 outputEvents = metricsRegistry.newCounter(logicalOpId, TranslatorConstants.OUTPUT_EVENTS_NAME);
 outputEvents.clear();
}