import org.openstreetmap.osmosis.osmbinary.file.BlockInputStream; //导入依赖的package包/类
@Override
public void copyTo(OSMEntitySink sink) throws IOException {
    entitySink = sink;
    entitySink.writeBegin();
    new BlockInputStream(inputStream, this).process();
    entitySink.writeEnd();
}
 

import org.openstreetmap.osmosis.osmbinary.file.BlockInputStream; //导入依赖的package包/类
private static void loadFileToHdfs(
		java.nio.file.Path file,
		OsmAvroBinaryParser parser ) {

	InputStream is = null;
	try {
		is = new FileInputStream(
				file.toFile());
		new BlockInputStream(
				is,
				parser).process();
	}
	catch (FileNotFoundException e) {
		LOGGER.error(
				"Unable to load file: " + file.toString(),
				e);
	}
	catch (IOException e1) {
		LOGGER.error(
				"Unable to process file: " + file.toString(),
				e1);
	}
	finally {
		IOUtils.closeQuietly(is);
	}

}
 

import org.openstreetmap.osmosis.osmbinary.file.BlockInputStream; //导入依赖的package包/类
public static OsmData process(InputStream is) {
	OsmPbfParser parser = new OsmPbfParser();

	try {
		(new BlockInputStream(is, parser)).process();
	} catch (IOException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
		return null;
	}

	return parser.getData();
}
 

import org.openstreetmap.osmosis.osmbinary.file.BlockInputStream; //导入依赖的package包/类
public static OSMData process(InputStream is){
	OsmPbfParser parser = new OsmPbfParser();

	try {
		(new BlockInputStream(is, parser)).process();
	} catch (IOException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
		return null;
	}

	return parser.getData();
}
 

import org.openstreetmap.osmosis.osmbinary.file.BlockInputStream; //导入依赖的package包/类
public static List<GeoNode> openPBFFile( InputStream input ) throws IOException {
    OSMReader reader = new OSMReader();
    new BlockInputStream(input, reader).process();
    return reader.savedPlaces;
}