package edu.uci.ics.amber.core

Get desktop application:
View/edit binary Protocol Buffers messages

Used in: ChannelIdentity, engine.architecture.rpc.AsyncRPCContext, engine.architecture.rpc.Chain, engine.architecture.rpc.Collect, engine.architecture.rpc.MultiCall, engine.architecture.rpc.Ping, engine.architecture.rpc.Pong, engine.architecture.rpc.QueryStatisticsRequest, engine.architecture.rpc.RetryWorkflowRequest

• string name = 1

Used in: engine.architecture.rpc.AddInputChannelRequest, engine.architecture.rpc.ChannelMarkerPayload, engine.architecture.sendsemantics.BroadcastPartitioning, engine.architecture.sendsemantics.HashBasedShufflePartitioning, engine.architecture.sendsemantics.OneToOnePartitioning, engine.architecture.sendsemantics.RangeBasedShufflePartitioning, engine.architecture.sendsemantics.RoundRobinPartitioning, engine.common.PythonControlMessage, engine.common.PythonDataHeader

• optional ActorVirtualIdentity fromWorkerId = 1

• optional ActorVirtualIdentity toWorkerId = 2

• bool isControl = 3

Used in: engine.architecture.rpc.ChannelMarkerPayload, engine.architecture.rpc.FinalizeCheckpointRequest, engine.architecture.rpc.PrepareCheckpointRequest, engine.architecture.rpc.PropagateChannelMarkerRequest, engine.architecture.rpc.TakeGlobalCheckpointRequest

• string id = 1

Used in: engine.common.ExecutionMetadataStore

• int64 id = 1

Used in: WorkflowFatalError

• COMPILATION_ERROR = 0

• EXECUTION_FAILURE = 1

• optional PhysicalOpIdentity opId = 1

• optional PortIdentity portId = 2

• bool input = 3

• optional PortIdentity id = 1

• string displayName = 2

• bool allowMultiLinks = 3

• repeated PortIdentity dependencies = 4

Used in: engine.architecture.rpc.InitializeExecutorRequest

• oneof sealed_value

  • OpExecWithClassName opExecWithClassName = 1

  • OpExecWithCode opExecWithCode = 2

  • OpExecSource opExecSource = 3

Used in: OpExecInitInfo

• string storageKey = 1

• optional WorkflowIdentity workflowIdentity = 2

Used in: OpExecInitInfo

• string className = 1

• string descString = 2

Used in: OpExecInitInfo

• string code = 1

• string language = 2

Used in: PhysicalOpIdentity

• string id = 1

• optional PortIdentity id = 1

• string displayName = 2

• bool blocking = 3

• OutputPort.OutputMode mode = 4

Used in: OutputPort

• SET_SNAPSHOT = 0

  outputs complete result set snapshot for each update

• SET_DELTA = 1

  outputs incremental result set delta for each update

• SINGLE_SNAPSHOT = 2

  outputs a single snapshot for the entire execution, used explicitly to support visualization operators that may exceed the memory limit TODO: remove this mode after we have a better solution for output size limit

Used in: engine.architecture.rpc.AddPartitioningRequest, engine.architecture.rpc.LinkWorkersRequest

• optional PhysicalOpIdentity fromOpId = 1

• optional PortIdentity fromPortId = 2

• optional PhysicalOpIdentity toOpId = 3

• optional PortIdentity toPortId = 4

Used in: GlobalPortIdentity, PhysicalLink, engine.architecture.rpc.PropagateChannelMarkerRequest, engine.architecture.rpc.UpdateExecutorRequest

• optional OperatorIdentity logicalOpId = 1

• string layerName = 2

Used in: GlobalPortIdentity, InputPort, OutputPort, PhysicalLink, engine.architecture.rpc.AddInputChannelRequest, engine.architecture.rpc.AssignPortRequest, engine.architecture.rpc.PortCompletedRequest, engine.architecture.worker.PortTupleMetricsMapping

• int32 id = 1

• bool internal = 2

Used in: engine.common.ExecutionMetadataStore

• FatalErrorType type = 1

• optional google.protobuf.Timestamp timestamp = 2

• string message = 3

• string details = 4

• string operatorId = 5

• string workerId = 6

Used in: OpExecSource

• int64 id = 1