@Test public void testAddExecutePermission() { Assert.assertEquals(FileAwareInputStreamDataWriter.addExecutePermissionToOwner(new FsPermission("000")), new FsPermission("100")); Assert.assertEquals(FileAwareInputStreamDataWriter.addExecutePermissionToOwner(new FsPermission("100")), new FsPermission("100")); Assert.assertEquals(FileAwareInputStreamDataWriter.addExecutePermissionToOwner(new FsPermission("200")), new FsPermission("300")); Assert.assertEquals(FileAwareInputStreamDataWriter.addExecutePermissionToOwner(new FsPermission("400")), new FsPermission("500")); Assert.assertEquals(FileAwareInputStreamDataWriter.addExecutePermissionToOwner(new FsPermission("600")), new FsPermission("700")); Assert.assertEquals(FileAwareInputStreamDataWriter.addExecutePermissionToOwner(new FsPermission("700")), new FsPermission("700")); Assert.assertEquals(FileAwareInputStreamDataWriter.addExecutePermissionToOwner(new FsPermission("211")), new FsPermission("311")); Assert.assertEquals(FileAwareInputStreamDataWriter.addExecutePermissionToOwner(new FsPermission("250")), new FsPermission("350")); }
static FsPermission addExecutePermissionToOwner(FsPermission fsPermission) { FsAction newOwnerAction = fsPermission.getUserAction().or(FsAction.EXECUTE); return new FsPermission(newOwnerAction, fsPermission.getGroupAction(), fsPermission.getOtherAction()); }
FileAwareInputStreamDataWriter extends InstrumentedDataWriter<FileAwareInputStream> implements FinalState, SpeculativeAttemptAwareConstruct { static FsPermission addExecutePermissionToOwner(FsPermission fsPermission) { FsAction newOwnerAction = fsPermission.getUserAction().or(FsAction.EXECUTE); return new FsPermission(newOwnerAction, fsPermission.getGroupAction(), fsPermission.getOtherAction()); } }
FileAwareInputStreamDataWriter extends InstrumentedDataWriter<FileAwareInputStream> implements FinalState, SpeculativeAttemptAwareConstruct { static FsPermission addExecutePermissionToOwner(FsPermission fsPermission) { FsAction newOwnerAction = fsPermission.getUserAction().or(FsAction.EXECUTE); return new FsPermission(newOwnerAction, fsPermission.getGroupAction(), fsPermission.getOtherAction()); } FileAwareInputStreamDataWriter(State state, int numBranches, int branchId, String writerAttemptId);  FileAwareInputStreamDataWriter(State state, int numBranches, int branchId); }
FileAwareInputStreamDataWriter extends InstrumentedDataWriter<FileAwareInputStream> implements FinalState, SpeculativeAttemptAwareConstruct { static FsPermission addExecutePermissionToOwner(FsPermission fsPermission) { FsAction newOwnerAction = fsPermission.getUserAction().or(FsAction.EXECUTE); return new FsPermission(newOwnerAction, fsPermission.getGroupAction(), fsPermission.getOtherAction()); } FileAwareInputStreamDataWriter(State state, int numBranches, int branchId, String writerAttemptId);  FileAwareInputStreamDataWriter(State state, int numBranches, int branchId); @Override final void writeImpl(FileAwareInputStream fileAwareInputStream); static Path getOutputFilePath(CopyableFile file, Path outputDir,
      CopyEntity.DatasetAndPartition datasetAndPartition); static Path getSplitOutputFilePath(CopyableFile file, Path outputDir,
      CopyableFile.DatasetAndPartition datasetAndPartition, State workUnit); static Path getOutputDir(State state); @Override long recordsWritten(); @Override long bytesWritten(); @Override void commit(); @Override void cleanup(); @Override State getFinalState(); @Override boolean isSpeculativeAttemptSafe(); }
FileAwareInputStreamDataWriter extends InstrumentedDataWriter<FileAwareInputStream> implements FinalState, SpeculativeAttemptAwareConstruct { static FsPermission addExecutePermissionToOwner(FsPermission fsPermission) { FsAction newOwnerAction = fsPermission.getUserAction().or(FsAction.EXECUTE); return new FsPermission(newOwnerAction, fsPermission.getGroupAction(), fsPermission.getOtherAction()); } FileAwareInputStreamDataWriter(State state, int numBranches, int branchId, String writerAttemptId);  FileAwareInputStreamDataWriter(State state, int numBranches, int branchId); @Override final void writeImpl(FileAwareInputStream fileAwareInputStream); static Path getOutputFilePath(CopyableFile file, Path outputDir,
      CopyEntity.DatasetAndPartition datasetAndPartition); static Path getSplitOutputFilePath(CopyableFile file, Path outputDir,
      CopyableFile.DatasetAndPartition datasetAndPartition, State workUnit); static Path getOutputDir(State state); @Override long recordsWritten(); @Override long bytesWritten(); @Override void commit(); @Override void cleanup(); @Override State getFinalState(); @Override boolean isSpeculativeAttemptSafe(); static final String GOBBLIN_COPY_BYTES_COPIED_METER; static final String GOBBLIN_COPY_CHECK_FILESIZE; static final boolean DEFAULT_GOBBLIN_COPY_CHECK_FILESIZE; static final String GOBBLIN_COPY_TASK_OVERWRITE_ON_COMMIT; static final boolean DEFAULT_GOBBLIN_COPY_TASK_OVERWRITE_ON_COMMIT; static final String STAGING_DIR_SUFFIX; static final String DATASET_STAGING_DIR_PATH; }