This project has retired. For details please refer to its Attic page.

org.apache.crunch
Class CombineFn.StringConcatAggregator

java.lang.Object
  org.apache.crunch.CombineFn.StringConcatAggregator

All Implemented Interfaces:

Serializable, CombineFn.Aggregator<String>

Enclosing class:

CombineFn<S,T>

public static class CombineFn.StringConcatAggregator
extends Object
implements CombineFn.Aggregator<String>

See Also:

Serialized Form

Constructor Summary

CombineFn.StringConcatAggregator(String separator, boolean skipNulls)

CombineFn.StringConcatAggregator(String separator, boolean skipNull, long maxOutputLength, long maxInputLength)

Method Summary

void	reset() Clears the internal state of this Aggregator and prepares it for the values associated with the next key.
Iterable<String>	results() Returns the current aggregated state of this instance.
void	update(String next) Incorporate the given value into the aggregate state maintained by this instance.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CombineFn.StringConcatAggregator

public CombineFn.StringConcatAggregator(String separator,
                                        boolean skipNulls)

CombineFn.StringConcatAggregator

public CombineFn.StringConcatAggregator(String separator,
                                        boolean skipNull,
                                        long maxOutputLength,
                                        long maxInputLength)

Method Detail

reset

public void reset()

Description copied from interface: CombineFn.Aggregator

Clears the internal state of this Aggregator and prepares it for the values associated with the next key.

Specified by:

reset in interface CombineFn.Aggregator<String>

update

public void update(String next)

Description copied from interface: CombineFn.Aggregator

Incorporate the given value into the aggregate state maintained by this instance.

Specified by:

update in interface CombineFn.Aggregator<String>

results

public Iterable<String> results()

Description copied from interface: CombineFn.Aggregator

Returns the current aggregated state of this instance.

Specified by:

results in interface CombineFn.Aggregator<String>