Serialized Form (flink-mesos 1.7.0-mrs-1.8.0 API)

Package org.apache.flink.mesos.runtime.clusterframework
- Class org.apache.flink.mesos.runtime.clusterframework.RegisteredMesosWorkerNode extends Object implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - worker
```
MesosWorkerStore.Worker worker
```
Package org.apache.flink.mesos.runtime.clusterframework.store
- Class org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore.Worker extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - taskID
```
org.apache.mesos.Protos.TaskID taskID
```
    - profile
```
org.apache.flink.runtime.clusterframework.types.ResourceProfile profile
```
    - slaveID
```
scala.Option<A> slaveID
```
    - hostname
```
scala.Option<A> hostname
```
    - state
```
MesosWorkerStore.WorkerState state
```
Package org.apache.flink.mesos.scheduler
- Class org.apache.flink.mesos.scheduler.ConnectionMonitor.ConnectedState$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.ConnectionMonitor.ConnectingState$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.ConnectionMonitor.Start extends Object implements Serializable
- Class org.apache.flink.mesos.scheduler.ConnectionMonitor.Start$ extends scala.runtime.AbstractFunction0<org.apache.flink.mesos.scheduler.ConnectionMonitor.Start> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.ConnectionMonitor.Stop extends Object implements Serializable
- Class org.apache.flink.mesos.scheduler.ConnectionMonitor.Stop$ extends scala.runtime.AbstractFunction0<org.apache.flink.mesos.scheduler.ConnectionMonitor.Stop> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.ConnectionMonitor.StoppedState$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Assign extends Object implements Serializable
  - Serialized Fields
    - tasks
```
List<E> tasks
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Assign$ extends scala.runtime.AbstractFunction1<List<org.apache.flink.api.java.tuple.Tuple2<com.netflix.fenzo.TaskRequest,String>>,org.apache.flink.mesos.scheduler.LaunchCoordinator.Assign> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.GatherData extends Object implements Serializable
  - Serialized Fields
    - tasks
```
scala.collection.Seq<A> tasks
```
    - newLeases
```
scala.collection.Seq<A> newLeases
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.GatherData$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<LaunchableTask>,scala.collection.Seq<com.netflix.fenzo.VirtualMachineLease>,org.apache.flink.mesos.scheduler.LaunchCoordinator.GatherData> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.GatheringOffers$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Idle$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Launch extends Object implements Serializable
  - Serialized Fields
    - tasks
```
List<E> tasks
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Launch$ extends scala.runtime.AbstractFunction1<List<LaunchableTask>,org.apache.flink.mesos.scheduler.LaunchCoordinator.Launch> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Suspended$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Unassign extends Object implements Serializable
  - Serialized Fields
    - taskID
```
org.apache.mesos.Protos.TaskID taskID
```
    - hostname
```
String hostname
```
- Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Unassign$ extends scala.runtime.AbstractFunction2<org.apache.mesos.Protos.TaskID,String,org.apache.flink.mesos.scheduler.LaunchCoordinator.Unassign> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.ReconciliationCoordinator.Idle$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.ReconciliationCoordinator.Reconcile extends Object implements Serializable
  - Serialized Fields
    - tasks
```
scala.collection.Seq<A> tasks
```
    - replace
```
boolean replace
```
- Class org.apache.flink.mesos.scheduler.ReconciliationCoordinator.Reconcile$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<org.apache.mesos.Protos.TaskStatus>,Object,org.apache.flink.mesos.scheduler.ReconciliationCoordinator.Reconcile> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.ReconciliationCoordinator.ReconciliationData extends Object implements Serializable
  - Serialized Fields
    - remaining
```
scala.collection.immutable.Map<A,B> remaining
```
    - retries
```
int retries
```
- Class org.apache.flink.mesos.scheduler.ReconciliationCoordinator.ReconciliationData$ extends scala.runtime.AbstractFunction2<scala.collection.immutable.Map<org.apache.mesos.Protos.TaskID,org.apache.mesos.Protos.TaskStatus>,Object,org.apache.flink.mesos.scheduler.ReconciliationCoordinator.ReconciliationData> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.ReconciliationCoordinator.Reconciling$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.ReconciliationCoordinator.Suspended$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.Killing$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.Launched extends Object implements Serializable
  - Serialized Fields
    - taskID
```
org.apache.mesos.Protos.TaskID taskID
```
    - slaveID
```
org.apache.mesos.Protos.SlaveID slaveID
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.Launched$ extends scala.runtime.AbstractFunction2<org.apache.mesos.Protos.TaskID,org.apache.mesos.Protos.SlaveID,org.apache.flink.mesos.scheduler.TaskMonitor.Launched> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.New extends Object implements Serializable
  - Serialized Fields
    - taskID
