org.apache.calcite.rel.type.RelDataTypeFactory.createMapType()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(7.7k)|赞(0)|评价(0)|浏览(117)

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

RelDataTypeFactory.createMapType介绍

[英]Creates a map type. Maps are unordered collections of key/value pairs.
[中]创建贴图类型。映射是键/值对的无序集合。

代码示例

代码示例来源:origin: apache/drill

@Override
public RelDataType getRowType(RelDataTypeFactory typeFactory) {
 ArrayList<RelDataType> typeList = new ArrayList<>();
 ArrayList<String> fieldNameList = new ArrayList<>();
 fieldNameList.add(ROW_KEY);
 typeList.add(typeFactory.createSqlType(SqlTypeName.ANY));
 Set<byte[]> families = tableDesc.getFamiliesKeys();
 for (byte[] family : families) {
  fieldNameList.add(Bytes.toString(family));
  typeList.add(typeFactory.createMapType(typeFactory.createSqlType(SqlTypeName.VARCHAR), typeFactory.createSqlType(SqlTypeName.ANY)));
 }
 return typeFactory.createStructType(typeList, fieldNameList);
}

代码示例来源:origin: apache/hive

public static RelDataType convert(MapTypeInfo mapType, RelDataTypeFactory dtFactory)
 throws CalciteSemanticException {
 RelDataType keyType = convert(mapType.getMapKeyTypeInfo(), dtFactory);
 RelDataType valueType = convert(mapType.getMapValueTypeInfo(), dtFactory);
 return dtFactory.createMapType(keyType, valueType);
}

代码示例来源:origin: apache/drill

private RelDataType getRelDataType(MapTypeInfo mapTypeInfo) {
 RelDataType keyType = convertToRelDataType(mapTypeInfo.getMapKeyTypeInfo());
 RelDataType valueType = convertToRelDataType(mapTypeInfo.getMapValueTypeInfo());
 return typeFactory.createMapType(keyType, valueType);
}

代码示例来源:origin: apache/drill

public static RelDataType convert(MapTypeInfo mapType, RelDataTypeFactory dtFactory)
 throws CalciteSemanticException {
 RelDataType keyType = convert(mapType.getMapKeyTypeInfo(), dtFactory);
 RelDataType valueType = convert(mapType.getMapValueTypeInfo(), dtFactory);
 return dtFactory.createMapType(keyType, valueType);
}

代码示例来源:origin: Qihoo360/Quicksql

public static RelDataType createMapType(
  RelDataTypeFactory typeFactory,
  RelDataType keyType,
  RelDataType valueType,
  boolean nullable) {
 RelDataType ret = typeFactory.createMapType(keyType, valueType);
 return typeFactory.createTypeWithNullability(ret, nullable);
}

代码示例来源:origin: org.apache.calcite/calcite-core

public static RelDataType createMapType(
  RelDataTypeFactory typeFactory,
  RelDataType keyType,
  RelDataType valueType,
  boolean nullable) {
 RelDataType ret = typeFactory.createMapType(keyType, valueType);
 return typeFactory.createTypeWithNullability(ret, nullable);
}

代码示例来源:origin: org.apache.kylin/atopcalcite

public static RelDataType createMapType(
    RelDataTypeFactory typeFactory,
    RelDataType keyType,
    RelDataType valueType,
    boolean nullable) {
  RelDataType ret = typeFactory.createMapType(keyType, valueType);
  return typeFactory.createTypeWithNullability(ret, nullable);
}

代码示例来源:origin: org.apache.drill.contrib/drill-storage-hbase

@Override
public RelDataType getRowType(RelDataTypeFactory typeFactory) {
 ArrayList<RelDataType> typeList = new ArrayList<>();
 ArrayList<String> fieldNameList = new ArrayList<>();
 fieldNameList.add(ROW_KEY);
 typeList.add(typeFactory.createSqlType(SqlTypeName.ANY));
 Set<byte[]> families = tableDesc.getFamiliesKeys();
 for (byte[] family : families) {
  fieldNameList.add(Bytes.toString(family));
  typeList.add(typeFactory.createMapType(typeFactory.createSqlType(SqlTypeName.VARCHAR), typeFactory.createSqlType(SqlTypeName.ANY)));
 }
 return typeFactory.createStructType(typeList, fieldNameList);
}

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

public static RelDataType convert(MapTypeInfo mapType, RelDataTypeFactory dtFactory)
 throws CalciteSemanticException {
 RelDataType keyType = convert(mapType.getMapKeyTypeInfo(), dtFactory);
 RelDataType valueType = convert(mapType.getMapValueTypeInfo(), dtFactory);
 return dtFactory.createMapType(keyType, valueType);
}

代码示例来源:origin: Qihoo360/Quicksql

