Constant Field Values

Contents

• org.apache.*

org.apache.*

org.apache.nemo.common.dag.DAG<V extends Vertex,E extends Edge<V>>

Modifier and Type	Constant Field	Value
public static final java.lang.String	EMPTY_DAG_DIRECTORY	""

org.apache.nemo.common.ir.edge.executionproperty.PartitionerProperty

Modifier and Type	Constant Field	Value
public static final int	NUM_EQUAL_TO_DST_PARALLELISM	0

org.apache.nemo.common.ir.vertex.executionproperty.ResourcePriorityProperty

Modifier and Type	Constant Field	Value
public static final java.lang.String	COMPUTE	"Compute"
public static final java.lang.String	NONE	"None"
public static final java.lang.String	RESERVED	"Reserved"
public static final java.lang.String	TRANSIENT	"Transient"

org.apache.nemo.common.test.ExampleTestArgs

Modifier and Type	Constant Field	Value
public static final int	TIMEOUT	500000

org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.SkewAnnotatingPass

Modifier and Type	Constant Field	Value
public static final int	HASH_RANGE_MULTIPLIER	5

org.apache.nemo.examples.beam.BeamWordCount

Modifier and Type	Constant Field	Value
public static final java.lang.String	TOKENIZER_PATTERN	"[^\\p{L}]+"

org.apache.nemo.examples.beam.WindowedWordCount

Modifier and Type	Constant Field	Value
public static final java.lang.String	INPUT_TYPE_BOUNDED	"bounded"
public static final java.lang.String	INPUT_TYPE_UNBOUNDED	"unbounded"

org.apache.nemo.runtime.common.comm.ControlMessage.BlockLocationInfoMsg

Modifier and Type	Constant Field	Value
public static final int	BLOCKID_FIELD_NUMBER	2
public static final int	OWNEREXECUTORID_FIELD_NUMBER	4
public static final int	REQUESTID_FIELD_NUMBER	1
public static final int	STATE_FIELD_NUMBER	3

org.apache.nemo.runtime.common.comm.ControlMessage.BlockStateChangedMsg

Modifier and Type	Constant Field	Value
public static final int	BLOCKID_FIELD_NUMBER	2
public static final int	EXECUTORID_FIELD_NUMBER	1
public static final int	LOCATION_FIELD_NUMBER	4
public static final int	STATE_FIELD_NUMBER	3

org.apache.nemo.runtime.common.comm.ControlMessage.BlockStateFromExecutor

Modifier and Type	Constant Field	Value
public static final int	AVAILABLE_VALUE	2
public static final int	IN_PROGRESS_VALUE	1
public static final int	NOT_AVAILABLE_VALUE	0

org.apache.nemo.runtime.common.comm.ControlMessage.BlockStore

Modifier and Type	Constant Field	Value
public static final int	LOCAL_FILE_VALUE	2
public static final int	MEMORY_VALUE	0
public static final int	REMOTE_FILE_VALUE	3
public static final int	SER_MEMORY_VALUE	1

org.apache.nemo.runtime.common.comm.ControlMessage.BlockTransferContextDescriptor

Modifier and Type	Constant Field	Value
public static final int	BLOCKID_FIELD_NUMBER	1
public static final int	BLOCKSTORE_FIELD_NUMBER	2
public static final int	KEYRANGE_FIELD_NUMBER	4
public static final int	RUNTIMEEDGEID_FIELD_NUMBER	3

org.apache.nemo.runtime.common.comm.ControlMessage.ByteTransferContextSetupMessage

Modifier and Type	Constant Field	Value
public static final int	CONTEXTDESCRIPTOR_FIELD_NUMBER	4
public static final int	DATADIRECTION_FIELD_NUMBER	3
public static final int	INITIATOREXECUTORID_FIELD_NUMBER	1
public static final int	ISPIPE_FIELD_NUMBER	5
public static final int	TRANSFERINDEX_FIELD_NUMBER	2

