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

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

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

Tuple.elements介绍

[英]Field elements
[中]场元素

代码示例

代码示例来源:origin: elastic/elasticsearch-hadoop

List<Object> elements = Tuple.elements(entry.getTuple());
elements.clear();
elements.addAll(data.values());

代码示例来源:origin: elastic/elasticsearch-hadoop

List<Object> elements = Tuple.elements(entry.getTuple());
elements.clear();
elements.addAll(data.values());

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

@Override
public void reset( Tuple value )
 {
 elements = Tuple.elements( value );
 }
}

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

public DelegatedTuple( Tuple wrapped )
 {
 // pass it in to prevent one being allocated
 super( Tuple.elements( wrapped ) );
 }

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

@Override
public void reset( Tuple value )
 {
 elements = Tuple.elements( value );
 }
}

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

public WrappedTuple( TupleHasher tupleHasher, Tuple input )
 {
 super( Tuple.elements( input ) );
 this.tupleHasher = tupleHasher;
 }

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

/**
 * Method format uses the {@link Formatter} class for formatting this tuples values into a new string.
 *
 * @param format of type String
 * @return String
 */
public String format( String format )
 {
 return String.format( format, elements() );
 }

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

public void writeWith( TupleElementWriter[] writers, Tuple tuple ) throws IOException
 {
 List<Object> elements = Tuple.elements( tuple );
 for( int i = 0; i < writers.length; i++ )
  writers[ i ].write( this, elements.get( i ) );
 }

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

public void writeTyped( Class[] classes, Tuple tuple ) throws IOException
 {
 List<Object> elements = Tuple.elements( tuple );
 for( int i = 0; i < classes.length; i++ )
  {
  Class type = classes[ i ];
  writeTypedElement( type, elements.get( i ) );
  }
 }

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

public static <V> Tuple reset( Tuple tuple, V... values )
 {
 ( (Resettable<V>) Tuple.elements( tuple ) ).reset( values );
 return tuple;
 }
}

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

public <T extends Tuple> T readWith( TupleElementReader[] readers, T tuple ) throws IOException
 {
 List<Object> elements = Tuple.elements( tuple );
 elements.clear();
 for( int i = 0; i < readers.length; i++ )
  {
  Object element = readers[ i ].read( this );
  elements.add( element );
  }
 return tuple;
 }

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

public <T extends Tuple> T readTyped( Class[] classes, T tuple ) throws IOException
 {
 List<Object> elements = Tuple.elements( tuple );
 elements.clear();
 for( int i = 0; i < classes.length; i++ )
  {
  Class type = classes[ i ];
  elements.add( readType( type ) );
  }
 return tuple;
 }

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

@Override
public Object[] current()
 {
 if( current == DUMMY )
  throw new NoSuchElementException();
 return Tuple.elements( current ).toArray( new Object[ current.size() ] );
 }
}

代码示例来源:origin: cascading/cascading-hadoop2-common

@Override
public int hash( Tuple tuple, Hasher[] hashers )
 {
 int hash = 1;
 List<Object> elements = Tuple.elements( tuple );
 for( int i = 0; i < elements.size(); i++ )
  {
  Object element = elements.get( i );
  hash = 31 * hash + ( element != null ? hashers[ i % hashers.length ].hashCode( element ) : 0 );
  }
 return hash;
 }
}

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

public <T extends Tuple> T readUnTyped( T tuple ) throws IOException
 {
 List<Object> elements = Tuple.elements( tuple );
 elements.clear();
 int len = getNumElements();
 for( int i = 0; i < len; i++ )
  elements.add( getNextElement() );
 return tuple;
 }

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

public void writeUnTyped( Tuple tuple ) throws IOException
 {
 List<Object> elements = Tuple.elements( tuple );
 writeIntInternal( elements.size() );
 for( Object element : elements )
  writeElement( element );
 }

代码示例来源:origin: com.hotels/plunger

/** Creates a new {@link Tuple} with the specified values. */
public DataBuilder addTuple(Tuple tuple) {
 newTuple();
 List<Object> elements = Tuple.elements(tuple);
 setTuple(elements.toArray(new Object[elements.size()]));
 return this;
}

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

/**
 * Method add will add the given {@link cascading.tuple.Tuple} to this list.
 *
 * @param tuple of type Tuple
 */
@Override
public boolean add( Tuple tuple )
 {
 doSpill(); // spill if we break over the threshold
 current.add( Tuple.elements( tuple ).toArray( new Object[ tuple.size() ] ) );
 size++;
 return true;
 }

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

public int hash( Tuple tuple, Hasher[] hashers )
 {
 int hash = Murmur3.SEED;
 List<Object> elements = Tuple.elements( tuple );
 for( int i = 0; i < elements.size(); i++ )
  {
  Object element = elements.get( i );
  int hashCode = hashers[ i % hashers.length ].hashCode( element );
  hash = Murmur3.mixH1( hash, Murmur3.mixK1( hashCode ) );
  }
 return Murmur3.fmix( hash, elements.size() );
 }
}

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

/**
 * Method asArray copies the elements of the given Tuple instance to the given Object array.
 *
 * @param tuple       of type Tuple
 * @param destination of type Object[]
 * @return Object[]
 */
public static <T> T[] asArray( Tuple tuple, T[] destination )
 {
 if( tuple.size() != destination.length )
  throw new OperationException( "number of input tuple values: " + tuple.size() + ", does not match destination array size: " + destination.length );
 return tuple.elements( destination );
 }

相关文章