org.apache.parquet.schema.MessageType.equals()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(2.3k)|赞(0)|评价(0)|浏览(88)

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

MessageType.equals介绍

暂无

代码示例

代码示例来源:origin: org.lasersonlab.apache.parquet/parquet-hadoop

static GlobalMetaData mergeInto(
  FileMetaData toMerge,
  GlobalMetaData mergedMetadata,
  boolean strict) {
 MessageType schema = null;
 Map<String, Set<String>> newKeyValues = new HashMap<String, Set<String>>();
 Set<String> createdBy = new HashSet<String>();
 if (mergedMetadata != null) {
  schema = mergedMetadata.getSchema();
  newKeyValues.putAll(mergedMetadata.getKeyValueMetaData());
  createdBy.addAll(mergedMetadata.getCreatedBy());
 }
 if ((schema == null && toMerge.getSchema() != null)
   || (schema != null && !schema.equals(toMerge.getSchema()))) {
  schema = mergeInto(toMerge.getSchema(), schema, strict);
 }
 for (Entry<String, String> entry : toMerge.getKeyValueMetaData().entrySet()) {
  Set<String> values = newKeyValues.get(entry.getKey());
  if (values == null) {
   values = new LinkedHashSet<String>();
   newKeyValues.put(entry.getKey(), values);
  }
  values.add(entry.getValue());
 }
 createdBy.add(toMerge.getCreatedBy());
 return new GlobalMetaData(
   schema,
   newKeyValues,
   createdBy);
}

代码示例来源:origin: org.apache.parquet/parquet-hadoop

static GlobalMetaData mergeInto(
  FileMetaData toMerge,
  GlobalMetaData mergedMetadata,
  boolean strict) {
 MessageType schema = null;
 Map<String, Set<String>> newKeyValues = new HashMap<String, Set<String>>();
 Set<String> createdBy = new HashSet<String>();
 if (mergedMetadata != null) {
  schema = mergedMetadata.getSchema();
  newKeyValues.putAll(mergedMetadata.getKeyValueMetaData());
  createdBy.addAll(mergedMetadata.getCreatedBy());
 }
 if ((schema == null && toMerge.getSchema() != null)
   || (schema != null && !schema.equals(toMerge.getSchema()))) {
  schema = mergeInto(toMerge.getSchema(), schema, strict);
 }
 for (Entry<String, String> entry : toMerge.getKeyValueMetaData().entrySet()) {
  Set<String> values = newKeyValues.get(entry.getKey());
  if (values == null) {
   values = new LinkedHashSet<String>();
   newKeyValues.put(entry.getKey(), values);
  }
  values.add(entry.getValue());
 }
 createdBy.add(toMerge.getCreatedBy());
 return new GlobalMetaData(
   schema,
   newKeyValues,
   createdBy);
}

相关文章