Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
LAST_SUPERSTEP |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ALWAYS |
1 |
public static final int |
AT_THE_END |
-1 |
public static final String |
FILENAME |
"giraph.textAggregatorWriter.filename" |
public static final String |
FREQUENCY |
"giraph.textAggregatorWriter.frequency" |
public static final int |
NEVER |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SUPERSTEP_COUNT |
"giraph.pageRank.superstepCount" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
AGG_SUPERSTEP_TOTAL_BYTES |
"superstep total bytes sent" |
public static final String |
AGG_SUPERSTEP_TOTAL_MESSAGES |
"superstep total messages" |
public static final String |
AGG_SUPERSTEP_TOTAL_MILLIS |
"superstep total millis" |
public static final String |
AGG_TOTAL_BYTES |
"total bytes sent" |
public static final String |
AGG_TOTAL_MESSAGES |
"total messages" |
public static final String |
AGG_TOTAL_MILLIS |
"total millis" |
public static final int |
DEFAULT_NUM_BYTES_PER_MESSAGE |
16 |
public static final int |
DEFAULT_NUM_MESSAGES_PER_EDGE |
1 |
public static final String |
NUM_BYTES_PER_MESSAGE |
"giraph.randomMessageBenchmark.numBytesPerMessage" |
public static final String |
NUM_MESSAGES_PER_EDGE |
"giraph.randomMessageBenchmark.numMessagesPerEdge" |
public static final String |
SUPERSTEP_COUNT |
"giraph.randomMessageBenchmark.superstepCount" |
public static final String |
WORKERS_NUM |
"workers" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SOURCE_ID |
"giraph.shortestPathsBenchmark.sourceId" |
public static final long |
SOURCE_ID_DEFAULT |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SUPERSTEP_COUNT |
"giraph.weightedPageRank.superstepCount" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
GROUP |
"Blocks Framework" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
REDUCER_COUNT |
39989 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
APPLICATION_ATTEMPTS_DIR |
"/_applicationAttemptsDir" |
public static final String |
BASE_DIR |
"/_hadoopBsp" |
public static final String |
CLEANED_UP_DIR |
"/_cleanedUpDir" |
public static final String |
COUNTERS_DIR |
"/_counters" |
public static final String |
FORCE_CHECKPOINT_USER_FLAG |
"/_checkpointAndStop" |
public static final String |
HALT_COMPUTATION_NODE |
"/_haltComputation" |
public static final String |
INPUT_SPLITS_ALL_DONE_NODE |
"/_inputSplitsAllDone" |
public static final String |
INPUT_SPLITS_WORKER_DONE_DIR |
"/_inputSplitsWorkerDoneDir" |
public static final long |
INPUT_SUPERSTEP |
-1L |
public static final String |
JSONOBJ_APPLICATION_ATTEMPT_KEY |
"_applicationAttemptKey" |
public static final String |
JSONOBJ_METRICS_KEY |
"_metricsKey" |
public static final String |
JSONOBJ_NUM_MESSAGE_BYTES_KEY |
"_numMsgBytesKey" |
public static final String |
JSONOBJ_NUM_MESSAGES_KEY |
"_numMsgsKey" |
public static final String |
JSONOBJ_STATE_KEY |
"_stateKey" |
public static final String |
JSONOBJ_SUPERSTEP_KEY |
"_superstepKey" |
public static final String |
KRYO_REGISTERED_CLASS_DIR |
"/_kryo" |
public static final String |
MASTER_ELECTION_DIR |
"/_masterElectionDir" |
public static final String |
MASTER_JOB_STATE_NODE |
"/_masterJobState" |
public static final String |
MASTER_SUFFIX |
"_master" |
public static final String |
MEMORY_OBSERVER_DIR |
"/_memoryObserver" |
public static final String |
METRICS_DIR |
"/_metrics" |
public static final String |
PARTITION_EXCHANGE_DIR |
"/_partitionExchangeDir" |
public static final String |
SUPERSTEP_DIR |
"/_superstepDir" |
public static final String |
SUPERSTEP_FINISHED_NODE |
"/_superstepFinished" |
public static final long |
UNSET_APPLICATION_ATTEMPT |
-9223372036854775808L |
public static final long |
UNSET_SUPERSTEP |
-9223372036854775808L |
public static final String |
WORKER_FINISHED_DIR |
"/_workerFinishedDir" |
public static final String |
WORKER_HEALTHY_DIR |
"/_workerHealthyDir" |
public static final String |
WORKER_SUFFIX |
"_worker" |
public static final String |
WORKER_UNHEALTHY_DIR |
"/_workerUnhealthyDir" |
public static final String |
WORKER_WROTE_CHECKPOINT_DIR |
"/_workerWroteCheckpointDir" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
MAX_BYTES_PER_AGGREGATOR_REQUEST |
"giraph.maxBytesPerAggregatorRequest" |
public static final int |
MAX_BYTES_PER_AGGREGATOR_REQUEST_DEFAULT |
1048576 |
public static final String |
USE_THREAD_LOCAL_AGGREGATORS |
"giraph.useThreadLocalAggregators" |
public static final boolean |
USE_THREAD_LOCAL_AGGREGATORS_DEFAULT |
false |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final double |
MEGABYTE |
1048576.0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAX_CONNECTION_MILLISECONDS_DEFAULT |
30000 |
public static final int |
MAX_DESTINATION_TASK_IDS_TO_LIST |
10 |
public static final int |
MAX_REQUESTS_TO_LIST |
10 |
public static final String |
NETTY_COUNTERS_GROUP |
"Netty counters" |
public static final String |
NETWORK_REQUESTS_RESENT_FOR_CHANNEL_FAILURE_NAME |
"Network requests resent for channel failure" |
public static final String |
NETWORK_REQUESTS_RESENT_FOR_CONNECTION_FAILURE_NAME |
"Network requests resent for connection or request failure" |
public static final String |
NETWORK_REQUESTS_RESENT_FOR_TIMEOUT_NAME |
"Network requests resent for timeout" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAXIMUM_THREAD_POOL_SIZE_DEFAULT |
32 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
RESPONSE_BYTES |
16 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
UNKNOWN_SIZE |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BASE_ZNODE_KEY |
"giraph.zkBaseZNode" |
public static final int |
DEFAULT_ZOOKEEPER_MAX_CLIENT_CNXNS |
10000 |
public static final int |
DEFAULT_ZOOKEEPER_SNAP_COUNT |
50000 |
public static final int |
DEFAULT_ZOOKEEPER_TICK_TIME |
6000 |
public static final String |
GIRAPH_YARN_CONF_FILE |
"giraph-conf.xml" |
public static final int |
GIRAPH_YARN_PRIORITY |
10 |
public static final int |
GIRAPH_YARN_TASK_HEAP_MB_DEFAULT |
1024 |
public static final String |
MAX_WORKERS |
"giraph.maxWorkers" |
public static final String |
MIN_WORKERS |
"giraph.minWorkers" |
public static final String |
MSG_NUM_FLUSH_THREADS |
"giraph.msgNumFlushThreads" |
public static final int |
ONE_KB |
1024 |
public static final int |
ONE_MB |
1048576 |
public static final String |
PARTITION_VERTEX_KEY_SPACE_SIZE |
"giraph.vertexKeySpaceSize" |
public static final String |
RESTART_SUPERSTEP |
"giraph.restartSuperstep" |
public static final String |
YOURKIT_OUTPUT_DIR |
"giraph.yourkit.outputDir" |
public static final String |
YOURKIT_OUTPUT_DIR_DEFAULT |
"/tmp/giraph/%JOB_ID%/%TASK_ID%" |
public static final String |
ZOOKEEPER_BASE_PATH_COUNTER_GROUP |
"Zookeeper base path" |
public static final String |
ZOOKEEPER_DIR |
"giraph.zkDir" |
public static final String |
ZOOKEEPER_HALT_NODE_COUNTER_GROUP |
"Zookeeper halt node" |
public static final int |
ZOOKEEPER_PURGE_INTERVAL |
1 |
public static final String |
ZOOKEEPER_SERVER_PORT_COUNTER_GROUP |
"Zookeeper server:port" |
public static final int |
ZOOKEEPER_SNAP_RETAIN_COUNT |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
AGGREGATE_SENT_MESSAGE_BYTES_NAME |
"Aggregate sent message bytes" |
public static final String |
AGGREGATE_SENT_MESSAGES_NAME |
"Aggregate sent messages" |
public static final String |
CURRENT_MASTER_PARTITION_TASK_NAME |
"Current master task partition" |
public static final String |
CURRENT_WORKERS_NAME |
"Current workers" |
public static final String |
EDGES_NAME |
"Aggregate edges" |
public static final String |
FINISHED_VERTICES_NAME |
"Aggregate finished vertices" |
public static final String |
GROUP_NAME |
"Giraph Stats" |
public static final String |
LAST_CHECKPOINTED_SUPERSTEP_NAME |
"Last checkpointed superstep" |
public static final String |
LOWEST_GRAPH_PERCENTAGE_IN_MEMORY_NAME |
"Lowest percentage of graph in memory so far (out-of-core)" |
public static final String |
OOC_BYTES_LOADED_NAME |
"Aggregate bytes loaded from local disks (out-of-core)" |
public static final String |
OOC_BYTES_STORED_NAME |
"Aggregate bytes stored to local disks (out-of-core)" |
public static final String |
SENT_MESSAGE_BYTES_NAME |
"Sent message bytes" |
public static final String |
SENT_MESSAGES_NAME |
"Sent messages" |
public static final String |
SUPERSTEP_NAME |
"Superstep" |
public static final String |
VERTICES_NAME |
"Aggregate vertices" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
GROUP_NAME |
"Giraph Timers" |
public static final String |
INITIALIZE_MS_NAME |
"Initialize (ms)" |
public static final String |
SETUP_MS_NAME |
"Setup (ms)" |
public static final String |
SHUTDOWN_MS_NAME |
"Shutdown (ms)" |
public static final String |
TOTAL_MS_NAME |
"Total (ms)" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAX_SUPERSTEPS |
30 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ENABLE_FAULT |
"simpleCheckpointVertex.enableFault" |
public static final int |
FAULTING_SUPERSTEP |
4 |
public static final long |
FAULTING_VERTEX_ID |
1L |
public static final String |
SUPERSTEP_COUNT |
"simpleCheckpointVertex.superstepCount" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FAULT_FILE |
"/tmp/faultFile" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SMC_AGG |
"simplemastercompute.aggregator" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAX_SUPERSTEPS |
30 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
OUTPUTDIR |
"svwwc.outputdir" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
NUM_COMPUTE_THREADS |
10 |
public static final int |
NUM_PARTITIONS |
25 |
public static final int |
NUM_VERTICES |
100 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SUPERSTEP_COUNT |
"verifyMessageVertex.superstepCount" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SMC_AGG |
"simplemastercompute.aggregator" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONVERGED |
"scccompute.converged" |
public static final String |
NEW_MAXIMUM |
"scccompute.max" |
public static final String |
PHASE |
"scccompute.phase" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
ACK |
4L |
public static final long |
CTRL_IN_EDGE |
16L |
public static final long |
DONE |
8L |
public static final long |
GRANT |
2L |
public static final long |
NOTIFY |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
MAX_EDGES_PER_TRANSFER |
"giraph.maxEdgesPerTransfer" |
public static final int |
MAX_EDGES_PER_TRANSFER_DEFAULT |
80000 |
public static final String |
MAX_VERTICES_PER_TRANSFER |
"giraph.maxVerticesPerTransfer" |
public static final int |
MAX_VERTICES_PER_TRANSFER_DEFAULT |
10000 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
TIMER_COMMUNICATION_TIME |
"communication-time-ms" |
public static final String |
TIMER_COMPUTE_ALL |
"compute-all-ms" |
public static final String |
TIMER_SUPERSTEP_GC_TIME |
"superstep-gc-time-ms" |
public static final String |
TIMER_SUPERSTEP_TIME |
"superstep-time-ms" |
public static final String |
TIMER_TIME_TO_FIRST_MSG |
"time-to-first-message-ms" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
LINE_TOKENIZE_VALUE |
"adj.list.input.delimiter" |
public static final String |
LINE_TOKENIZE_VALUE_DEFAULT |
"\t" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
LINE_TOKENIZE_VALUE |
"output.delimiter" |
public static final String |
LINE_TOKENIZE_VALUE_DEFAULT |
"\t" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EDGE_INPUT_DIR |
"giraph.edge.input.dir" |
public static final String |
NUM_EDGE_INPUT_FILES |
"giraph.input.edge.num.files" |
public static final String |
NUM_VERTEX_INPUT_FILES |
"giraph.input.vertex.num.files" |
public static final String |
VERTEX_INPUT_DIR |
"giraph.vertex.input.dir" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
LINE_TOKENIZE_VALUE |
"output.delimiter" |
public static final String |
LINE_TOKENIZE_VALUE_DEFAULT |
"\t" |
public static final String |
REVERSE_ID_AND_VALUE |
"reverse.id.and.value" |
public static final boolean |
REVERSE_ID_AND_VALUE_DEFAULT |
false |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EDGE_ARRAY_KEY |
"edgeArray" |
public static final String |
VERTEX_ID_KEY |
"vertexId" |
public static final String |
VERTEX_VALUE_KEY |
"vertexValue" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
AGGREGATE_VERTICES |
"giraph.pseudoRandomInputFormat.aggregateVertices" |
public static final String |
EDGES_PER_VERTEX |
"giraph.pseudoRandomInputFormat.edgesPerVertex" |
public static final String |
LOCAL_EDGES_MIN_RATIO |
"giraph.pseudoRandomInputFormat.localEdgesMinRatio" |
public static final float |
LOCAL_EDGES_MIN_RATIO_DEFAULT |
0.0f |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_INPUT_SPLIT_THREAD_COUNT |
1 |
public static final int |
MAX_PRINTABLE_REMAINING_WORKERS |
10 |
public static final String |
NUM_MASTER_ZK_INPUT_SPLIT_THREADS |
"giraph.numMasterZkInputSplitThreads" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MASTER_TASK_ID |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
GIRAPH_TIMERS_COUNTER_GROUP_NAME |
"Giraph Timers" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EDGES_FILTERED |
"edges-filtered" |
public static final String |
EDGES_FILTERED_PCT |
"edges-filtered-pct" |
public static final String |
HISTOGRAM_COMPUTE_PER_PARTITION |
"compute-per-partition-ms" |
public static final String |
LOCAL_REQUESTS |
"local-requests" |
public static final String |
MEMORY_FREE_PERCENT |
"memory-free-pct" |
public static final String |
MESSAGE_BYTES_SENT |
"message-bytes-sent" |
public static final String |
MESSAGES_SENT |
"messages-sent" |
public static final String |
PERCENT_LOCAL_REQUESTS |
"percent-local-requests" |
public static final String |
RECEIVED_BYTES |
"received-bytes" |
public static final String |
REMOTE_REQUESTS |
"remote-requests" |
public static final String |
SEND_AGGREGATORS_TO_MASTER_REQUESTS |
"send-aggregators-to-master-requests" |
public static final String |
SEND_AGGREGATORS_TO_OWNER_REQUESTS |
"send-aggregators-to-owner-requests" |
public static final String |
SEND_AGGREGATORS_TO_WORKER_REQUESTS |
"send-aggregators-to-worker-requests" |
public static final String |
SEND_PARTITION_CURRENT_MESSAGES_REQUESTS |
"send-partition-current-messages-requests" |
public static final String |
SEND_PARTITION_MUTATIONS_REQUESTS |
"send-partition-mutations-requests" |
public static final String |
SEND_VERTEX_REQUESTS |
"send-vertex-requests" |
public static final String |
SEND_WORKER_AGGREGATORS_REQUESTS |
"send-worker-aggregators-requests" |
public static final String |
SEND_WORKER_MESSAGES_REQUESTS |
"send-worker-messages-requests" |
public static final String |
SENT_BYTES |
"sent-bytes" |
public static final String |
TIME_SPENT_WAITING_ON_TOO_MANY_OPEN_REQUESTS_MS |
"time-spent-waiting-on-too-many-open-requests-ms" |
public static final String |
TOTAL_REQUESTS |
"total-requests" |
public static final String |
VERTICES_FILTERED |
"vertices-filtered" |
public static final String |
VERTICES_FILTERED_PCT |
"vertices-filtered-pct" |
public static final String |
VERTICES_IN_MUTATION_REQUEST |
"vertices-per-mutations-request" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CHECK_IN_INTERVAL |
1023 |
public static final String |
GRAPH_PERCENTAGE_IN_MEMORY |
"ooc-graph-in-mem-%" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BYTES_LOAD_FROM_DISK |
"ooc-bytes-load" |
public static final String |
BYTES_STORE_TO_DISK |
"ooc-bytes-store" |
public static final String |
HISTOGRAM_LOAD_SIZE |
"ooc-load-size-bytes" |
public static final String |
HISTOGRAM_STORE_SIZE |
"ooc-store-size-bytes" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
NO_PARTITION_TO_PROCESS |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EGDE_BALANCE_ALGORITHM |
"edges" |
public static final String |
PARTITION_BALANCE_ALGORITHM |
"hash.partitionBalanceAlgorithm" |
public static final String |
STATIC_BALANCE_ALGORITHM |
"static" |
public static final String |
VERTICES_BALANCE_ALGORITHM |
"vertices" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
MS_PER_DAY |
86400000L |
public static final long |
MS_PER_HOUR |
3600000L |
public static final long |
MS_PER_SECOND |
1000L |
public static final float |
MS_PER_SECOND_AS_FLOAT |
1000.0f |
public static final long |
NS_PER_MS |
1000000L |
public static final long |
NS_PER_SECOND |
1000000000L |
public static final float |
NS_PER_SECOND_AS_FLOAT |
1.0E9f |
public static final long |
NS_PER_US |
1000L |
public static final long |
SECONDS_PER_DAY |
86400L |
public static final long |
SECONDS_PER_HOUR |
3600L |
public static final long |
US_PER_MS |
1000L |
public static final long |
US_PER_SECOND |
1000000L |
public static final float |
US_PER_SECOND_AS_FLOAT |
1000000.0f |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
MAX_OPEN_HASHSET_CAPACITY |
800000000L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SIZE_OF_BOOLEAN |
1 |
public static final int |
SIZE_OF_BYTE |
1 |
public static final int |
SIZE_OF_CHAR |
2 |
public static final int |
SIZE_OF_DOUBLE |
8 |
public static final int |
SIZE_OF_FLOAT |
4 |
public static final int |
SIZE_OF_INT |
4 |
public static final int |
SIZE_OF_LONG |
8 |
public static final int |
SIZE_OF_SHORT |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CHECKPOINT_DATA_POSTFIX |
".data" |
public static final String |
CHECKPOINT_FINALIZED_POSTFIX |
".finalized" |
public static final String |
CHECKPOINT_METADATA_POSTFIX |
".metadata" |
public static final String |
CHECKPOINT_VALID_POSTFIX |
".valid" |
public static final String |
CHECKPOINT_VERTICES_POSTFIX |
".vertices" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MIN_BITS_TO_SHIFT |
65536 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ARGS |
" -histo " |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
MASTER_LOGGING_AGGREGATOR_NAME |
"masterLoggingAggregator" |
public static final String |
USE_MASTER_LOGGING_AGGREGATOR |
"giraph.useMasterLoggingAggregator" |
public static final boolean |
USE_MASTER_LOGGING_AGGREGATOR_DEFAULT |
false |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
TIMER_WAIT_REQUESTS |
"wait-requests-us" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
EDGES_FILTERED_UPDATE_PERIOD |
10000 |
public static final int |
EDGES_UPDATE_PERIOD |
1000000 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
VERTICES_FILTERED_UPDATE_PERIOD |
2500 |
public static final int |
VERTICES_UPDATE_PERIOD |
250000 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SEQUENCE_NUMBER_LENGTH |
10 |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.