voldemort.tools.admin.command
Class AdminCommandStream.SubCommandStreamFetchEntries

java.lang.Object
  extended by voldemort.tools.admin.command.AbstractAdminCommand
      extended by voldemort.tools.admin.command.AdminCommandStream.SubCommandStreamFetchEntries
Enclosing class:
AdminCommandStream

public static class AdminCommandStream.SubCommandStreamFetchEntries
extends AbstractAdminCommand

stream fetch-entries command


Constructor Summary
AdminCommandStream.SubCommandStreamFetchEntries()
           
 
Method Summary
static void doStreamFetchEntries(AdminClient adminClient, java.lang.Integer nodeId, java.util.List<java.lang.String> storeNames, java.util.List<java.lang.Integer> partIds, java.lang.Boolean orphaned, java.io.File directory, java.lang.String format)
          Fetches entries from a given node.
static void executeCommand(java.lang.String[] args)
          Parses command-line and fetches entries from a given node.
protected static joptsimple.OptionParser getParser()
          Initializes parser
static void printHelp(java.io.PrintStream stream)
          Prints help menu for command.
 
Methods inherited from class voldemort.tools.admin.command.AbstractAdminCommand
executeHelp
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AdminCommandStream.SubCommandStreamFetchEntries

public AdminCommandStream.SubCommandStreamFetchEntries()
Method Detail

getParser

protected static joptsimple.OptionParser getParser()
Initializes parser

Returns:
OptionParser object with all available options

printHelp

public static void printHelp(java.io.PrintStream stream)
                      throws java.io.IOException
Prints help menu for command.

Parameters:
stream - PrintStream object for output
Throws:
java.io.IOException

executeCommand

public static void executeCommand(java.lang.String[] args)
                           throws java.io.IOException
Parses command-line and fetches entries from a given node.

Parameters:
args - Command-line input
printHelp - Tells whether to print help only or execute command actually
Throws:
java.io.IOException

doStreamFetchEntries

public static void doStreamFetchEntries(AdminClient adminClient,
                                        java.lang.Integer nodeId,
                                        java.util.List<java.lang.String> storeNames,
                                        java.util.List<java.lang.Integer> partIds,
                                        java.lang.Boolean orphaned,
                                        java.io.File directory,
                                        java.lang.String format)
                                 throws java.io.IOException
Fetches entries from a given node.

Parameters:
adminClient - An instance of AdminClient points to given cluster
nodeId - Node id to fetch entries from
storeNames - List of stores to fetch from
partIds - List of partitions to fetch from
orphaned - Tells if orphaned entries to be fetched
directory - File object of directory to output to
format - output format
Throws:
java.io.IOException


Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu