本文整理了Java中org.apache.calcite.rel.core.Project.getInputs()
方法的一些代码示例,展示了Project.getInputs()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Project.getInputs()
方法的具体详情如下:
包路径:org.apache.calcite.rel.core.Project
类名称: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();
}
内容来源于网络,如有侵权,请联系作者删除!