```
org.apache.mesos.Protos.TaskID taskID
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.New$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.Reconciling$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.Released extends Object implements Serializable
  - Serialized Fields
    - taskID
```
org.apache.mesos.Protos.TaskID taskID
```
    - slaveID
```
org.apache.mesos.Protos.SlaveID slaveID
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.Released$ extends scala.runtime.AbstractFunction2<org.apache.mesos.Protos.TaskID,org.apache.mesos.Protos.SlaveID,org.apache.flink.mesos.scheduler.TaskMonitor.Released> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.Running$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.Staging$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.StateData extends Object implements Serializable
  - Serialized Fields
    - goal
```
org.apache.flink.mesos.scheduler.TaskMonitor.TaskGoalState goal
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.StateData$ extends scala.runtime.AbstractFunction1<org.apache.flink.mesos.scheduler.TaskMonitor.TaskGoalState,org.apache.flink.mesos.scheduler.TaskMonitor.StateData> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.Suspended$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.TaskGoalStateUpdated extends Object implements Serializable
  - Serialized Fields
    - state
```
org.apache.flink.mesos.scheduler.TaskMonitor.TaskGoalState state
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.TaskGoalStateUpdated$ extends scala.runtime.AbstractFunction1<org.apache.flink.mesos.scheduler.TaskMonitor.TaskGoalState,org.apache.flink.mesos.scheduler.TaskMonitor.TaskGoalStateUpdated> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.TaskTerminated extends Object implements Serializable
  - Serialized Fields
    - taskID
```
org.apache.mesos.Protos.TaskID taskID
```
    - status
```
org.apache.mesos.Protos.TaskStatus status
```
- Class org.apache.flink.mesos.scheduler.TaskMonitor.TaskTerminated$ extends scala.runtime.AbstractFunction2<org.apache.mesos.Protos.TaskID,org.apache.mesos.Protos.TaskStatus,org.apache.flink.mesos.scheduler.TaskMonitor.TaskTerminated> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
Package org.apache.flink.mesos.scheduler.messages
- Class org.apache.flink.mesos.scheduler.messages.AcceptOffers extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - hostname
```
String hostname
```
    - offerIds
```
Collection<E> offerIds
```
    - operations
```
Collection<E> operations
```
    - filters
```
org.apache.mesos.Protos.Filters filters
```
- Class org.apache.flink.mesos.scheduler.messages.Connected extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.mesos.scheduler.messages.Disconnected extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.mesos.scheduler.messages.Error extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - message
```
String message
```
- Class org.apache.flink.mesos.scheduler.messages.ExecutorLost extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - executorId
```
org.apache.mesos.Protos.ExecutorID executorId
```
    - slaveId
```
org.apache.mesos.Protos.SlaveID slaveId
```
    - status
```
int status
```
- Class org.apache.flink.mesos.scheduler.messages.FrameworkMessage extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - executorId
```
org.apache.mesos.Protos.ExecutorID executorId
```
    - slaveId
```
org.apache.mesos.Protos.SlaveID slaveId
```
    - data
```
byte[] data
```
- Class org.apache.flink.mesos.scheduler.messages.OfferRescinded extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - offerId
```
org.apache.mesos.Protos.OfferID offerId
```
- Class org.apache.flink.mesos.scheduler.messages.Registered extends Connected implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - frameworkId
```
org.apache.mesos.Protos.FrameworkID frameworkId
```
    - masterInfo
```
org.apache.mesos.Protos.MasterInfo masterInfo
```
- Class org.apache.flink.mesos.scheduler.messages.ReRegistered extends Connected implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - masterInfo
```
org.apache.mesos.Protos.MasterInfo masterInfo
```
- Class org.apache.flink.mesos.scheduler.messages.ResourceOffers extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - offers
```
List<E> offers
```
- Class org.apache.flink.mesos.scheduler.messages.SlaveLost extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - slaveId
```
org.apache.mesos.Protos.SlaveID slaveId
```
- Class org.apache.flink.mesos.scheduler.messages.StatusUpdate extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - status
```
org.apache.mesos.Protos.TaskStatus status
```