org.apache.nemo.runtime.common.comm.ControlMessage.ByteTransferDataDirection

Modifier and Type	Constant Field	Value
public static final int	INITIATOR_RECEIVES_DATA_VALUE	1
public static final int	INITIATOR_SENDS_DATA_VALUE	0

org.apache.nemo.runtime.common.comm.ControlMessage.ClientToDriverMessage

Modifier and Type	Constant Field	Value
public static final int	LAUNCHDAG_FIELD_NUMBER	2
public static final int	MESSAGE_FIELD_NUMBER	3
public static final int	TYPE_FIELD_NUMBER	1

org.apache.nemo.runtime.common.comm.ControlMessage.ClientToDriverMessageType

Modifier and Type	Constant Field	Value
public static final int	DriverShutdown_VALUE	1
public static final int	LaunchDAG_VALUE	0
public static final int	Notification_VALUE	2

org.apache.nemo.runtime.common.comm.ControlMessage.ContainerFailedMsg

Modifier and Type	Constant Field	Value
public static final int	EXECUTORID_FIELD_NUMBER	1

org.apache.nemo.runtime.common.comm.ControlMessage.DataCollectMessage

Modifier and Type	Constant Field	Value
public static final int	DATA_FIELD_NUMBER	1

org.apache.nemo.runtime.common.comm.ControlMessage.DriverToClientMessage

Modifier and Type	Constant Field	Value
public static final int	DATACOLLECTED_FIELD_NUMBER	2
public static final int	OPTIMIZATIONTYPE_FIELD_NUMBER	3
public static final int	TYPE_FIELD_NUMBER	1

org.apache.nemo.runtime.common.comm.ControlMessage.DriverToClientMessageType

Modifier and Type	Constant Field	Value
public static final int	DataCollected_VALUE	2
public static final int	DriverReady_VALUE	1
public static final int	DriverStarted_VALUE	0
public static final int	ExecutionDone_VALUE	3
public static final int	LaunchOptimization_VALUE	4

org.apache.nemo.runtime.common.comm.ControlMessage.ExecutorFailedMsg

Modifier and Type	Constant Field	Value
public static final int	EXCEPTION_FIELD_NUMBER	2
public static final int	EXECUTORID_FIELD_NUMBER	1

org.apache.nemo.runtime.common.comm.ControlMessage.InMasterBroadcastVariableMessage

Modifier and Type	Constant Field	Value
public static final int	REQUESTID_FIELD_NUMBER	1
public static final int	VARIABLE_FIELD_NUMBER	2

org.apache.nemo.runtime.common.comm.ControlMessage.LaunchDAGMessage

Modifier and Type	Constant Field	Value
public static final int	BROADCASTVARS_FIELD_NUMBER	2
public static final int	DAG_FIELD_NUMBER	1

org.apache.nemo.runtime.common.comm.ControlMessage.Message

Modifier and Type	Constant Field	Value
public static final int	BLOCKLOCATIONINFOMSG_FIELD_NUMBER	9
public static final int	BLOCKSTATECHANGEDMSG_FIELD_NUMBER	6
public static final int	BROADCASTVARIABLEMSG_FIELD_NUMBER	15
public static final int	CONTAINERFAILEDMSG_FIELD_NUMBER	11
public static final int	DATACOLLECTED_FIELD_NUMBER	13
public static final int	EXECUTORFAILEDMSG_FIELD_NUMBER	10
public static final int	ID_FIELD_NUMBER	2
public static final int	LISTENERID_FIELD_NUMBER	3
public static final int	METRICMSG_FIELD_NUMBER	12
public static final int	PIPEINITMSG_FIELD_NUMBER	16
public static final int	PIPELOCINFOMSG_FIELD_NUMBER	18
public static final int	REQUESTBLOCKLOCATIONMSG_FIELD_NUMBER	8
public static final int	REQUESTBROADCASTVARIABLEMSG_FIELD_NUMBER	14
public static final int	REQUESTPIPELOCMSG_FIELD_NUMBER	17
public static final int	RUNTIMEPASSMESSAGEMSG_FIELD_NUMBER	7
public static final int	SCHEDULETASKMSG_FIELD_NUMBER	5
public static final int	TASKSTATECHANGEDMSG_FIELD_NUMBER	4
public static final int	TYPE_FIELD_NUMBER	1

org.apache.nemo.runtime.common.comm.ControlMessage.MessageType

Modifier and Type	Constant Field	Value
public static final int	BlockLocationInfo_VALUE	5
public static final int	BlockStateChanged_VALUE	2
public static final int	ExecutorDataCollected_VALUE	7
public static final int	ExecutorFailed_VALUE	6
public static final int	InMasterBroadcastVariable_VALUE	12
public static final int	MetricFlushed_VALUE	10
public static final int	MetricMessageReceived_VALUE	8
public static final int	PipeInit_VALUE	13
public static final int	PipeLocInfo_VALUE	15
public static final int	RequestBlockLocation_VALUE	4
public static final int	RequestBroadcastVariable_VALUE	11
public static final int	RequestMetricFlush_VALUE	9
public static final int	RequestPipeLoc_VALUE	14
public static final int	RunTimePassMessage_VALUE	3
public static final int	ScheduleTask_VALUE	1
public static final int	TaskStateChanged_VALUE	0

org.apache.nemo.runtime.common.comm.ControlMessage.Metric

Modifier and Type	Constant Field	Value
public static final int	METRICFIELD_FIELD_NUMBER	3
public static final int	METRICID_FIELD_NUMBER	2
public static final int	METRICTYPE_FIELD_NUMBER	1
public static final int	METRICVALUE_FIELD_NUMBER	4

org.apache.nemo.runtime.common.comm.ControlMessage.MetricMsg

Modifier and Type	Constant Field	Value
public static final int	METRIC_FIELD_NUMBER	1

org.apache.nemo.runtime.common.comm.ControlMessage.NotificationMessage

Modifier and Type	Constant Field	Value
public static final int	DATA_FIELD_NUMBER	2
public static final int	OPTIMIZATIONTYPE_FIELD_NUMBER	1

org.apache.nemo.runtime.common.comm.ControlMessage.OptimizationType

Modifier and Type	Constant Field	Value
public static final int	XGBoost_VALUE	0

org.apache.nemo.runtime.common.comm.ControlMessage.PipeInitMessage

Modifier and Type	Constant Field	Value
public static final int	EXECUTORID_FIELD_NUMBER	3
public static final int	RUNTIMEEDGEID_FIELD_NUMBER	2
public static final int	SRCTASKINDEX_FIELD_NUMBER	1

org.apache.nemo.runtime.common.comm.ControlMessage.PipeLocationInfoMessage

Modifier and Type	Constant Field	Value
public static final int	EXECUTORID_FIELD_NUMBER	2
public static final int	REQUESTID_FIELD_NUMBER	1

org.apache.nemo.runtime.common.comm.ControlMessage.PipeTransferContextDescriptor

Modifier and Type	Constant Field	Value
public static final int	DSTTASKINDEX_FIELD_NUMBER	3
public static final int	NUMPIPETOWAIT_FIELD_NUMBER	4
public static final int	RUNTIMEEDGEID_FIELD_NUMBER	2
public static final int	SRCTASKINDEX_FIELD_NUMBER	1

org.apache.nemo.runtime.common.comm.ControlMessage.RecoverableFailureCause

Modifier and Type	Constant Field	Value
public static final int	InputReadFailure_VALUE	0
public static final int	OutputWriteFailure_VALUE	1

org.apache.nemo.runtime.common.comm.ControlMessage.RequestBlockLocationMsg

