Constant Field Values


Contents
org.apache.*

org.apache.giraph.aggregators.AggregatorWriter
public static final int LAST_SUPERSTEP -1

org.apache.giraph.aggregators.TextAggregatorWriter
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

org.apache.giraph.benchmark.PageRankComputation
public static final String SUPERSTEP_COUNT "giraph.pageRank.superstepCount"

org.apache.giraph.benchmark.RandomMessageBenchmark
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"

org.apache.giraph.benchmark.ShortestPathsComputation
public static final String SOURCE_ID "giraph.shortestPathsBenchmark.sourceId"
public static final long SOURCE_ID_DEFAULT 1L

org.apache.giraph.benchmark.WeightedPageRankComputation
public static final String SUPERSTEP_COUNT "giraph.weightedPageRank.superstepCount"

org.apache.giraph.bsp.BspService<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
public static final String ADDRESSES_AND_PARTITIONS_DIR "/_addressesAndPartitions"
public static final String APPLICATION_ATTEMPTS_DIR "/_applicationAttemptsDir"
public static final String BASE_DIR "/_hadoopBsp"
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"
public static final String CLEANED_UP_DIR "/_cleanedUpDir"
public static final String EDGE_INPUT_SPLIT_DIR "/_edgeInputSplitDir"
public static final String EDGE_INPUT_SPLIT_DONE_DIR "/_edgeInputSplitDoneDir"
public static final String EDGE_INPUT_SPLIT_FINISHED_NODE "/_edgeInputSplitFinished"
public static final String EDGE_INPUT_SPLIT_RESERVED_NODE "/_edgeInputSplitReserved"
public static final String EDGE_INPUT_SPLITS_ALL_DONE_NODE "/_edgeInputSplitsAllDone"
public static final String EDGE_INPUT_SPLITS_ALL_READY_NODE "/_edgeInputSplitsAllReady"
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_MESSAGES_KEY "_numMsgsKey"
public static final String JSONOBJ_PARTITION_STATS_KEY "_partitionStatsKey"
public static final String JSONOBJ_STATE_KEY "_stateKey"
public static final String JSONOBJ_SUPERSTEP_KEY "_superstepKey"
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 MERGED_AGGREGATOR_DIR "/_mergedAggregatorDir"
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 VERTEX_INPUT_SPLIT_DIR "/_vertexInputSplitDir"
public static final String VERTEX_INPUT_SPLIT_DONE_DIR "/_vertexInputSplitDoneDir"
public static final String VERTEX_INPUT_SPLIT_FINISHED_NODE "/_vertexInputSplitFinished"
public static final String VERTEX_INPUT_SPLIT_RESERVED_NODE "/_vertexInputSplitReserved"
public static final String VERTEX_INPUT_SPLITS_ALL_DONE_NODE "/_vertexInputSplitsAllDone"
public static final String VERTEX_INPUT_SPLITS_ALL_READY_NODE "/_vertexInputSplitsAllReady"
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"

org.apache.giraph.comm.aggregators.AggregatorUtils
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 SPECIAL_COUNT_AGGREGATOR "__aggregatorRequestCount"
public static final String USE_THREAD_LOCAL_AGGREGATORS "giraph.useThreadLocalAggregators"
public static final boolean USE_THREAD_LOCAL_AGGREGATORS_DEFAULT false

org.apache.giraph.comm.netty.ByteCounter
public static final double MEGABYTE 1048576.0

org.apache.giraph.comm.netty.NettyClient
public static final String LIMIT_NUMBER_OF_OPEN_REQUESTS "giraph.waitForRequestsConfirmation"
public static final boolean LIMIT_NUMBER_OF_OPEN_REQUESTS_DEFAULT false
public static final int MAX_CONNECTION_MILLISECONDS_DEFAULT 30000
public static final int MAX_DESTINATION_TASK_IDS_TO_LIST 10
public static final String MAX_NUMBER_OF_OPEN_REQUESTS "giraph.maxNumberOfOpenRequests"
public static final int MAX_NUMBER_OF_OPEN_REQUESTS_DEFAULT 10000
public static final int MAX_REQUESTS_TO_LIST 10

org.apache.giraph.comm.netty.NettyServer
public static final int MAXIMUM_THREAD_POOL_SIZE_DEFAULT 32

org.apache.giraph.comm.netty.handler.RequestServerHandler<R>
public static final int RESPONSE_BYTES 13

org.apache.giraph.comm.requests.WritableRequest<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
public static final int UNKNOWN_SIZE -1

org.apache.giraph.conf.GiraphConstants
public static final String BASE_ZNODE_KEY "giraph.zkBaseZNode"
public static final int DEFAULT_ZOOKEEPER_INIT_LIMIT 10
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_SYNC_LIMIT 5
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 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_DIR "giraph.zkDir"
public static final String ZOOKEEPER_JAR "giraph.zkJar"
public static final String ZOOKEEPER_LIST "giraph.zkList"

