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

Tuple.getDouble介绍

[英]Method getDouble returns the element at the given position as a double. Zero if null.
[中]方法getDouble将给定位置的元素作为double返回。如果为空，则为零。

代码示例

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

/**
 * Method posToDouble returns the double value at the given tuple position.
 *
 * @param pos the ordinal position to select from
 * @return the value in the given ordinal position
 */
public static ToDoubleFunction<Tuple> posToDouble( int pos )
 {
 return value -> value.getDouble( pos );
 }

代码示例来源：origin: cascading/pattern-core

@Override
public double calculate( CompareFunction[] compareFunctions, Tuple values, double[] points )
 {
 double sumOfSquares = 0.0;
 for( int i = 0; i < points.length; i++ )
  sumOfSquares += Math.pow( values.getDouble( i ) - points[ i ], 2.0 );
 return sumOfSquares;
 }
}

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

public void aggregate( FlowProcess flowProcess, AggregatorCall<Map<String, Double>> aggregatorCall )
 {
 Map<String, Double> context = aggregatorCall.getContext();
 TupleEntry entry = aggregatorCall.getArguments();
 context.put( COUNT, ( (Double) context.get( COUNT ) ) + 1d );
 context.put( SUM1, ( (Double) context.get( SUM1 ) ) + entry.getTuple().getDouble( 0 ) );
 context.put( SUM2, ( (Double) context.get( SUM2 ) ) + entry.getTuple().getDouble( 1 ) );
 context.put( SUMSQRS1, ( (Double) context.get( SUMSQRS1 ) ) + Math.pow( entry.getTuple().getDouble( 0 ), 2 ) );
 context.put( SUMSQRS2, ( (Double) context.get( SUMSQRS2 ) ) + Math.pow( entry.getTuple().getDouble( 1 ), 2 ) );
 context.put( SUMPROD, ( (Double) context.get( SUMPROD ) ) + ( entry.getTuple().getDouble( 0 ) * entry.getTuple().getDouble( 1 ) ) );
 }

代码示例来源：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

@Test
public void testLast()
 {
 Aggregator aggregator = new Last();
 Tuple[] arguments = new Tuple[]{new Tuple( new Double( 1.0 ) ), new Tuple( new Double( 3.0 ) ),
                 new Tuple( new Double( 2.0 ) ), new Tuple( new Double( 4.0 ) ),
                 new Tuple( new Double( -5.0 ) )};
 Fields resultFields = new Fields( "field" );
 TupleListCollector resultEntryCollector = invokeAggregator( aggregator, arguments, resultFields );
 Tuple tuple = resultEntryCollector.iterator().next();
 assertEquals( "got expected value after aggregate", -5.0, tuple.getDouble( 0 ), 0.0d );
 }

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

@Test
public void testFirstN()
 {
 Aggregator aggregator = new First( 3 );
 Tuple[] arguments = new Tuple[]{new Tuple( new Double( 1.0 ) ), new Tuple( new Double( 3.0 ) ),
                 new Tuple( new Double( 2.0 ) ), new Tuple( new Double( 4.0 ) ),
                 new Tuple( new Double( -5.0 ) )};
 Fields resultFields = new Fields( "field" );
 TupleListCollector resultEntryCollector = invokeAggregator( aggregator, arguments, resultFields );
 Iterator<Tuple> iterator = resultEntryCollector.iterator();
 assertEquals( "got expected value after aggregate", 1.0, iterator.next().getDouble( 0 ), 0.0d );
 assertEquals( "got expected value after aggregate", 3.0, iterator.next().getDouble( 0 ), 0.0d );
 assertEquals( "got expected value after aggregate", 2.0, iterator.next().getDouble( 0 ), 0.0d );
 }

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

@Test
public void testMaxValue()
 {
 Aggregator aggregator = new MaxValue();
 Tuple[] arguments = new Tuple[]{new Tuple( new Double( 1.0 ) ), new Tuple( new Double( 3.0 ) ),
                 new Tuple( new Double( 2.0 ) ), new Tuple( new Double( 4.0 ) ),
                 new Tuple( new Double( -5.0 ) )};
 Fields resultFields = new Fields( "field" );
 TupleListCollector resultEntryCollector = invokeAggregator( aggregator, arguments, resultFields );
 Tuple tuple = resultEntryCollector.iterator().next();
 assertEquals( "got expected value after aggregate", 4.0, tuple.getDouble( 0 ), 0.0d );
 }

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

public void operate( FlowProcess flowProcess, FunctionCall functionCall )
 {
 TupleEntry input = functionCall.getArguments();
 functionCall.getOutputCollector().add( new Tuple( Math.pow( input.getTuple().getDouble( 0 ) - input.getTuple().getDouble( 1 ), 2 ) ) );
 }
};

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

