@Test public void testGetStagingBucketName_OneFolder() throws Exception { String expectedBucketName = "test"; PowerMockito.doReturn( "/test" ).when( jobExecutor, "getS3FileObjectPath" ); String bucketName = jobExecutor.getStagingBucketName(); assertEquals( expectedBucketName, bucketName ); }
public String getStagingBucketName() throws FileSystemException, KettleException { String bucketName = ""; String pathToStagingDir = getS3FileObjectPath(); bucketName = pathToStagingDir.substring( 1, pathToStagingDir.length() ).split( "/" )[ 0 ]; return bucketName; }
AbstractAmazonJobExecutor extends AbstractAmazonJobEntry { public String getStagingBucketName() throws FileSystemException, KettleException { String bucketName = ""; String pathToStagingDir = getS3FileObjectPath(); bucketName = pathToStagingDir.substring( 1, pathToStagingDir.length() ).split( "/" )[ 0 ]; return bucketName; } }
AbstractAmazonJobExecutor extends AbstractAmazonJobEntry { public String getStagingBucketName() throws FileSystemException, KettleException { String bucketName = ""; String pathToStagingDir = getS3FileObjectPath(); bucketName = pathToStagingDir.substring( 1, pathToStagingDir.length() ).split( "/" )[ 0 ]; return bucketName; }  }
AbstractAmazonJobExecutor extends AbstractAmazonJobEntry { public String getStagingBucketName() throws FileSystemException, KettleException { String bucketName = ""; String pathToStagingDir = getS3FileObjectPath(); bucketName = pathToStagingDir.substring( 1, pathToStagingDir.length() ).split( "/" )[ 0 ]; return bucketName; }  void setupLogFile(); String getStagingBucketName(); String getStagingS3BucketUrl( String stagingBucketName ); String getStagingS3FileUrl( String stagingBucketName ); String buildFilename( String filename ); abstract File createStagingFile(); abstract String getStepBootstrapActions(); abstract String getMainClass(); abstract String getStepType(); @Override Result execute( Result result, int arg1 ); }
AbstractAmazonJobExecutor extends AbstractAmazonJobEntry { public String getStagingBucketName() throws FileSystemException, KettleException { String bucketName = ""; String pathToStagingDir = getS3FileObjectPath(); bucketName = pathToStagingDir.substring( 1, pathToStagingDir.length() ).split( "/" )[ 0 ]; return bucketName; }  void setupLogFile(); String getStagingBucketName(); String getStagingS3BucketUrl( String stagingBucketName ); String getStagingS3FileUrl( String stagingBucketName ); String buildFilename( String filename ); abstract File createStagingFile(); abstract String getStepBootstrapActions(); abstract String getMainClass(); abstract String getStepType(); @Override Result execute( Result result, int arg1 );  }