Package | Description |
---|---|
org.apache.tez.mapreduce.hadoop |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
org.apache.tez.mapreduce.lib |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
org.apache.tez.mapreduce.protos |
Modifier and Type | Method and Description |
---|---|
static MRRuntimeProtos.MRSplitProto |
MRInputHelpers.createSplitProto(org.apache.hadoop.mapred.InputSplit oldSplit) |
static <T extends org.apache.hadoop.mapreduce.InputSplit> |
MRInputHelpers.createSplitProto(T newSplit,
org.apache.hadoop.io.serializer.SerializationFactory serializationFactory) |
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.mapreduce.InputSplit |
MRInputHelpers.createNewFormatSplitFromUserPayload(MRRuntimeProtos.MRSplitProto splitProto,
org.apache.hadoop.io.serializer.SerializationFactory serializationFactory)
Create an instance of
InputSplit from the MRInput representation of a split. |
static org.apache.hadoop.mapred.InputSplit |
MRInputHelpers.createOldFormatSplitFromUserPayload(MRRuntimeProtos.MRSplitProto splitProto,
org.apache.hadoop.io.serializer.SerializationFactory serializationFactory)
Create an instance of
InputSplit from the MRInput representation of a split. |
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.mapreduce.InputSplit |
MRInputUtils.getNewSplitDetailsFromEvent(MRRuntimeProtos.MRSplitProto splitProto,
org.apache.hadoop.conf.Configuration conf) |
static org.apache.hadoop.mapred.InputSplit |
MRInputUtils.getOldSplitDetailsFromEvent(MRRuntimeProtos.MRSplitProto splitProto,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<MRRuntimeProtos.MRSplitProto> |
MRRuntimeProtos.MRSplitProto.PARSER |
Modifier and Type | Method and Description |
---|---|
MRRuntimeProtos.MRSplitProto |
MRRuntimeProtos.MRSplitProto.Builder.build() |
MRRuntimeProtos.MRSplitProto |
MRRuntimeProtos.MRSplitProto.Builder.buildPartial() |
static MRRuntimeProtos.MRSplitProto |
MRRuntimeProtos.MRSplitProto.getDefaultInstance() |
MRRuntimeProtos.MRSplitProto |
MRRuntimeProtos.MRSplitProto.getDefaultInstanceForType() |
MRRuntimeProtos.MRSplitProto |
MRRuntimeProtos.MRSplitProto.Builder.getDefaultInstanceForType() |
MRRuntimeProtos.MRSplitProto |
MRRuntimeProtos.MRSplitsProtoOrBuilder.getSplits(int index)
repeated .MRSplitProto splits = 2; |
MRRuntimeProtos.MRSplitProto |
MRRuntimeProtos.MRSplitsProto.getSplits(int index)
repeated .MRSplitProto splits = 2; |
MRRuntimeProtos.MRSplitProto |
MRRuntimeProtos.MRSplitsProto.Builder.getSplits(int index)
repeated .MRSplitProto splits = 2; |
static MRRuntimeProtos.MRSplitProto |
MRRuntimeProtos.MRSplitProto.parseDelimitedFrom(InputStream input) |
static MRRuntimeProtos.MRSplitProto |
MRRuntimeProtos.MRSplitProto.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static MRRuntimeProtos.MRSplitProto |
MRRuntimeProtos.MRSplitProto.parseFrom(byte[] data) |
static MRRuntimeProtos.MRSplitProto |
MRRuntimeProtos.MRSplitProto.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static MRRuntimeProtos.MRSplitProto |
MRRuntimeProtos.MRSplitProto.parseFrom(com.google.protobuf.ByteString data) |
static MRRuntimeProtos.MRSplitProto |
MRRuntimeProtos.MRSplitProto.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static MRRuntimeProtos.MRSplitProto |
MRRuntimeProtos.MRSplitProto.parseFrom(com.google.protobuf.CodedInputStream input) |
static MRRuntimeProtos.MRSplitProto |
MRRuntimeProtos.MRSplitProto.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static MRRuntimeProtos.MRSplitProto |
MRRuntimeProtos.MRSplitProto.parseFrom(InputStream input) |
static MRRuntimeProtos.MRSplitProto |
MRRuntimeProtos.MRSplitProto.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<MRRuntimeProtos.MRSplitProto> |
MRRuntimeProtos.MRSplitProto.getParserForType() |
List<MRRuntimeProtos.MRSplitProto> |
MRRuntimeProtos.MRSplitsProtoOrBuilder.getSplitsList()
repeated .MRSplitProto splits = 2; |
List<MRRuntimeProtos.MRSplitProto> |
MRRuntimeProtos.MRSplitsProto.getSplitsList()
repeated .MRSplitProto splits = 2; |
List<MRRuntimeProtos.MRSplitProto> |
MRRuntimeProtos.MRSplitsProto.Builder.getSplitsList()
repeated .MRSplitProto splits = 2; |
Modifier and Type | Method and Description |
---|---|
MRRuntimeProtos.MRSplitsProto.Builder |
MRRuntimeProtos.MRSplitsProto.Builder.addSplits(int index,
MRRuntimeProtos.MRSplitProto value)
repeated .MRSplitProto splits = 2; |
MRRuntimeProtos.MRSplitsProto.Builder |
MRRuntimeProtos.MRSplitsProto.Builder.addSplits(MRRuntimeProtos.MRSplitProto value)
repeated .MRSplitProto splits = 2; |
MRRuntimeProtos.MRSplitProto.Builder |
MRRuntimeProtos.MRSplitProto.Builder.mergeFrom(MRRuntimeProtos.MRSplitProto other) |
static MRRuntimeProtos.MRSplitProto.Builder |
MRRuntimeProtos.MRSplitProto.newBuilder(MRRuntimeProtos.MRSplitProto prototype) |
MRRuntimeProtos.MRSplitsProto.Builder |
MRRuntimeProtos.MRSplitsProto.Builder.setSplits(int index,
MRRuntimeProtos.MRSplitProto value)
repeated .MRSplitProto splits = 2; |
Modifier and Type | Method and Description |
---|---|
MRRuntimeProtos.MRSplitsProto.Builder |
MRRuntimeProtos.MRSplitsProto.Builder.addAllSplits(Iterable<? extends MRRuntimeProtos.MRSplitProto> values)
repeated .MRSplitProto splits = 2; |
Copyright © 2016 Apache Software Foundation. All rights reserved.