@Test
public void testSum()
 {
 Aggregator aggregator = new Sum();
 Tuple[] arguments = new Tuple[]{new Tuple( new Double( 1.0 ) ), new Tuple( new Double( 3.0 ) ),
                 new Tuple( new Double( 2.0 ) ), new Tuple( new Double( 4.0 ) ),
                 new Tuple( new Double( -5.0 ) )};
 Fields resultFields = new Fields( "field" );
 TupleListCollector resultEntryCollector = invokeAggregator( aggregator, arguments, resultFields );
 Tuple tuple = resultEntryCollector.iterator().next();
 assertEquals( "got expected value after aggregate", 5.0, tuple.getDouble( 0 ), 0.0d );
 }

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

public void operate( FlowProcess flowProcess, FunctionCall functionCall )
 {
 TupleEntry input = functionCall.getArguments();
 functionCall.getOutputCollector().add( new Tuple( Math.pow( input.getTuple().getDouble( 0 ) - input.getTuple().getDouble( 1 ), 2 ) ) );
 }
};

代码示例来源：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: cascading/cascading-platform

public void operate( FlowProcess flowProcess, FunctionCall functionCall )
 {
 TupleEntry input = functionCall.getArguments();
 functionCall.getOutputCollector().add( new Tuple( Math.pow( input.getTuple().getDouble( 0 ) - input.getTuple().getDouble( 1 ), 2 ) ) );
 }
};

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

@Test
public void testAverage()
 {
 Aggregator aggregator = new Average();
 Tuple[] arguments = new Tuple[]{new Tuple( new Double( 1.0 ) ), new Tuple( new Double( 3.0 ) ),
                 new Tuple( new Double( 2.0 ) ), new Tuple( new Double( 4.0 ) ),
                 new Tuple( new Double( -5.0 ) )};
 Fields resultFields = new Fields( "field" );
 TupleListCollector resultEntryCollector = invokeAggregator( aggregator, arguments, resultFields );
 Tuple tuple = resultEntryCollector.iterator().next();
 assertEquals( "got expected value after aggregate", 1.0, tuple.getDouble( 0 ), 0.0d );
 }

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

@Test
public void testFirst()
 {
 Aggregator aggregator = new First();
 Tuple[] arguments = new Tuple[]{new Tuple( new Double( 1.0 ) ), new Tuple( new Double( 3.0 ) ),
                 new Tuple( new Double( 2.0 ) ), new Tuple( new Double( 4.0 ) ),
                 new Tuple( new Double( -5.0 ) )};
 Fields resultFields = new Fields( "field" );
 TupleListCollector resultEntryCollector = invokeAggregator( aggregator, arguments, resultFields );
 Tuple tuple = resultEntryCollector.iterator().next();
 assertEquals( "got expected value after aggregate", 1.0, tuple.getDouble( 0 ), 0.0d );
 }

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

@Test
public void testMinValue()
 {
 Aggregator aggregator = new MinValue();
 Tuple[] arguments = new Tuple[]{new Tuple( new Double( 1.0 ) ), new Tuple( new Double( 3.0 ) ),
                 new Tuple( new Double( 2.0 ) ), new Tuple( new Double( 4.0 ) ),
                 new Tuple( new Double( -5.0 ) )};
 Fields resultFields = new Fields( "field" );
 TupleListCollector resultEntryCollector = invokeAggregator( aggregator, arguments, resultFields );
 Tuple tuple = resultEntryCollector.iterator().next();
 assertEquals( "got expected value after aggregate", -5.0, tuple.getDouble( 0 ), 0.0d );
 }

代码示例来源：origin: cascading/cascading-platform

public void operate( FlowProcess flowProcess, FunctionCall functionCall )
 {
 TupleEntry input = functionCall.getArguments();
 functionCall.getOutputCollector().add( new Tuple( Math.pow( input.getTuple().getDouble( 0 ) - input.getTuple().getDouble( 1 ), 2 ) ) );
 }
};

代码示例来源：origin: cascading/cascading-platform

public void complete( FlowProcess flowProcess, AggregatorCall aggregatorCall )
 {
 Tuple tuple = super.getResult( aggregatorCall );
 aggregatorCall.getOutputCollector().add( new Tuple( 1 / ( 1 + tuple.getDouble( 0 ) ) ) );
 }
};

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

public void complete( FlowProcess flowProcess, AggregatorCall aggregatorCall )
 {
 Tuple tuple = super.getResult( aggregatorCall );
 aggregatorCall.getOutputCollector().add( new Tuple( 1 / ( 1 + tuple.getDouble( 0 ) ) ) );
 }
};

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

public void complete( FlowProcess flowProcess, AggregatorCall aggregatorCall )
 {
 Tuple tuple = super.getResult( aggregatorCall );
 aggregatorCall.getOutputCollector().add( new Tuple( 1 / ( 1 + tuple.getDouble( 0 ) ) ) );
 }
};

代码示例来源：origin: cascading/cascading-platform

public void complete( FlowProcess flowProcess, AggregatorCall aggregatorCall )
 {
 Tuple tuple = super.getResult( aggregatorCall );
 aggregatorCall.getOutputCollector().add( new Tuple( 1 / ( 1 + tuple.getDouble( 0 ) ) ) );
 }
};