org.apache.tez.runtime.library.shuffle.impl

Interface ShuffleUserPayloads.DataMovementEventPayloadProtoOrBuilder

All Superinterfaces:

com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder

All Known Implementing Classes:

ShuffleUserPayloads.DataMovementEventPayloadProto, ShuffleUserPayloads.DataMovementEventPayloadProto.Builder

Enclosing class:

ShuffleUserPayloads

public static interface ShuffleUserPayloads.DataMovementEventPayloadProtoOrBuilder
extends com.google.protobuf.MessageOrBuilder

Method Summary

Methods

Modifier and Type	Method and Description
com.google.protobuf.ByteString	getEmptyPartitions() optional bytes empty_partitions = 1;
String	getHost() optional string host = 2;
com.google.protobuf.ByteString	getHostBytes() optional string host = 2;
boolean	getLastEvent() optional bool last_event = 8;
String	getPathComponent() optional string path_component = 4;
com.google.protobuf.ByteString	getPathComponentBytes() optional string path_component = 4;
boolean	getPipelined() optional bool pipelined = 7;
int	getPort() optional int32 port = 3;
int	getRunDuration() optional int32 run_duration = 5;
int	getSpillId() optional int32 spill_id = 9;
boolean	hasEmptyPartitions() optional bytes empty_partitions = 1;
boolean	hasHost() optional string host = 2;
boolean	hasLastEvent() optional bool last_event = 8;
boolean	hasPathComponent() optional string path_component = 4;
boolean	hasPipelined() optional bool pipelined = 7;
boolean	hasPort() optional int32 port = 3;
boolean	hasRunDuration() optional int32 run_duration = 5;
boolean	hasSpillId() optional int32 spill_id = 9;

Methods inherited from interface com.google.protobuf.MessageOrBuilder

findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField

Methods inherited from interface com.google.protobuf.MessageLiteOrBuilder

isInitialized

Method Detail

hasEmptyPartitions

boolean hasEmptyPartitions()

optional bytes empty_partitions = 1;

getEmptyPartitions

com.google.protobuf.ByteString getEmptyPartitions()

optional bytes empty_partitions = 1;

hasHost

boolean hasHost()

optional string host = 2;

getHost

String getHost()

optional string host = 2;

getHostBytes

com.google.protobuf.ByteString getHostBytes()

optional string host = 2;

hasPort

boolean hasPort()

optional int32 port = 3;

getPort

int getPort()

optional int32 port = 3;

hasPathComponent

boolean hasPathComponent()

optional string path_component = 4;

getPathComponent

String getPathComponent()

optional string path_component = 4;

getPathComponentBytes

com.google.protobuf.ByteString getPathComponentBytes()

optional string path_component = 4;

hasRunDuration

boolean hasRunDuration()

optional int32 run_duration = 5;

getRunDuration

int getRunDuration()

optional int32 run_duration = 5;

hasPipelined

boolean hasPipelined()

optional bool pipelined = 7;

 Related to pipelined shuffle
 

getPipelined

boolean getPipelined()

optional bool pipelined = 7;

 Related to pipelined shuffle
 

hasLastEvent

boolean hasLastEvent()

optional bool last_event = 8;

 Related to pipelined shuffle
 

getLastEvent

boolean getLastEvent()

optional bool last_event = 8;

 Related to pipelined shuffle
 

hasSpillId

boolean hasSpillId()

optional int32 spill_id = 9;

  Related to pipelined shuffle.
 

getSpillId

int getSpillId()

optional int32 spill_id = 9;

  Related to pipelined shuffle.