public interface StreamComparator<T extends InputStream>
InputStreaminstances to be compared, typically bit-wise. This is most useful when defining custom types to be stored in
Tupleinstances and the values will need to be grouped on and/or secondary sorted (via
CoGroup) and the underlying serialization implementation enables a useful bit-wise comparison without deserializing the custom type into memory. Typically this interface is used to mark a
Comparatoras additionally supporting the ability to compare raw streams in tandem with comparing Object instances. Thus concrete implementations should implement this interface and the Comparator interface when being used as a "grouping" or "sorting" field Comparator When used with Hadoop, a
BufferedInputStreamis passed into the
compare(java.io.InputStream, java.io.InputStream)method. This class gives access to the underlying byte array so each individual byte need to be
InputStream.read(). So it is useful to declare an implementation as
public class YourCustomComparator implements StreamComparator<BufferedInputStream>, Comparator<YourCustomType>, SerializableNote the method
BufferedInputStreamwill need to be called with the number of bytes read from the underlying byte buffer before the compare() method returns.
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.