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.protos |
Modifier and Type | Method and Description |
---|---|
MRRuntimeProtos.MRSplitsProto |
InputSplitInfoDisk.getSplitsProto() |
MRRuntimeProtos.MRSplitsProto |
InputSplitInfo.getSplitsProto()
Get the splits proto
|
MRRuntimeProtos.MRSplitsProto |
InputSplitInfoMem.getSplitsProto() |
Modifier and Type | Method and Description |
---|---|
protected static org.apache.tez.dag.api.UserPayload |
MRInputHelpers.createMRInputPayload(org.apache.hadoop.conf.Configuration conf,
MRRuntimeProtos.MRSplitsProto mrSplitsProto) |
protected static org.apache.tez.dag.api.UserPayload |
MRInputHelpers.createMRInputPayload(org.apache.hadoop.conf.Configuration conf,
MRRuntimeProtos.MRSplitsProto mrSplitsProto,
boolean isGrouped,
boolean isSorted)
When isGrouped is true, it specifies that grouping of input splits be
performed by Tez The conf should have the input format class configuration
set to the TezGroupedSplitsInputFormat.
|
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<MRRuntimeProtos.MRSplitsProto> |
MRRuntimeProtos.MRSplitsProto.PARSER |
Modifier and Type | Method and Description |
---|---|
MRRuntimeProtos.MRSplitsProto |
MRRuntimeProtos.MRSplitsProto.Builder.build() |
MRRuntimeProtos.MRSplitsProto |
MRRuntimeProtos.MRSplitsProto.Builder.buildPartial() |
static MRRuntimeProtos.MRSplitsProto |
MRRuntimeProtos.MRSplitsProto.getDefaultInstance() |
MRRuntimeProtos.MRSplitsProto |
MRRuntimeProtos.MRSplitsProto.getDefaultInstanceForType() |
MRRuntimeProtos.MRSplitsProto |
MRRuntimeProtos.MRSplitsProto.Builder.getDefaultInstanceForType() |
MRRuntimeProtos.MRSplitsProto |
MRRuntimeProtos.MRInputUserPayloadProtoOrBuilder.getSplits()
optional .MRSplitsProto splits = 2; |
MRRuntimeProtos.MRSplitsProto |
MRRuntimeProtos.MRInputUserPayloadProto.getSplits()
optional .MRSplitsProto splits = 2; |
MRRuntimeProtos.MRSplitsProto |
MRRuntimeProtos.MRInputUserPayloadProto.Builder.getSplits()
optional .MRSplitsProto splits = 2; |
static MRRuntimeProtos.MRSplitsProto |
MRRuntimeProtos.MRSplitsProto.parseDelimitedFrom(InputStream input) |
static MRRuntimeProtos.MRSplitsProto |
MRRuntimeProtos.MRSplitsProto.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static MRRuntimeProtos.MRSplitsProto |
MRRuntimeProtos.MRSplitsProto.parseFrom(byte[] data) |
static MRRuntimeProtos.MRSplitsProto |
MRRuntimeProtos.MRSplitsProto.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static MRRuntimeProtos.MRSplitsProto |
MRRuntimeProtos.MRSplitsProto.parseFrom(com.google.protobuf.ByteString data) |
static MRRuntimeProtos.MRSplitsProto |
MRRuntimeProtos.MRSplitsProto.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static MRRuntimeProtos.MRSplitsProto |
MRRuntimeProtos.MRSplitsProto.parseFrom(com.google.protobuf.CodedInputStream input) |
static MRRuntimeProtos.MRSplitsProto |
MRRuntimeProtos.MRSplitsProto.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static MRRuntimeProtos.MRSplitsProto |
MRRuntimeProtos.MRSplitsProto.parseFrom(InputStream input) |
static MRRuntimeProtos.MRSplitsProto |
MRRuntimeProtos.MRSplitsProto.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<MRRuntimeProtos.MRSplitsProto> |
MRRuntimeProtos.MRSplitsProto.getParserForType() |
Modifier and Type | Method and Description |
---|---|
MRRuntimeProtos.MRSplitsProto.Builder |
MRRuntimeProtos.MRSplitsProto.Builder.mergeFrom(MRRuntimeProtos.MRSplitsProto other) |
MRRuntimeProtos.MRInputUserPayloadProto.Builder |
MRRuntimeProtos.MRInputUserPayloadProto.Builder.mergeSplits(MRRuntimeProtos.MRSplitsProto value)
optional .MRSplitsProto splits = 2; |
static MRRuntimeProtos.MRSplitsProto.Builder |
MRRuntimeProtos.MRSplitsProto.newBuilder(MRRuntimeProtos.MRSplitsProto prototype) |
MRRuntimeProtos.MRInputUserPayloadProto.Builder |
MRRuntimeProtos.MRInputUserPayloadProto.Builder.setSplits(MRRuntimeProtos.MRSplitsProto value)
optional .MRSplitsProto splits = 2; |
Copyright © 2019 Apache Software Foundation. All rights reserved.