本文整理了Java中cascading.tuple.Tuple.get()
方法的一些代码示例,展示了Tuple.get()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Tuple.get()
方法的具体详情如下:
包路径:cascading.tuple.Tuple
类名称: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 ) );
}
内容来源于网络,如有侵权,请联系作者删除!