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

Project.getId介绍

暂无

代码示例

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

void translate(final Project project, final String logicalOpId, final TranslatorContext context) {
 MessageStream<SamzaSqlRelMessage> messageStream = context.getMessageStream(project.getInput().getId());
 List<Integer> flattenProjects =
   project.getProjects().stream().filter(this::isFlatten).map(this::getProjectIndex).collect(Collectors.toList());
 if (flattenProjects.size() > 0) {
  if (flattenProjects.size() > 1) {
   String msg = "Multiple flatten operators in a single query is not supported";
   LOG.error(msg);
   throw new SamzaException(msg);
  }
  messageStream = translateFlatten(flattenProjects.get(0), messageStream);
 }
 final int projectId = project.getId();
 MessageStream<SamzaSqlRelMessage> outputStream = messageStream.map(new ProjectMapFunction(projectId, queryId, logicalOpId));
 context.registerMessageStream(project.getId(), outputStream);
 context.registerRelNode(project.getId(), project);
}

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

void translate(final Project project, final TranslatorContext context) {
 MessageStream<SamzaSqlRelMessage> messageStream = context.getMessageStream(project.getInput().getId());
 List<Integer> flattenProjects =
   project.getProjects().stream().filter(this::isFlatten).map(this::getProjectIndex).collect(Collectors.toList());
 if (flattenProjects.size() > 0) {
  if (flattenProjects.size() > 1) {
   String msg = "Multiple flatten operators in a single query is not supported";
   LOG.error(msg);
   throw new SamzaException(msg);
  }
  messageStream = translateFlatten(flattenProjects.get(0), messageStream);
 }
 final int projectId = project.getId();
 MessageStream<SamzaSqlRelMessage> outputStream = messageStream.map(new ProjectMapFunction(projectId, queryId));
 context.registerMessageStream(project.getId(), outputStream);
 context.registerRelNode(project.getId(), project);
}