Package | Description |
---|---|
org.apache.giraph.bsp |
Package of generic bulk synchronous processing objects.
|
org.apache.giraph.utils |
Package of all generic utility classes.
|
org.apache.giraph.worker |
Package of all the worker related things
|
org.apache.giraph.writable.kryo |
Utilities for using Kryo to efficiently serialize objects,
and integrate with Writable interface.
|
org.apache.giraph.zk |
Package of
ZooKeeper related objects. |
Modifier and Type | Method and Description |
---|---|
ZooKeeperExt |
BspService.getZkExt()
Get the ZooKeeperExt instance.
|
Modifier and Type | Method and Description |
---|---|
static void |
WritableUtils.readFieldsFromZnode(ZooKeeperExt zkExt,
String zkPath,
boolean watch,
org.apache.zookeeper.data.Stat stat,
org.apache.hadoop.io.Writable... writableObjects)
Read fields from a ZooKeeper znode.
|
static <T extends org.apache.hadoop.io.Writable> |
WritableUtils.readListFieldsFromZnode(ZooKeeperExt zkExt,
String zkPath,
boolean watch,
org.apache.zookeeper.data.Stat stat,
Class<? extends T> writableClass,
org.apache.hadoop.conf.Configuration conf)
Read fields from a ZooKeeper znode into a list of objects.
|
static ZooKeeperExt.PathStat |
WritableUtils.writeListToZnode(ZooKeeperExt zkExt,
String zkPath,
int version,
List<? extends org.apache.hadoop.io.Writable> writableList)
Write list of objects to a ZooKeeper znode.
|
static ZooKeeperExt.PathStat |
WritableUtils.writeToZnode(ZooKeeperExt zkExt,
String zkPath,
int version,
org.apache.hadoop.io.Writable... writableObjects)
Write object to a ZooKeeper znode.
|
Constructor and Description |
---|
MemoryObserver(ZooKeeperExt zk,
String zkPath,
GiraphConfiguration conf)
Constructor
|
Modifier and Type | Method and Description |
---|---|
static void |
GiraphClassResolver.setZookeeperInfo(ZooKeeperExt zookeeperExt,
String kryoClassPath)
Sets zookeeper informaton.
|
Modifier and Type | Method and Description |
---|---|
void |
GiraphZooKeeperAdmin.doZooKeeperCleanup(ZooKeeperExt zooKeeper,
String zkBasePath)
Cleans the ZooKeeper quorum of in-memory failed/killed job fragments.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.