Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package mypack;
- import org.apache.hadoop.conf.Configuration;
- import org.apache.hadoop.fs.FSDataInputStream;
- import org.apache.hadoop.fs.FileSystem;
- import org.apache.hadoop.fs.Path;
- import org.apache.hadoop.io.BytesWritable;
- import org.apache.hadoop.io.IOUtils;
- import org.apache.hadoop.io.SequenceFile;
- import org.apache.hadoop.io.Text;
- public class ImageToSeq {
- public static void main(String args[]) throws Exception {
- Configuration confHadoop = new Configuration();
- confHadoop.addResource(new Path("/hadoop/projects/hadoop-1.0.4/conf/core-site.xml"));
- confHadoop.addResource(new Path("/hadoop/projects/hadoop-1.0.4/conf/hdfs-site.xml"));
- FileSystem fs = FileSystem.get(confHadoop);
- Path inPath = new Path("/mapin/1.png");
- Path outPath = new Path("/mapin/11.png");
- FSDataInputStream in = null;
- Text key = new Text();
- BytesWritable value = new BytesWritable();
- SequenceFile.Writer writer = null;
- try{
- in = fs.open(inPath);
- byte buffer[] = new byte[in.available()];
- in.read(buffer);
- writer = SequenceFile.createWriter(fs, confHadoop, outPath, key.getClass(),value.getClass());
- writer.append(new Text(inPath.getName()), new BytesWritable(buffer));
- }catch (Exception e) {
- System.out.println("Exception MESSAGES = "+e.getMessage());
- }
- finally {
- IOUtils.closeStream(writer);
- System.out.println("last line of the code....!!!!!!!!!!");
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement