Package | Description |
---|---|
org.apache.flink.runtime.akka | |
org.apache.flink.runtime.clusterframework.messages |
This package contains the actor messages that are sent between the
cluster resource framework and the JobManager, as well as the generic
messages sent between the cluster resource framework and the client.
|
org.apache.flink.runtime.dispatcher | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmanager.slots | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.runtime.resourcemanager.slotmanager | |
org.apache.flink.runtime.taskexecutor |
Class and Description |
---|
Acknowledge
A generic acknowledgement message.
|
Class and Description |
---|
RequiresLeaderSessionID
Marks messages to be sent wrapped in a
JobManagerMessages.LeaderSessionMessage |
Class and Description |
---|
Acknowledge
A generic acknowledgement message.
|
Class and Description |
---|
StackTraceSampleResponse
Response to the TriggerStackTraceSample message.
|
Class and Description |
---|
Acknowledge
A generic acknowledgement message.
|
Class and Description |
---|
Acknowledge
A generic acknowledgement message.
|
StackTrace |
StackTraceSampleResponse
Response to the TriggerStackTraceSample message.
|
Class and Description |
---|
Acknowledge
A generic acknowledgement message.
|
StackTrace |
StackTraceSampleResponse
Response to the TriggerStackTraceSample message.
|
Class and Description |
---|
Acknowledge
A generic acknowledgement message.
|
MessageDecorator
Interface for message decorators
|
Class and Description |
---|
Acknowledge
A generic acknowledgement message.
|
Class and Description |
---|
Acknowledge
A generic acknowledgement message.
|
Class and Description |
---|
Acknowledge
A generic acknowledgement message.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.