cascading.tuple.TupleEntry.getFloat()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(4.6k)|赞(0)|评价(0)|浏览(74)

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

TupleEntry.getFloat介绍

[英]Method getFloat returns the element for the given field name or position as a float. Zero if null.
fieldName may optionally be a Fields instance. Only the first field name or position will be considered.
[中]方法getFloat以浮点形式返回给定字段名或位置的元素。如果为空,则为零。
fieldName也可以是Fields实例。只考虑第一个字段名或位置。

代码示例

代码示例来源:origin: com.twitter/scalding-parquet

private void writePrimitive(TupleEntry record, PrimitiveType field) {
  switch (field.getPrimitiveTypeName()) {
   case BINARY:
    recordConsumer.addBinary(Binary.fromString(record.getString(field.getName())));
    break;
   case BOOLEAN:
    recordConsumer.addBoolean(record.getBoolean(field.getName()));
    break;
   case INT32:
    recordConsumer.addInteger(record.getInteger(field.getName()));
    break;
   case INT64:
    recordConsumer.addLong(record.getLong(field.getName()));
    break;
   case DOUBLE:
    recordConsumer.addDouble(record.getDouble(field.getName()));
    break;
   case FLOAT:
    recordConsumer.addFloat(record.getFloat(field.getName()));
    break;
   case FIXED_LEN_BYTE_ARRAY:
    throw new UnsupportedOperationException("Fixed len byte array type not implemented");
   case INT96:
    throw new UnsupportedOperationException("Int96 type not implemented");
   default:
    throw new UnsupportedOperationException(field.getName() + " type not implemented");
  }
 }
}

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

private void writePrimitive(TupleEntry record, PrimitiveType field) {
  switch (field.getPrimitiveTypeName()) {
   case BINARY:
    recordConsumer.addBinary(Binary.fromString(record.getString(field.getName())));
    break;
   case BOOLEAN:
    recordConsumer.addBoolean(record.getBoolean(field.getName()));
    break;
   case INT32:
    recordConsumer.addInteger(record.getInteger(field.getName()));
    break;
   case INT64:
    recordConsumer.addLong(record.getLong(field.getName()));
    break;
   case DOUBLE:
    recordConsumer.addDouble(record.getDouble(field.getName()));
    break;
   case FLOAT:
    recordConsumer.addFloat(record.getFloat(field.getName()));
    break;
   case FIXED_LEN_BYTE_ARRAY:
    throw new UnsupportedOperationException("Fixed len byte array type not implemented");
   case INT96:
    throw new UnsupportedOperationException("Int96 type not implemented");
   default:
    throw new UnsupportedOperationException(field.getName() + " type not implemented");
  }
 }
}

代码示例来源:origin: com.twitter/parquet-cascading

private void writePrimitive(TupleEntry record, PrimitiveType field) {
  switch (field.getPrimitiveTypeName()) {
   case BINARY:
    recordConsumer.addBinary(Binary.fromString(record.getString(field.getName())));
    break;
   case BOOLEAN:
    recordConsumer.addBoolean(record.getBoolean(field.getName()));
    break;
   case INT32:
    recordConsumer.addInteger(record.getInteger(field.getName()));
    break;
   case INT64:
    recordConsumer.addLong(record.getLong(field.getName()));
    break;
   case DOUBLE:
    recordConsumer.addDouble(record.getDouble(field.getName()));
    break;
   case FLOAT:
    recordConsumer.addFloat(record.getFloat(field.getName()));
    break;
   case FIXED_LEN_BYTE_ARRAY:
    throw new UnsupportedOperationException("Fixed len byte array type not implemented");
   case INT96:
    throw new UnsupportedOperationException("Int96 type not implemented");
   default:
    throw new UnsupportedOperationException(field.getName() + " type not implemented");
  }
 }
}

代码示例来源:origin: com.twitter/scalding-parquet-cascading

private void writePrimitive(TupleEntry record, PrimitiveType field) {
  switch (field.getPrimitiveTypeName()) {
   case BINARY:
    recordConsumer.addBinary(Binary.fromString(record.getString(field.getName())));
    break;
   case BOOLEAN:
    recordConsumer.addBoolean(record.getBoolean(field.getName()));
    break;
   case INT32:
    recordConsumer.addInteger(record.getInteger(field.getName()));
    break;
   case INT64:
    recordConsumer.addLong(record.getLong(field.getName()));
    break;
   case DOUBLE:
    recordConsumer.addDouble(record.getDouble(field.getName()));
    break;
   case FLOAT:
    recordConsumer.addFloat(record.getFloat(field.getName()));
    break;
   case FIXED_LEN_BYTE_ARRAY:
    throw new UnsupportedOperationException("Fixed len byte array type not implemented");
   case INT96:
    throw new UnsupportedOperationException("Int96 type not implemented");
   default:
    throw new UnsupportedOperationException(field.getName() + " type not implemented");
  }
 }
}

代码示例来源:origin: cwensel/cascading

@Test
public void testCoerceCanonicalUnknown()
 {
 Tuple tuple = new Tuple( 1 );
 TupleEntry results = new TupleEntry( Fields.UNKNOWN, tuple );
 assertEquals( 1, results.getObject( 0 ) );
 assertEquals( 1, results.getInteger( 0 ) );
 assertEquals( 1, results.getShort( 0 ) );
 assertEquals( 1L, results.getLong( 0 ) );
 assertEquals( 1.0F, results.getFloat( 0 ) );
 assertEquals( 1.0D, results.getDouble( 0 ) );
 assertEquals( "1", results.getString( 0 ) );
 }

相关文章