java接收rowtype类型_Java PhysType.getJavaRowType方法代码示例
import org.apache.calcite.adapter.enumerable.PhysType; //导入方法依赖的package包/类
public Result implementSpark(Implementor implementor) {
/*
return Linq4j.asSpark(
new Object[][] {
new Object[] {1, 2},
new Object[] {3, 4}
});
*/
final JavaTypeFactory typeFactory =
(JavaTypeFactory) getCluster().getTypeFactory();
final BlockBuilder builder = new BlockBuilder();
final PhysType physType =
PhysTypeImpl.of(implementor.getTypeFactory(),
getRowType(),
JavaRowFormat.CUSTOM);
final Type rowClass = physType.getJavaRowType();
final List expressions = new ArrayList();
final List fields = rowType.getFieldList();
for (List tuple : tuples) {
final List literals = new ArrayList();
for (Pair pair
: Pair.zip(fields, tuple)) {
literals.add(
RexToLixTranslator.translateLiteral(
pair.right,
pair.left.getType(),
typeFactory,
RexImpTable.NullAs.NULL));
}
expressions.add(physType.record(literals));
}
builder.add(
Expressions.return_(null,
Expressions.call(SparkMethod.ARRAY_TO_RDD.method,
Expressions.call(SparkMethod.GET_SPARK_CONTEXT.method,
implementor.getRootExpression()),
Expressions.newArrayInit(Primitive.box(rowClass),
expressions))));
return implementor.result(physType, builder.toBlock());
}
java接收rowtype类型_Java PhysType.getJavaRowType方法代码示例相关推荐
- JAVA里tokens意思_Java TokenMetadata.sortedTokens方法代码示例
import org.apache.cassandra.locator.TokenMetadata; //导入方法依赖的package包/类 /** * Get the "primary r ...
- java中isolate时间_Java HikariDataSource.setIdleTimeout方法代码示例
import com.zaxxer.hikari.HikariDataSource; //导入方法依赖的package包/类 private HikariDataSource createHikari ...
- java getattribute为空_Java TransMeta.getAttribute方法代码示例
import org.pentaho.di.trans.TransMeta; //导入方法依赖的package包/类 @Override public void getData( TransMeta ...
- java okhttp设置超时_Java OkHttpClient.setWriteTimeout方法代码示例
import com.squareup.okhttp.OkHttpClient; //导入方法依赖的package包/类 @Bean @ConditionalOnMissingBean public ...
- java jtree 监听_Java JTree.addTreeExpansionListener方法代码示例
import javax.swing.JTree; //导入方法依赖的package包/类 public PackageBrowser(JFrame frame, String title, bool ...
- java打印设置缩放_Java PrintSetup.setPaperSize方法代码示例
import org.apache.poi.ss.usermodel.PrintSetup; //导入方法依赖的package包/类 /** * 复制模板工作表的打印区域到数据工作表中 * * @au ...
- java sslcontext详解_Java SslContext.newEngine方法代码示例
import io.netty.handler.ssl.SslContext; //导入方法依赖的package包/类 /** * 业务线程池 * 用以单独处理业务handler,避免造成IO线程的阻 ...
- java sslcontext详解_Java SslContext.newServerContext方法代码示例
import io.netty.handler.ssl.SslContext; //导入方法依赖的package包/类 public void start() throws CertificateEx ...
- java中setattr功能_Java Controller.setAttr方法代码示例
import com.jfinal.core.Controller; //导入方法依赖的package包/类 /** * 为了规范代码,这里做了一点类是Spring的ResponseEntity的东西 ...
最新文章
- MPB：西农焦硕组-微生物生物地理学研究方法
- javascript元素跟随鼠标在指定区域运动
- 【以前的空间】树链剖分
- Spring-Spring MVC + Spring JDBC + Spring Transaction + Maven 构建web登录模块
- 事务里面捕获异常_三问Spring事务：解决什么问题？如何解决？存在什么问题？...
- socket选项： SO_REUSEADDR, SO_RCVBUF, SO_SNDBUF
- 幅值与峰峰值的计算_电厂振动测量、计算基础及汽轮机组振动标准！
- python 三目运算符
- 蓝桥杯 ALGO-88 算法训练 字串统计
- python中支持双向索引的有哪些_解决Python中展示tkinter不支持的图片格式
- 关于钱学森定义复杂网络一事的探究
- 计算机术语int,整型（计算机语言）_百度百科
- ##Mysql数据库DQL查询工具的使用
- 目标检测综述(二：古典方法对比现代方式以及目标检测算法相关概述)
- 增长模型拆解：分享有礼裂变玩法的底层逻辑与细节设计
- 小程序：下载图片文件（wx.downloadFile）并保存到手机相册（wx.saveImageToPhotosAlbum）
- 小程序开发-用户对自己信息的更改
- C# MessageBox.Show 用法
- win10台式机 更换蓝牙模块后配对过的蓝牙设备无法连接 且删除失败解决方法
- 管理者如何提高自身管理能力？