pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/HdfsResources.java [28:49]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class HdfsResources {

    private final Configuration configuration;
    private final FileSystem fileSystem;
    private final UserGroupInformation userGroupInformation;

    public HdfsResources(Configuration config, FileSystem fs, UserGroupInformation ugi) {
        this.configuration = config;
        this.fileSystem = fs;
        this.userGroupInformation = ugi;
    }

    public Configuration getConfiguration() {
        return configuration;
    }

    public FileSystem getFileSystem() {
        return fileSystem;
    }

    public UserGroupInformation getUserGroupInformation() {
        return userGroupInformation;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/HdfsResources.java [28:49]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class HdfsResources {

    private final Configuration configuration;
    private final FileSystem fileSystem;
    private final UserGroupInformation userGroupInformation;

    public HdfsResources(Configuration config, FileSystem fs, UserGroupInformation ugi) {
        this.configuration = config;
        this.fileSystem = fs;
        this.userGroupInformation = ugi;
    }

    public Configuration getConfiguration() {
        return configuration;
    }

    public FileSystem getFileSystem() {
        return fileSystem;
    }

    public UserGroupInformation getUserGroupInformation() {
        return userGroupInformation;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -