cascading.tuple.Tuple.get()方法的使用及代码示例

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

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

Tuple.get介绍

[英]Method get returns a new Tuple populated with only those values whose field names are specified in the given selector. The declarator Fields instance declares the fields and positions in the current Tuple instance.
[中]方法get返回一个新的元组,该元组中只填充了字段名在给定选择器中指定的值。declarator Fields实例声明当前元组实例中的字段和位置。

代码示例

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

@Override
public Tuple makeResult( Tuple input, Tuple output )
 {
 return input.get( incomingFields, narrowFields );
 }
};

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

@Test
public void testWildcard()
 {
 Fields aFields = Fields.ALL;
 Tuple aTuple = tuple.get( fields, aFields );
 assertEquals( "not equal: aTuple.size()", 5, aTuple.size() );
 assertEquals( "not equal: aTuple.get( 0 )", "a", aTuple.get( fields, new Fields( "one" ) ).getObject( 0 ) );
 assertEquals( "not equal: aTuple.get( 1 )", "b", aTuple.get( fields, new Fields( "two" ) ).getObject( 0 ) );
 }

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

@Test
public void testArgumentSelector()
 {
 Fields declarator = new Fields( "1", "2", "3", "4" );
 Tuple incoming = new Tuple( 1, 2, 3, 4 );
 Fields selector = new Fields( "3", "2" );
 assertTuple( incoming.get( declarator, selector ) );
 int[] pos = incoming.getPos( declarator, selector );
 assertTuple( incoming.get( pos ) );
 assertTuple( TupleViews.createNarrow( pos, incoming ) );
 }

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

@Test
public void testHas()
 {
 assertEquals( "not equal: tuple.size()", 5, tuple.size() );
 assertEquals( "not equal: tuple.get( 0 )", "a", tuple.get( fields, new Fields( "one" ) ).getObject( 0 ) );
 assertEquals( "not equal: tuple.get( 1 )", "b", tuple.get( fields, new Fields( "two" ) ).getObject( 0 ) );
 }

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

@Override
public Tuple makeResult( Tuple input, Tuple output )
 {
 return input.get( incomingFields, argumentsSelector );
 }
};

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

@Test
public void testGetNull()
 {
 Tuple aTuple = tuple.get( (int[]) null );
 assertEquals( "not equal: aTuple.size()", 5, aTuple.size() );
 assertEquals( "not equal: aTuple.get( 0 )", "a", aTuple.getObject( 0 ) );
 assertEquals( "not equal: aTuple.get( 1 )", "b", aTuple.getObject( 1 ) );
 assertEquals( "not equal: tuple.size()", 5, tuple.size() );
 assertEquals( "not equal: tuple.get( 0 )", "a", tuple.getObject( 0 ) );
 assertEquals( "not equal: tuple.get( 1 )", "b", tuple.getObject( 1 ) );
 }

代码示例来源:origin: dataArtisans/cascading-flink

@Override
public Tuple2<Tuple, Tuple[]> map(Tuple tuple) throws Exception {
  if(keyFields == null) {
    out.f0 = empty;
  }
  else {
    out.f0 = tuple.get(schema, keyFields);
  }
  out.f1[initialPos] = tuple;
  return out;
}

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

@Test
public void testGet()
 {
 Tuple aTuple = tuple.get( new int[]{0} );
 assertEquals( "not equal: aTuple.size()", 1, aTuple.size() );
 assertEquals( "not equal: aTuple.get( 0 )", "a", aTuple.getObject( 0 ) );
 assertEquals( "not equal: tuple.size()", 5, tuple.size() );
 assertEquals( "not equal: tuple.get( 0 )", "a", tuple.getObject( 0 ) );
 assertEquals( "not equal: tuple.get( 1 )", "b", tuple.getObject( 1 ) );
 }

代码示例来源:origin: dataArtisans/cascading-flink

@Override
public Tuple2<Tuple, Tuple[]> join(Tuple2<Tuple, Tuple[]> leftT, Tuple rightT) throws Exception {
  if(leftT == null) {
    outT.f0 = rightT.get(inputFields, keyFields);
    outT.f1[tupleListPos] = rightT;
    return outT;
  }
  else {
    leftT.f1[tupleListPos] = rightT;
    return leftT;
  }
}

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

@Test
public void testPut()
 {
 Fields aFields = new Fields( "one", "five" );
 tuple.put( fields, aFields, new Tuple( "ten", "eleven" ) );
 assertEquals( "not equal: tuple.size()", 5, tuple.size() );
 assertEquals( "not equal: tuple.get( 0 )", "ten", tuple.getObject( 0 ) );
 assertEquals( "not equal: tuple.get( 0 )", "ten", tuple.get( fields, new Fields( "one" ) ).getObject( 0 ) );
 assertEquals( "not equal: tuple.get( 0 )", "eleven", tuple.getObject( 4 ) );
 assertEquals( "not equal: tuple.get( 0 )", "eleven", tuple.get( fields, new Fields( "five" ) ).getObject( 0 ) );
 }

代码示例来源:origin: dataArtisans/cascading-flink

