source: proiecte/HadoopJUnit/hadoop-0.20.1/src/test/org/apache/hadoop/fs/s3native/NativeS3FileSystemContractBaseTest.java @ 120

Last change on this file since 120 was 120, checked in by (none), 14 years ago

Added the mail files for the Hadoop JUNit Project

  • Property svn:executable set to *
File size: 1.9 KB
Line 
1/**
2 * Licensed to the Apache Software Foundation (ASF) under one
3 * or more contributor license agreements.  See the NOTICE file
4 * distributed with this work for additional information
5 * regarding copyright ownership.  The ASF licenses this file
6 * to you under the Apache License, Version 2.0 (the
7 * "License"); you may not use this file except in compliance
8 * with the License.  You may obtain a copy of the License at
9 *
10 *     http://www.apache.org/licenses/LICENSE-2.0
11 *
12 * Unless required by applicable law or agreed to in writing, software
13 * distributed under the License is distributed on an "AS IS" BASIS,
14 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 * See the License for the specific language governing permissions and
16 * limitations under the License.
17 */
18
19package org.apache.hadoop.fs.s3native;
20
21import java.io.IOException;
22import java.net.URI;
23
24import org.apache.hadoop.conf.Configuration;
25import org.apache.hadoop.fs.FileStatus;
26import org.apache.hadoop.fs.FileSystemContractBaseTest;
27import org.apache.hadoop.fs.Path;
28
29public abstract class NativeS3FileSystemContractBaseTest
30  extends FileSystemContractBaseTest {
31 
32  private NativeFileSystemStore store;
33 
34  abstract NativeFileSystemStore getNativeFileSystemStore() throws IOException;
35
36  @Override
37  protected void setUp() throws Exception {
38    Configuration conf = new Configuration();
39    store = getNativeFileSystemStore();
40    fs = new NativeS3FileSystem(store);
41    fs.initialize(URI.create(conf.get("test.fs.s3n.name")), conf);
42  }
43 
44  @Override
45  protected void tearDown() throws Exception {
46    store.purge("test");
47    super.tearDown();
48  }
49 
50  public void testListStatusForRoot() throws Exception {
51    Path testDir = path("/test");
52    assertTrue(fs.mkdirs(testDir));
53   
54    FileStatus[] paths = fs.listStatus(path("/"));
55    assertEquals(1, paths.length);
56    assertEquals(path("/test"), paths[0].getPath());
57  }
58 
59}
Note: See TracBrowser for help on using the repository browser.