Package | Description |
---|---|
alluxio.master.lineage | |
alluxio.thrift | |
alluxio.wire |
Modifier and Type | Method and Description |
---|---|
CreateLineageTResponse |
LineageMasterClientServiceHandler.createLineage(List<String> inputFiles,
List<String> outputFiles,
CommandLineJobInfo jobInfo,
CreateLineageTOptions options) |
Modifier and Type | Method and Description |
---|---|
CommandLineJobInfo |
CommandLineJobInfo.deepCopy() |
CommandLineJobInfo |
LineageMasterClientService.createLineage_args.getJob()
the command line job info
|
CommandLineJobInfo |
LineageInfo.getJob() |
CommandLineJobInfo |
CommandLineJobInfo.setCommand(String command) |
CommandLineJobInfo |
CommandLineJobInfo.setConf(JobConfInfo conf) |
Modifier and Type | Method and Description |
---|---|
int |
CommandLineJobInfo.compareTo(CommandLineJobInfo other) |
CreateLineageTResponse |
LineageMasterClientService.Iface.createLineage(List<String> inputFiles,
List<String> outputFiles,
CommandLineJobInfo job,
CreateLineageTOptions options)
Creates a lineage and returns the lineage id.
|
CreateLineageTResponse |
LineageMasterClientService.Client.createLineage(List<String> inputFiles,
List<String> outputFiles,
CommandLineJobInfo job,
CreateLineageTOptions options) |
void |
LineageMasterClientService.AsyncIface.createLineage(List<String> inputFiles,
List<String> outputFiles,
CommandLineJobInfo job,
CreateLineageTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
LineageMasterClientService.AsyncClient.createLineage(List<String> inputFiles,
List<String> outputFiles,
CommandLineJobInfo job,
CreateLineageTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
boolean |
CommandLineJobInfo.equals(CommandLineJobInfo that) |
void |
LineageMasterClientService.Client.send_createLineage(List<String> inputFiles,
List<String> outputFiles,
CommandLineJobInfo job,
CreateLineageTOptions options) |
LineageMasterClientService.createLineage_args |
LineageMasterClientService.createLineage_args.setJob(CommandLineJobInfo job)
the command line job info
|
LineageInfo |
LineageInfo.setJob(CommandLineJobInfo job) |
Constructor and Description |
---|
CommandLineJobInfo(CommandLineJobInfo other)
Performs a deep copy on other.
|
createLineage_args(List<String> inputFiles,
List<String> outputFiles,
CommandLineJobInfo job,
CreateLineageTOptions options) |
createLineage_call(List<String> inputFiles,
List<String> outputFiles,
CommandLineJobInfo job,
CreateLineageTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler,
org.apache.thrift.async.TAsyncClient client,
org.apache.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.thrift.transport.TNonblockingTransport transport) |
LineageInfo(long id,
List<String> inputFiles,
List<String> outputFiles,
CommandLineJobInfo job,
long creationTimeMs,
List<Long> parents,
List<Long> children) |
Modifier and Type | Method and Description |
---|---|
CommandLineJobInfo |
CommandLineJobInfo.toThrift() |
Modifier and Type | Method and Description |
---|---|
static CommandLineJobInfo |
CommandLineJobInfo.fromThrift(CommandLineJobInfo info)
Creates a new instance of
CommandLineJobInfo from a thrift representation. |
Copyright © 2023. All Rights Reserved.