Modifier and Type	Constant Field	Value
public static final int	BLOCKIDWILDCARD_FIELD_NUMBER	2
public static final int	EXECUTORID_FIELD_NUMBER	1

org.apache.nemo.runtime.common.comm.ControlMessage.RequestBroadcastVariableMessage

Modifier and Type	Constant Field	Value
public static final int	BROADCASTID_FIELD_NUMBER	2
public static final int	EXECUTORID_FIELD_NUMBER	1

org.apache.nemo.runtime.common.comm.ControlMessage.RequestPipeLocationMessage

Modifier and Type	Constant Field	Value
public static final int	EXECUTORID_FIELD_NUMBER	1
public static final int	RUNTIMEEDGEID_FIELD_NUMBER	3
public static final int	SRCTASKINDEX_FIELD_NUMBER	2

org.apache.nemo.runtime.common.comm.ControlMessage.RunTimePassMessageEntry

Modifier and Type	Constant Field	Value
public static final int	KEY_FIELD_NUMBER	1
public static final int	VALUE_FIELD_NUMBER	2

org.apache.nemo.runtime.common.comm.ControlMessage.RunTimePassMessageMsg

Modifier and Type	Constant Field	Value
public static final int	ENTRY_FIELD_NUMBER	2
public static final int	TASKID_FIELD_NUMBER	1

org.apache.nemo.runtime.common.comm.ControlMessage.ScheduleTaskMsg

Modifier and Type	Constant Field	Value
public static final int	TASK_FIELD_NUMBER	1

org.apache.nemo.runtime.common.comm.ControlMessage.TaskStateChangedMsg

Modifier and Type	Constant Field	Value
public static final int	ATTEMPTIDX_FIELD_NUMBER	6
public static final int	EXECUTORID_FIELD_NUMBER	1
public static final int	FAILURECAUSE_FIELD_NUMBER	5
public static final int	STATE_FIELD_NUMBER	3
public static final int	TASKID_FIELD_NUMBER	2
public static final int	VERTEXPUTONHOLDID_FIELD_NUMBER	4

org.apache.nemo.runtime.common.comm.ControlMessage.TaskStateFromExecutor

Modifier and Type	Constant Field	Value
public static final int	COMPLETE_VALUE	2
public static final int	EXECUTING_VALUE	1
public static final int	FAILED_RECOVERABLE_VALUE	3
public static final int	FAILED_UNRECOVERABLE_VALUE	4
public static final int	ON_HOLD_VALUE	5
public static final int	READY_VALUE	0

org.apache.nemo.runtime.common.comm.MessageServiceGrpc

Modifier and Type	Constant Field	Value
public static final java.lang.String	SERVICE_NAME	"protobuf.MessageService"

org.apache.nemo.runtime.common.message.MessageEnvironment

Modifier and Type	Constant Field	Value
public static final java.lang.String	BLOCK_MANAGER_MASTER_MESSAGE_LISTENER_ID	"BLOCK_MANAGER_MASTER_MESSAGE_LISTENER_ID"
public static final java.lang.String	EXECUTOR_MESSAGE_LISTENER_ID	"EXECUTOR_MESSAGE_LISTENER_ID"
public static final java.lang.String	MASTER_COMMUNICATION_ID	"MASTER"
public static final java.lang.String	PIPE_MANAGER_MASTER_MESSAGE_LISTENER_ID	"PIPE_MANAGER_MASTER_MESSAGE_LISTENER_ID"
public static final java.lang.String	RUNTIME_MASTER_MESSAGE_LISTENER_ID	"RUNTIME_MASTER_MESSAGE_LISTENER_ID"

org.apache.nemo.runtime.common.metric.MetricUtils

Modifier and Type	Constant Field	Value
public static final java.lang.String	POSTGRESQL_METADATA_DB_NAME	"jdbc:postgresql://nemo-optimization.cabbufr3evny.us-west-2.rds.amazonaws.com:5432/nemo_optimization"