org.apache.giraph.io.filters

Class DefaultEdgeInputFilter<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,org.apache.hadoop.io.Writable,E>

org.apache.giraph.io.filters.DefaultEdgeInputFilter<I,E>

Type Parameters:

I - Vertex ID

E - Edge Value

All Implemented Interfaces:

GiraphConfigurationSettable<I,org.apache.hadoop.io.Writable,E>, ImmutableClassesGiraphConfigurable<I,org.apache.hadoop.io.Writable,E>, EdgeInputFilter<I,E>

public class DefaultEdgeInputFilter<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
extends DefaultImmutableClassesGiraphConfigurable<I,org.apache.hadoop.io.Writable,E>
implements EdgeInputFilter<I,E>

Default edge filter that lets in all edges.

Constructor Summary

Constructors

Constructor and Description
DefaultEdgeInputFilter()

Method Summary

Modifier and Type	Method and Description
boolean	dropEdge(I sourceId, Edge<I,E> edge) Whether to drop this edge

Methods inherited from class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

getConf, setConf

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultEdgeInputFilter

public DefaultEdgeInputFilter()

Method Detail

dropEdge

public boolean dropEdge(I sourceId,
                        Edge<I,E> edge)

Description copied from interface: EdgeInputFilter

Whether to drop this edge

Specified by:

dropEdge in interface EdgeInputFilter<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>

Parameters:

sourceId - ID of source of edge

edge - to check

Returns:

true if we should drop the edge