@Override public RelDataType getRowType(RelDataTypeFactory relDataTypeFactory) {
 final RelDataType mapType = relDataTypeFactory.createMapType(
   relDataTypeFactory.createSqlType(SqlTypeName.VARCHAR),
   relDataTypeFactory.createTypeWithNullability(
     relDataTypeFactory.createSqlType(SqlTypeName.ANY),
     true));
 return relDataTypeFactory.builder().add("_MAP", mapType).build();
}

代码示例来源:origin: Qihoo360/Quicksql

public RelDataType getRowType(RelDataTypeFactory typeFactory) {
 return typeFactory.builder().add("_MAP",
   typeFactory.createMapType(
     typeFactory.createSqlType(SqlTypeName.VARCHAR),
     typeFactory.createTypeWithNullability(
       typeFactory.createSqlType(SqlTypeName.VARCHAR), true))).build();
}

代码示例来源:origin: org.apache.calcite/calcite-example-csv

public RelDataType getRowType(RelDataTypeFactory typeFactory) {
 return typeFactory.builder().add("_MAP",
   typeFactory.createMapType(
     typeFactory.createSqlType(SqlTypeName.VARCHAR),
     typeFactory.createTypeWithNullability(
       typeFactory.createSqlType(SqlTypeName.VARCHAR), true))).build();
}

代码示例来源:origin: org.apache.drill.exec/drill-java-exec

rowfields.add(new RelDataTypeFieldImpl(
  path.getRootSegmentPath(), rowfields.size(),
  typeFactory.createMapType(typeFactory.createSqlType(SqlTypeName.VARCHAR),
    typeFactory.createSqlType(SqlTypeName.ANY))
));

代码示例来源:origin: org.apache.drill.exec/drill-java-exec

RelDataType valueType = getNullableRelDataTypeFromAvroType(typeFactory, fieldSchema.getValueType());
 RelDataType keyType = typeFactory.createSqlType(SqlTypeName.VARCHAR);
 relDataType = typeFactory.createMapType(keyType, valueType);
 break;
case NULL:
 relDataType = typeFactory.createMapType(keyType, valueType);
 break;
case ENUM:

代码示例来源:origin: Qihoo360/Quicksql

public RelDataType getRowType(RelDataTypeFactory typeFactory) {
 RelDataType nullableVarcharType = typeFactory
   .createTypeWithNullability(typeFactory.createSqlType(SqlTypeName.VARCHAR), true);
 RelDataType nullableIntegerType = typeFactory
   .createTypeWithNullability(typeFactory.createSqlType(SqlTypeName.INTEGER), true);
 RelDataType nullableMapType = typeFactory
   .createTypeWithNullability(
     typeFactory.createMapType(nullableVarcharType, nullableIntegerType),
     true);
 return typeFactory.builder()
   .add("ID", SqlTypeName.INTEGER)
   .add("MAPFIELD",
     typeFactory.createTypeWithNullability(
      typeFactory.createMapType(nullableVarcharType, nullableIntegerType), true))
   .add("NESTEDMAPFIELD", typeFactory
     .createTypeWithNullability(
       typeFactory.createMapType(nullableVarcharType, nullableMapType), true))
   .add("ARRAYFIELD", typeFactory
     .createTypeWithNullability(
       typeFactory.createArrayType(nullableIntegerType, -1L), true))
   .add("STRINGARRAYFIELD", typeFactory
     .createTypeWithNullability(
       typeFactory.createArrayType(nullableVarcharType, -1L), true))
   .build();
}

代码示例来源:origin: org.apache.calcite/calcite-core

public RelDataType getRowType(RelDataTypeFactory typeFactory) {
 RelDataType nullableVarcharType = typeFactory
   .createTypeWithNullability(typeFactory.createSqlType(SqlTypeName.VARCHAR), true);
 RelDataType nullableIntegerType = typeFactory
   .createTypeWithNullability(typeFactory.createSqlType(SqlTypeName.INTEGER), true);
 RelDataType nullableMapType = typeFactory
   .createTypeWithNullability(
     typeFactory.createMapType(nullableVarcharType, nullableIntegerType),
     true);
 return typeFactory.builder()
   .add("ID", SqlTypeName.INTEGER)
   .add("MAPFIELD",
     typeFactory.createTypeWithNullability(
      typeFactory.createMapType(nullableVarcharType, nullableIntegerType), true))
   .add("NESTEDMAPFIELD", typeFactory
     .createTypeWithNullability(
       typeFactory.createMapType(nullableVarcharType, nullableMapType), true))
   .add("ARRAYFIELD", typeFactory
     .createTypeWithNullability(
       typeFactory.createArrayType(nullableIntegerType, -1L), true))
   .add("STRINGARRAYFIELD", typeFactory
     .createTypeWithNullability(
       typeFactory.createArrayType(nullableVarcharType, -1L), true))
   .build();
}

相关文章