Package | Description |
---|---|
org.apache.flink.api.common | |
org.apache.flink.runtime.clusterframework.types | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.io.network.partition.consumer | |
org.apache.flink.runtime.jobgraph | |
org.apache.flink.runtime.jobmanager.scheduler | |
org.apache.flink.runtime.metrics.groups | |
org.apache.flink.runtime.metrics.scope | |
org.apache.flink.runtime.query |
This package contains all KvState query related classes.
|
org.apache.flink.util |
Modifier and Type | Class and Description |
---|---|
class |
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Modifier and Type | Class and Description |
---|---|
class |
AllocationID
Unique identifier for a slot allocated by a JobManager from a TaskManager.
|
Modifier and Type | Class and Description |
---|---|
class |
ExecutionAttemptID
Unique identifier for the attempt to execute a tasks.
|
Modifier and Type | Class and Description |
---|---|
class |
InstanceID
Class for statistically unique instance IDs.
|
Modifier and Type | Method and Description |
---|---|
AbstractID |
Slot.getGroupID()
Gets the ID that identifies the logical group to which this slot belongs:
If the slot does not belong to any group in particular, this field is null.
If this slot was allocated as a sub-slot of a
SlotSharingGroupAssignment ,
then this ID will be the JobVertexID of the vertex whose task the slot
holds in its shared slot.
In case that the slot represents the shared slot of a co-location constraint, this ID will be the
ID of the co-location constraint.
|
Modifier and Type | Method and Description |
---|---|
int |
SlotSharingGroupAssignment.getNumberOfAvailableSlotsForGroup(AbstractID groupId)
Gets the number of shared slots into which the given group can place subtasks or
nested task groups.
|
Constructor and Description |
---|
SharedSlot(JobID jobID,
SlotOwner owner,
TaskManagerLocation location,
int slotNumber,
TaskManagerGateway taskManagerGateway,
SlotSharingGroupAssignment assignmentGroup,
SharedSlot parent,
AbstractID groupId)
Creates a new shared slot that has is a sub-slot of the given parent shared slot, and that belongs
to the given task group.
|
SharedSlot(SharedSlot parent,
SlotOwner owner,
int slotNumber,
SlotSharingGroupAssignment assignmentGroup,
AbstractID groupId)
Creates a new shared slot that is a sub-slot of the given parent shared slot, and that belongs
to the given task group.
|
SimpleSlot(JobID jobID,
SlotOwner owner,
TaskManagerLocation location,
int slotNumber,
TaskManagerGateway taskManagerGateway,
SharedSlot parent,
AbstractID groupID)
Creates a new simple slot that belongs to the given shared slot and
is identified by the given ID.
|
SimpleSlot(SharedSlot parent,
SlotOwner owner,
int slotNumber,
AbstractID groupID)
Creates a new simple slot that belongs to the given shared slot and
is identified by the given ID..
|
Slot(AllocatedSlot allocatedSlot,
SlotOwner owner,
int slotNumber,
SharedSlot parent,
AbstractID groupID)
Base constructor for slots.
|
Slot(JobID jobID,
SlotOwner owner,
TaskManagerLocation location,
int slotNumber,
TaskManagerGateway taskManagerGateway,
SharedSlot parent,
AbstractID groupID)
Base constructor for slots.
|
Modifier and Type | Class and Description |
---|---|
class |
InputChannelID |
Constructor and Description |
---|
InputChannelID(AbstractID id) |
Modifier and Type | Class and Description |
---|---|
class |
IntermediateDataSetID |
class |
IntermediateResultPartitionID |
class |
JobVertexID
A class for statistically unique job vertex IDs.
|
Constructor and Description |
---|
IntermediateDataSetID(AbstractID from)
Creates a new intermediate data set ID with the bytes of the given ID.
|
Modifier and Type | Method and Description |
---|---|
AbstractID |
CoLocationConstraint.getGroupId()
Gets the ID that identifies the co-location group.
|
AbstractID |
CoLocationGroup.getId()
Gets the ID that identifies this co-location group.
|
Modifier and Type | Field and Description |
---|---|
protected AbstractID |
TaskMetricGroup.vertexId |
Modifier and Type | Method and Description |
---|---|
AbstractID |
TaskMetricGroup.executionId() |
AbstractID |
TaskMetricGroup.vertexId() |
Modifier and Type | Method and Description |
---|---|
void |
TaskManagerJobMetricGroup.removeTaskMetricGroup(AbstractID executionId) |
Constructor and Description |
---|
TaskMetricGroup(MetricRegistry registry,
TaskManagerJobMetricGroup parent,
AbstractID vertexId,
AbstractID executionId,
String taskName,
int subtaskIndex,
int attemptNumber) |
Modifier and Type | Method and Description |
---|---|
String[] |
TaskScopeFormat.formatScope(TaskManagerJobMetricGroup parent,
AbstractID vertexId,
AbstractID attemptId,
String taskName,
int subtask,
int attemptNumber) |
Modifier and Type | Class and Description |
---|---|
class |
KvStateID
Identifier for
KvState instances. |
Modifier and Type | Method and Description |
---|---|
int |
AbstractID.compareTo(AbstractID o) |
Constructor and Description |
---|
AbstractID(AbstractID id)
Creates a new abstract ID from the given one.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.