org.apache.giraph.counters.GiraphStats
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 SENT_MESSAGES_NAME "Sent messages"
public static final String SUPERSTEP_NAME "Superstep"
public static final String VERTICES_NAME "Aggregate vertices"

org.apache.giraph.counters.GiraphTimers
public static final String GROUP_NAME "Giraph Timers"
public static final String SETUP_MS_NAME "Setup (milliseconds)"
public static final String SHUTDOWN_MS_NAME "Shutdown (milliseconds)"
public static final String TOTAL_MS_NAME "Total (milliseconds)"

org.apache.giraph.examples.GeneratedVertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
public static final boolean DEAFULT_REVERSE_ID_ORDER false
public static final long DEFAULT_READER_VERTICES 10L
public static final String READER_VERTICES "GeneratedVertexReader.reader_vertices"
public static final String REVERSE_ID_ORDER "GeneratedVertexReader.reverseIdOrder"

org.apache.giraph.examples.SimpleCheckpoint
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"

org.apache.giraph.examples.SimpleCheckpoint.SimpleCheckpointVertexWorkerContext
public static final String FAULT_FILE "/tmp/faultFile"

org.apache.giraph.examples.SimpleMasterComputeComputation
public static final String SMC_AGG "simplemastercompute.aggregator"

org.apache.giraph.examples.SimplePageRankComputation
public static final int MAX_SUPERSTEPS 30

org.apache.giraph.examples.SimpleVertexWithWorkerContext
public static final String OUTPUTDIR "svwwc.outputdir"

org.apache.giraph.examples.TestComputationStateComputation
public static final int NUM_COMPUTE_THREADS 10
public static final int NUM_PARTITIONS 25
public static final int NUM_VERTICES 100

org.apache.giraph.examples.VerifyMessage.VerifyMessageComputation
public static final String SUPERSTEP_COUNT "verifyMessageVertex.superstepCount"

org.apache.giraph.graph.GiraphTransferRegulator
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

org.apache.giraph.graph.GraphTaskManager<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
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_TIME "superstep-time-ms"
public static final String TIMER_TIME_TO_FIRST_MSG "time-to-first-message-ms"

org.apache.giraph.io.formats.AdjacencyListTextVertexInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
public static final String LINE_TOKENIZE_VALUE "adj.list.input.delimiter"
public static final String LINE_TOKENIZE_VALUE_DEFAULT "\t"

org.apache.giraph.io.formats.AdjacencyListTextVertexOutputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
public static final String LINE_TOKENIZE_VALUE "output.delimiter"
public static final String LINE_TOKENIZE_VALUE_DEFAULT "\t"

org.apache.giraph.io.formats.GiraphFileInputFormat<K,V>
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"

org.apache.giraph.io.formats.IdWithValueTextOutputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
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

org.apache.giraph.io.formats.JsonBase64VertexFormat
public static final String EDGE_ARRAY_KEY "edgeArray"
public static final String VERTEX_ID_KEY "vertexId"
public static final String VERTEX_VALUE_KEY "vertexValue"

org.apache.giraph.io.formats.PseudoRandomInputFormatConstants
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

org.apache.giraph.master.BspServiceMaster<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
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"

org.apache.giraph.master.MasterThread<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
public static final String GIRAPH_TIMERS_COUNTER_GROUP_NAME "Giraph Timers"

org.apache.giraph.metrics.AggregatedMetrics
public static final String USER_COMPUTE_MS "user-compute-ms"

org.apache.giraph.metrics.MetricNames
public static final String EDGES_FILTERED "edges-filtered"
public static final String EDGES_FILTERED_PCT "edges-filtered-pct"
public static final String LOCAL_REQUESTS "local-requests"
public static final String MEMORY_FREE_PERCENT "memory-free-pct"
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 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"

org.apache.giraph.partition.PartitionBalancer
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"

org.apache.giraph.time.Time
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

org.apache.giraph.utils.IncreasingBitSet
public static final int MIN_BITS_TO_SHIFT 65536

org.apache.giraph.utils.InternalVertexRunner
public static final int LOCAL_ZOOKEEPER_PORT 22182

org.apache.giraph.utils.JMap
public static final String ARGS " -histo "
public static final String CMD "jmap "

org.apache.giraph.utils.MasterLoggingAggregator
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

org.apache.giraph.utils.UnsafeByteArrayOutputStream
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_MEDIUM 3
public static final int SIZE_OF_SHORT 2

org.apache.giraph.worker.BspServiceWorker<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
public static final String TIMER_WAIT_REQUESTS "wait-requests-us"

org.apache.giraph.worker.EdgeInputSplitsCallable<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
public static final int EDGES_FILTERED_UPDATE_PERIOD 10000
public static final int EDGES_UPDATE_PERIOD 1000000

org.apache.giraph.worker.VertexInputSplitsCallable<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
public static final int VERTICES_FILTERED_UPDATE_PERIOD 2500
public static final int VERTICES_UPDATE_PERIOD 250000



Copyright © 2011-2013 The Apache Software Foundation. All Rights Reserved.