// Path: com.ibm.streamsx.hdfs/impl/java/src/com/ibm/streamsx/hdfs/client/IHdfsClient.java
// public interface IHdfsClient {
// 
// 	public FileSystem connect(String fileSystemUri, String hdfsUser, String configPath) throws Exception;
// 
// 	public InputStream getInputStream(String filePath) throws IOException;
// 
// 	public OutputStream getOutputStream(String filePath, boolean append) throws IOException;
// 
// 	public FileStatus[] scanDirectory(String dirPath, String filter) throws IOException;
// 
// 	public boolean exists(String filePath) throws IOException;
// 
// 	public boolean isDirectory(String filePath) throws IOException;
// 
// 	public long getFileSize(String filename) throws IOException;
// 
// 	public boolean rename(String src, String dst) throws IOException;
// 
// 	public boolean delete(String filePath, boolean recursive) throws IOException;
// 
// 	public void disconnect() throws Exception;
// 
// 	public void setConnectionProperty(String name, String value);
// 
// 	public String getConnectionProperty(String name);
// 
// 	public Map<String, String> getConnectionProperties();
// }


import java.io.IOException;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.nio.ByteBuffer;
import com.ibm.streams.operator.OperatorContext;
import com.ibm.streams.operator.Tuple;
import com.ibm.streams.operator.Type.MetaType;
import com.ibm.streams.operator.types.RString;
import com.ibm.streamsx.hdfs.client.IHdfsClient;
/*******************************************************************************
* Copyright (C) 2014-2019, International Business Machines Corporation
* All Rights Reserved
*******************************************************************************/
package com.ibm.streamsx.hdfs;




enum EnumFileExpirationPolicy {
	NEVER, SIZE, TUPLECNT, PUNC, TIME
}

public class HdfsFile {

// Path: com.ibm.streamsx.hdfs/impl/java/src/com/ibm/streamsx/hdfs/client/IHdfsClient.java
// public interface IHdfsClient {
// 
// 	public FileSystem connect(String fileSystemUri, String hdfsUser, String configPath) throws Exception;
// 
// 	public InputStream getInputStream(String filePath) throws IOException;
// 
// 	public OutputStream getOutputStream(String filePath, boolean append) throws IOException;
// 
// 	public FileStatus[] scanDirectory(String dirPath, String filter) throws IOException;
// 
// 	public boolean exists(String filePath) throws IOException;
// 
// 	public boolean isDirectory(String filePath) throws IOException;
// 
// 	public long getFileSize(String filename) throws IOException;
// 
// 	public boolean rename(String src, String dst) throws IOException;
// 
// 	public boolean delete(String filePath, boolean recursive) throws IOException;
// 
// 	public void disconnect() throws Exception;
// 
// 	public void setConnectionProperty(String name, String value);
// 
// 	public String getConnectionProperty(String name);
// 
// 	public Map<String, String> getConnectionProperties();
// }


// Path: com.ibm.streamsx.hdfs/impl/java/src/com/ibm/streamsx/hdfs/HdfsFile.java
import java.io.IOException;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.nio.ByteBuffer;
import com.ibm.streams.operator.OperatorContext;
import com.ibm.streams.operator.Tuple;
import com.ibm.streams.operator.Type.MetaType;
import com.ibm.streams.operator.types.RString;
import com.ibm.streamsx.hdfs.client.IHdfsClient;

/*******************************************************************************
* Copyright (C) 2014-2019, International Business Machines Corporation
* All Rights Reserved
*******************************************************************************/
package com.ibm.streamsx.hdfs;




enum EnumFileExpirationPolicy {
	NEVER, SIZE, TUPLECNT, PUNC, TIME
}

public class HdfsFile {

	private IHdfsClient fHdfsClient;