net.nutch.fs
Class TestClient

java.lang.Object
  net.nutch.ipc.Client
      net.nutch.fs.TestClient

All Implemented Interfaces:

FSConstants

public class TestClient

extends Client

implements FSConstants

This class tests the NutchFS system.

Author:

Mike Cafarella

Field Summary

Fields inherited from class net.nutch.ipc.Client

LOG

Fields inherited from interface net.nutch.fs.FSConstants

BLOCK_SIZE, BLOCKREPORT_INTERVAL, CHUNKED_ENCODING, DATANODE_STARTUP_PERIOD, FILE_COMPLETE_FAILED, FILE_COMPLETE_ONGOING, FILE_COMPLETE_SUCCESS, HEARTBEAT_INTERVAL, OP_ACK, OP_BLOCKRECEIVED, OP_BLOCKREPORT, OP_CLIENT_ADDBLOCK, OP_CLIENT_ADDBLOCK_ACK, OP_CLIENT_COMPLETEFILE, OP_CLIENT_COMPLETEFILE_ACK, OP_CLIENT_DELETE, OP_CLIENT_DELETE_ACK, OP_CLIENT_LISTING, OP_CLIENT_LISTING_ACK, OP_CLIENT_OPEN, OP_CLIENT_OPEN_ACK, OP_CLIENT_RENAMETO, OP_CLIENT_RENAMETO_ACK, OP_CLIENT_STARTFILE, OP_CLIENT_STARTFILE_ACK, OP_CLIENT_TRYAGAIN, OP_ERROR, OP_FAILURE, OP_HEARTBEAT, OP_INVALIDATE_BLOCKS, OP_READ_BLOCK, OP_TRANSFERBLOCKS, OP_TRANSFERDATA, OP_WRITE_BLOCK, RUNLENGTH_ENCODING, SYSTEM_STARTUP_PERIOD

Constructor Summary

TestClient(InetSocketAddress addr)

Method Summary

void	delete(String srcf) Delete an NDFS file
void	ls(String src) Get a listing of all files in NDFS at the indicated name
static void	main(String[] argv) main() has some simple utility methods
void	rename(String srcf, String dstf) Rename an NDFS file

Methods inherited from class net.nutch.ipc.Client

call, call, setTimeout, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestClient

public TestClient(InetSocketAddress addr)

Method Detail

ls

public void ls(String src)
        throws IOException

Get a listing of all files in NDFS at the indicated name

Throws:

IOException

rename

public void rename(String srcf,
                   String dstf)
            throws IOException

Rename an NDFS file

Throws:

IOException

delete

public void delete(String srcf)
            throws IOException

Delete an NDFS file

Throws:

IOException

main

public static void main(String[] argv)
                 throws IOException

main() has some simple utility methods

Throws:

IOException