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

Utilities.serializeExpression介绍

[英]Serializes expression via Kryo.
[中]通过Kryo序列化表达式。

代码示例

代码示例来源：origin: org.apache.hadoop.hive/hive-exec

protected void pushFilters(JobConf jobConf, TableScanOperator tableScan) {
 TableScanDesc scanDesc = tableScan.getConf();
 if (scanDesc == null) {
  return;
 }
 // construct column name list for reference by filter push down
 Utilities.setColumnNameList(jobConf, tableScan);
 // push down filters
 ExprNodeDesc filterExpr = scanDesc.getFilterExpr();
 if (filterExpr == null) {
  return;
 }
 String filterText = filterExpr.getExprString();
 String filterExprSerialized = Utilities.serializeExpression(filterExpr);
 if (LOG.isDebugEnabled()) {
  LOG.debug("Filter text = " + filterText);
  LOG.debug("Filter expression = " + filterExprSerialized);
 }
 jobConf.set(
  TableScanDesc.FILTER_TEXT_CONF_STR,
  filterText);
 jobConf.set(
  TableScanDesc.FILTER_EXPR_CONF_STR,
  filterExprSerialized);
}

代码示例来源：origin: org.apache.parquet/parquet-hive-0.10-binding

private void pushFilters(final JobConf jobConf, final TableScanOperator tableScan) {
 final TableScanDesc scanDesc = tableScan.getConf();
 if (scanDesc == null) {
  LOG.debug("Not pushing filters because TableScanDesc is null");
  return;
 }
 // construct column name list for reference by filter push down
 Utilities.setColumnNameList(jobConf, tableScan);
 // push down filters
 final ExprNodeDesc filterExpr = scanDesc.getFilterExpr();
 if (filterExpr == null) {
  LOG.debug("Not pushing filters because FilterExpr is null");
  return;
 }
 final String filterText = filterExpr.getExprString();
 final String filterExprSerialized = Utilities.serializeExpression(filterExpr);
 jobConf.set(
     TableScanDesc.FILTER_TEXT_CONF_STR,
     filterText);
 jobConf.set(
     TableScanDesc.FILTER_EXPR_CONF_STR,
     filterExprSerialized);
}

代码示例来源：origin: org.apache.parquet/parquet-hive-0.12-binding

private void pushFilters(final JobConf jobConf, final TableScanOperator tableScan) {
 final TableScanDesc scanDesc = tableScan.getConf();
 if (scanDesc == null) {
  LOG.debug("Not pushing filters because TableScanDesc is null");
  return;
 }
 // construct column name list for reference by filter push down
 Utilities.setColumnNameList(jobConf, tableScan);
 // push down filters
 final ExprNodeDesc filterExpr = scanDesc.getFilterExpr();
 if (filterExpr == null) {
  LOG.debug("Not pushing filters because FilterExpr is null");
  return;
 }
 final String filterText = filterExpr.getExprString();
 final String filterExprSerialized = Utilities.serializeExpression(filterExpr);
 jobConf.set(
     TableScanDesc.FILTER_TEXT_CONF_STR,
     filterText);
 jobConf.set(
     TableScanDesc.FILTER_EXPR_CONF_STR,
     filterExprSerialized);
}

代码示例来源：origin: com.twitter/parquet-hive-0.10-binding

private void pushFilters(final JobConf jobConf, final TableScanOperator tableScan) {
 final TableScanDesc scanDesc = tableScan.getConf();
 if (scanDesc == null) {
  LOG.debug("Not pushing filters because TableScanDesc is null");
  return;
 }
 // construct column name list for reference by filter push down
 Utilities.setColumnNameList(jobConf, tableScan);
 // push down filters
 final ExprNodeDesc filterExpr = scanDesc.getFilterExpr();
 if (filterExpr == null) {
  LOG.debug("Not pushing filters because FilterExpr is null");
  return;
 }
 final String filterText = filterExpr.getExprString();
 final String filterExprSerialized = Utilities.serializeExpression(filterExpr);
 jobConf.set(
     TableScanDesc.FILTER_TEXT_CONF_STR,
     filterText);
 jobConf.set(
     TableScanDesc.FILTER_EXPR_CONF_STR,
     filterExprSerialized);
}

代码示例来源：origin: com.facebook.presto.hive/hive-apache

private void pushFilters(final JobConf jobConf, final TableScanOperator tableScan) {
 final TableScanDesc scanDesc = tableScan.getConf();
 if (scanDesc == null) {
  LOG.debug("Not pushing filters because TableScanDesc is null");
  return;
 }
 // construct column name list for reference by filter push down
 Utilities.setColumnNameList(jobConf, tableScan);
 // push down filters
 final ExprNodeGenericFuncDesc filterExpr = scanDesc.getFilterExpr();
 if (filterExpr == null) {
  LOG.debug("Not pushing filters because FilterExpr is null");
  return;
 }
 final String filterText = filterExpr.getExprString();
 final String filterExprSerialized = Utilities.serializeExpression(filterExpr);
 jobConf.set(
   TableScanDesc.FILTER_TEXT_CONF_STR,
   filterText);
 jobConf.set(
   TableScanDesc.FILTER_EXPR_CONF_STR,
   filterExprSerialized);
}

代码示例来源：origin: com.facebook.presto.hive/hive-apache

String filterExprSerialized = Utilities.serializeExpression(filterExpr);
if (LOG.isDebugEnabled()) {
 LOG.debug("Filter text = " + filterText);