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