@Override
  public Tuple3<Tuple, Integer, Tuple> map(Tuple value) throws Exception {

    if(keyPos.length > 0) {
      outT.f0 = value.get(keyPos);
    }
    else {
      outT.f0 = defaultKey;
    }
    outT.f2 = value;
    return outT;
  }
}

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

@Test
public void testSelectComplex()
 {
 Tuple tuple = new Tuple( "movie", "name1", "movie1", "rate1", "name2", "movie2", "rate2" );
 Fields declarationA = new Fields( "movie", "name1", "movie1", "rate1", "name2", "movie2", "rate2" );
 Fields selectA = new Fields( "movie", "name1", "rate1", "name2", "rate2" );
 Tuple result = tuple.get( declarationA, selectA );
 assertEquals( "not equal: ", 5, result.size() );
 assertEquals( "not equal: ", "movie", result.getObject( 0 ) );
 assertEquals( "not equal: ", "name1", result.getObject( 1 ) );
 assertEquals( "not equal: ", "rate1", result.getObject( 2 ) );
 assertEquals( "not equal: ", "name2", result.getObject( 3 ) );
 assertEquals( "not equal: ", "rate2", result.getObject( 4 ) );
 }
}

代码示例来源:origin: dataArtisans/cascading-flink

@Override
public Tuple2<Tuple, Tuple[]> join(Tuple leftT, Tuple rightT) throws Exception {
  if(leftT == null) {
    outT.f0 = rightT.get(inputFieldsRight, keyFieldsRight);
  }
  else {
    outT.f0 = leftT.get(inputFieldsLeft, keyFieldsLeft);
  }
  outT.f1[0] = leftT;
  outT.f1[1] = rightT;
  return outT;
}

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

@Test
public void testGet()
 {
 Fields aFields = new Fields( "one" );
 Tuple aTuple = tuple.get( fields, aFields );
 assertEquals( "not equal: aTuple.size()", 1, aTuple.size() );
 assertEquals( "not equal: aTuple.get( 0 )", "a", aTuple.getObject( 0 ) );
 assertEquals( "not equal: tuple.size()", 5, tuple.size() );
 assertEquals( "not equal: tuple.get( 0 )", "a", tuple.getObject( 0 ) );
 assertEquals( "not equal: tuple.get( 1 )", "b", tuple.getObject( 1 ) );
 }

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

@Override
public Tuple makeResult( Tuple input, Tuple output )
 {
 return input.get( incomingFields, remainderFields ).append( output );
 }
};

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

@Test
public void testRemove()
 {
 Fields aFields = new Fields( "one" );
 Tuple aTuple = tuple.remove( fields, aFields );
 assertEquals( "not equal: aTuple.size()", 1, aTuple.size() );
 assertEquals( "not equal: aTuple.get( 0 )", "a", aTuple.getObject( 0 ) );
 fields = fields.subtract( aFields );
 assertEquals( "not equal: tuple.size()", 4, tuple.size() );
 assertEquals( "not equal: tuple.get( 0 )", "b", tuple.get( fields, new Fields( "two" ) ).getObject( 0 ) );
 assertEquals( "not equal: tuple.get( 1 )", "c", tuple.get( fields, new Fields( "three" ) ).getObject( 0 ) );
 }

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

@Override
public boolean apply( Tuple tuple )
 {
 for( Tuple skipTuple : skip )
  {
  Tuple value = tuple.get( skipFields.getPos() );
  if( value.equals( skipTuple ) )
   {
   LOG.debug( "skipping: lhs: {}", tuple );
   return false;
   }
  }
 return true;
 }
} );

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

@Override
public boolean apply( Tuple tuple )
 {
 for( Tuple skipTuple : skip )
  {
  Tuple value = tuple.get( skipFields.getPos() );
  if( value.equals( skipTuple ) )
   {
   LOG.debug( "skipping: rhs: {}", tuple );
   return false;
   }
  }
 return true;
 }
} );

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

private void useSize( TupleEntry input, TupleEntryCollector outputCollector )
 {
 LOG.debug( "using size: {}", size );
 Tuple tuple = new Tuple( input.getTuple() ); // make clone
 Tuple group = tuple.remove( input.getFields(), groupFieldSelector );
 for( int i = 0; i < tuple.size(); i = i + size )
  {
  Tuple result = new Tuple( group );
  result.addAll( tuple.get( Fields.offsetSelector( size, i ).getPos() ) );
  outputCollector.add( result );
  }
 }

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

@Test
 public void testSelectorAll()
  {
//    if( getOutputSelector().isAll() )
//      return inputEntry.getTuple().append( output );

  Fields incomingFields = new Fields( "1", "2", "3", "4" );
  Tuple incoming = new Tuple( 1, 2, 3, 4 );
  Fields resultFields = new Fields( "5", "6", "7" );
  Tuple result = new Tuple( 5, 6, 7 );

  Tuple view = TupleViews.createComposite( incoming, result );

  assertEquals( new Tuple( 1, 2, 3, 4, 5, 6, 7 ), view );
  assertEquals( new Tuple( 1, 2, 3, 4, 5, 6, 7 ), new Tuple( view ) );

  Fields allFields = Fields.join( incomingFields, resultFields );
  Fields selector = new Fields( "3", "2" );

  assertTuple( view.get( allFields, selector ) );
  }

相关文章