I
- Vertex idV
- Vertex valueE
- Edge valuepublic class InMemoryEdgeStoreFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> extends Object implements EdgeStoreFactory<I,V,E>
Modifier and Type | Field and Description |
---|---|
protected ImmutableClassesGiraphConfiguration<I,V,E> |
conf
Giraph configuration.
|
protected org.apache.hadoop.util.Progressable |
progressable
Progressable to report progress.
|
protected CentralizedServiceWorker<I,V,E> |
service
Service worker.
|
Constructor and Description |
---|
InMemoryEdgeStoreFactory() |
Modifier and Type | Method and Description |
---|---|
void |
initialize(CentralizedServiceWorker<I,V,E> service,
ImmutableClassesGiraphConfiguration<I,V,E> conf,
org.apache.hadoop.util.Progressable progressable)
Implementation class should use this method of initialization
of any required internal state.
|
EdgeStore<I,V,E> |
newStore()
Creates new edge store.
|
protected CentralizedServiceWorker<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> service
protected ImmutableClassesGiraphConfiguration<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> conf
protected org.apache.hadoop.util.Progressable progressable
public EdgeStore<I,V,E> newStore()
EdgeStoreFactory
newStore
in interface EdgeStoreFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
public void initialize(CentralizedServiceWorker<I,V,E> service, ImmutableClassesGiraphConfiguration<I,V,E> conf, org.apache.hadoop.util.Progressable progressable)
EdgeStoreFactory
initialize
in interface EdgeStoreFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
service
- Service to get partition mappingsconf
- Configurationprogressable
- ProgressableCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.