本文整理了Java中cascading.tuple.TupleEntry.getDouble()
方法的一些代码示例,展示了TupleEntry.getDouble()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。TupleEntry.getDouble()
方法的具体详情如下:
包路径:cascading.tuple.TupleEntry
类名称:TupleEntry
方法名:getDouble
[英]Method getDouble returns the element for the given field name or position as a double. Zero if null.
fieldName may optionally be a Fields instance. Only the first field name or position will be considered.
[中]方法getDouble将给定字段名或位置的元素作为double返回。如果为空,则为零。
fieldName也可以是Fields实例。只考虑第一个字段名或位置。
代码示例来源:origin: cwensel/cascading
/**
* Method fieldToDouble returns a {@link Function} that returns the double in the given named field or position.
*
* @param fields the field to select, only first field will be honored
* @return the double value in the selected field
*/
public static ToDoubleFunction<TupleEntry> fieldToDouble( Fields fields )
{
Objects.requireNonNull( fields );
return value -> value.getDouble( fields );
}
代码示例来源:origin: cwensel/cascading
/**
* Method fieldToDouble returns a {@link Function} that returns the double in the given named field or position.
*
* @param name the field to select
* @return the double value in the selected field
*/
public static ToDoubleFunction<TupleEntry> fieldToDouble( Comparable name )
{
Objects.requireNonNull( name );
return value -> value.getDouble( name );
}
代码示例来源:origin: cascading/pattern-core
public double calculate( TupleEntry tupleEntry )
{
return predictor.calculate( tupleEntry.getDouble( index ) );
}
}
代码示例来源:origin: cwensel/cascading
@Override
public void aggregate( FlowProcess flowProcess, AggregatorCall<Context> aggregatorCall )
{
Context context = aggregatorCall.getContext();
TupleEntry arguments = aggregatorCall.getArguments();
context.sum += arguments.getDouble( 0 );
context.count += 1L;
}
代码示例来源:origin: LiveRamp/cascading_ext
aggregate[i] = 0D;
aggregate[i] = ((Double)aggregate[i]) + nextValue.getDouble(i);
break;
代码示例来源:origin: cwensel/cascading
public void aggregate( FlowProcess flowProcess, AggregatorCall<Double[]> aggregatorCall )
{
TupleEntry entry = aggregatorCall.getArguments();
aggregatorCall.getContext()[ 0 ] += Math.pow( entry.getDouble( 0 ) - entry.getDouble( 1 ), 2 );
}
代码示例来源:origin: cwensel/cascading
@Override
public void aggregate( FlowProcess flowProcess, AggregatorCall<Pair<Double[], Tuple>> aggregatorCall )
{
TupleEntry arguments = aggregatorCall.getArguments();
if( arguments.getObject( 0 ) == null )
return;
Double[] sum = aggregatorCall.getContext().getLhs();
double value = sum[ 0 ] == null ? 0 : sum[ 0 ];
sum[ 0 ] = value + arguments.getDouble( 0 );
}
代码示例来源:origin: cascading/pattern-core
@Override
public void operate( FlowProcess flowProcess, BufferCall<DecisionContext> bufferCall )
{
double[] results = bufferCall.getContext().results;
Arrays.fill( results, 0 ); // clear before use
Iterator<TupleEntry> iterator = bufferCall.getArgumentsIterator();
int count = 0;
while( iterator.hasNext() )
{
TupleEntry next = iterator.next();
Double score = next.getDouble( 0 );
results[ count++ ] += score;
}
double prediction = selection.predict( results );
LOG.debug( "prediction: {}", prediction );
bufferCall.getOutputCollector().add( bufferCall.getContext().result( prediction ) );
}
}
代码示例来源:origin: cwensel/cascading
@Override
public Tuple aggregate( FlowProcess flowProcess, TupleEntry args, Tuple context )
{
if( context == null )
return args.getTupleCopy();
else if( args.getObject( 0 ) == null )
return context;
context.set( 0, context.getDouble( 0 ) + args.getDouble( 0 ) );
return context;
}
代码示例来源:origin: cwensel/cascading
@Override
public void aggregate( FlowProcess flowProcess, AggregatorCall<Context> aggregatorCall )
{
Context context = aggregatorCall.getContext();
TupleEntry arguments = aggregatorCall.getArguments();
if( arguments.getObject( 0 ) == null )
{
context.nulls++;
return;
}
context.sum += arguments.getDouble( 0 );
context.count += arguments.getLong( 1 );
}
代码示例来源:origin: cwensel/cascading
@Override
public Tuple aggregate( FlowProcess flowProcess, TupleEntry args, Tuple context )
{
if( context == null )
context = Tuple.size( 2 );
if( include == Include.NO_NULLS && args.getObject( 0 ) == null )
return context;
context.set( 0, context.getDouble( 0 ) + args.getDouble( 0 ) );
context.set( 1, context.getLong( 1 ) + 1 );
return context;
}
代码示例来源: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 ) );
}
内容来源于网络,如有侵权,请联系作者删除!