Toggle navigation
Home
long to alluxio.thrift.CreateLineageTResponse
No. of Instances - 9
No. of Commits - 1
No. of Projects - {'alluxio'}
Hierarchy/Composition: Composition
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Cascading Type Change (Different)
RpcCallableThrowsIOException<Long>
to
RpcCallableThrowsIOException<CreateLineageTResponse>
Update Anonymous class
{ @Override public Long call() throws AlluxioException, IOException { List<AlluxioURI> inputFilesUri=new ArrayList<>(); for ( String inputFile : inputFiles) { inputFilesUri.add(new AlluxioURI(inputFile)); } List<AlluxioURI> outputFilesUri=new ArrayList<>(); for ( String outputFile : outputFiles) { outputFilesUri.add(new AlluxioURI(outputFile)); } CommandLineJob job=new CommandLineJob(jobInfo.getCommand(),new JobConf(jobInfo.getConf().getOutputFile())); return mLineageMaster.createLineage(inputFilesUri,outputFilesUri,job); } }
to
{ @Override public CreateLineageTResponse call() throws AlluxioException, IOException { List<AlluxioURI> inputFilesUri=new ArrayList<>(); for ( String inputFile : inputFiles) { inputFilesUri.add(new AlluxioURI(inputFile)); } List<AlluxioURI> outputFilesUri=new ArrayList<>(); for ( String outputFile : outputFiles) { outputFilesUri.add(new AlluxioURI(outputFile)); } CommandLineJob job=new CommandLineJob(jobInfo.getCommand(),new JobConf(jobInfo.getConf().getOutputFile())); return new CreateLineageTResponse(mLineageMaster.createLineage(inputFilesUri,outputFilesUri,job)); } }