Serialized Form

Package org.apache.flink.mesos.runtime.clusterframework

Class org.apache.flink.mesos.runtime.clusterframework.RegisteredMesosWorkerNode extends Object implements Serializable

Serialized Fields

worker

Package org.apache.flink.mesos.runtime.clusterframework.store

Class org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore.Worker extends Object implements Serializable

Serialized Fields

taskID

profile

slaveID

hostname

state

Package org.apache.flink.mesos.scheduler

Class org.apache.flink.mesos.scheduler.ConnectionMonitor.ConnectedState$ extends Object implements Serializable

Serialization Methods

readResolve

Class org.apache.flink.mesos.scheduler.ConnectionMonitor.ConnectingState$ extends Object implements Serializable

Serialization Methods

readResolve

Class org.apache.flink.mesos.scheduler.ConnectionMonitor.Start extends Object implements Serializable

Class org.apache.flink.mesos.scheduler.ConnectionMonitor.Start$ extends scala.runtime.AbstractFunction0<org.apache.flink.mesos.scheduler.ConnectionMonitor.Start> implements Serializable

Serialization Methods

readResolve

Class org.apache.flink.mesos.scheduler.ConnectionMonitor.Stop extends Object implements Serializable

Class org.apache.flink.mesos.scheduler.ConnectionMonitor.Stop$ extends scala.runtime.AbstractFunction0<org.apache.flink.mesos.scheduler.ConnectionMonitor.Stop> implements Serializable

Serialization Methods

readResolve

Class org.apache.flink.mesos.scheduler.ConnectionMonitor.StoppedState$ extends Object implements Serializable

Serialization Methods

readResolve

Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Assign extends Object implements Serializable

Serialized Fields

tasks

Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Assign$ extends scala.runtime.AbstractFunction1<List<org.apache.flink.api.java.tuple.Tuple2<com.netflix.fenzo.TaskRequest,String>>,org.apache.flink.mesos.scheduler.LaunchCoordinator.Assign> implements Serializable

Serialization Methods

readResolve

Class org.apache.flink.mesos.scheduler.LaunchCoordinator.GatherData extends Object implements Serializable

Serialized Fields

tasks

newLeases

Class org.apache.flink.mesos.scheduler.LaunchCoordinator.GatherData$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<LaunchableTask>,scala.collection.Seq<com.netflix.fenzo.VirtualMachineLease>,org.apache.flink.mesos.scheduler.LaunchCoordinator.GatherData> implements Serializable

Serialization Methods

readResolve

Class org.apache.flink.mesos.scheduler.LaunchCoordinator.GatheringOffers$ extends Object implements Serializable

Serialization Methods

readResolve

Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Idle$ extends Object implements Serializable

Serialization Methods

readResolve

Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Launch extends Object implements Serializable

Serialized Fields

tasks

Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Launch$ extends scala.runtime.AbstractFunction1<List<LaunchableTask>,org.apache.flink.mesos.scheduler.LaunchCoordinator.Launch> implements Serializable

Serialization Methods

readResolve

Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Suspended$ extends Object implements Serializable

Serialization Methods

readResolve

Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Unassign extends Object implements Serializable

Serialized Fields

taskID

hostname

Class org.apache.flink.mesos.scheduler.LaunchCoordinator.Unassign$ extends scala.runtime.AbstractFunction2<org.apache.mesos.Protos.TaskID,String,org.apache.flink.mesos.scheduler.LaunchCoordinator.Unassign> implements Serializable

Serialization Methods

readResolve

Class org.apache.flink.mesos.scheduler.ReconciliationCoordinator.Idle$ extends Object implements Serializable

Serialization Methods

readResolve

Class org.apache.flink.mesos.scheduler.ReconciliationCoordinator.Reconcile extends Object implements Serializable

Serialized Fields

tasks

replace

Class org.apache.flink.mesos.scheduler.ReconciliationCoordinator.Reconcile$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<org.apache.mesos.Protos.TaskStatus>,Object,org.apache.flink.mesos.scheduler.ReconciliationCoordinator.Reconcile> implements Serializable

Serialization Methods

readResolve

Class org.apache.flink.mesos.scheduler.ReconciliationCoordinator.ReconciliationData extends Object implements Serializable

Serialized Fields

remaining

retries