
__author__ = 'Dongjoon Hyun (dongjoon@apache.org)'
__license__ = 'Apache License'
__version__ = '0.2'

from fabric.api import *


@task
def ls(inpath='/'):
    """
    fab hdfs.ls:/sample
    """
    cmd = '/usr/bin/hadoop fs -ls %(inpath)s 2> /dev/null' % locals()
    run(cmd)


@task
def count(inpath):
    """
    fab hdfs.count:/data/text/newsgroup
    """
    cmd = '/usr/bin/hadoop fs -count %(inpath)s 2> /dev/null' % locals()
    run(cmd)


@task
def du(inpath):
    """
    fab hdfs.du:/sample
    """
    cmd = '/usr/bin/hadoop fs -du -h %(inpath)s 2> /dev/null' % locals()
    run(cmd)


@task
def text(inpath, count=5):
    """
    fab hdfs.text:/sample/hani_news.head.txt.gz,5
    """
    cmd = '/usr/bin/hadoop fs -text %(inpath)s 2> /dev/null | head -n %(count)s' % locals()
    run(cmd)


__author__ = 'Dongjoon Hyun (dongjoon@apache.org)'
__license__ = 'Apache License'
__version__ = '0.2'

from fabric.api import *


@task
def ls(inpath='/'):
    """
    fab hdfs.ls:/sample
    """
    cmd = '/usr/bin/hadoop fs -ls %(inpath)s 2> /dev/null' % locals()
    run(cmd)


@task
def count(inpath):
    """
    fab hdfs.count:/data/text/newsgroup
    """
    cmd = '/usr/bin/hadoop fs -count %(inpath)s 2> /dev/null' % locals()
    run(cmd)


@task
def du(inpath):
    """
    fab hdfs.du:/sample
    """
    cmd = '/usr/bin/hadoop fs -du -h %(inpath)s 2> /dev/null' % locals()
    run(cmd)


@task
def text(inpath, count=0):
    """
    fab hdfs.text:/sample/hani_news.head.txt.gz,5
    """
    if count == 0:
        cmd = '/usr/bin/hadoop fs -text %(inpath)s 2> /dev/null' % locals()
    else:
        cmd = '/usr/bin/hadoop fs -text %(inpath)s 2> /dev/null | head -n %(count)s' % locals()
    run(cmd)

Change default value for line number
Change default value for line number

  
  __author__ = 'Dongjoon Hyun (dongjoon@apache.org)'
  __license__ = 'Apache License'
  __version__ = '0.2'
  
  from fabric.api import *
  
  
  @task
  def ls(inpath='/'):
      """
      fab hdfs.ls:/sample
      """
      cmd = '/usr/bin/hadoop fs -ls %(inpath)s 2> /dev/null' % locals()
      run(cmd)
  
  
  @task
  def count(inpath):
      """
      fab hdfs.count:/data/text/newsgroup
      """
      cmd = '/usr/bin/hadoop fs -count %(inpath)s 2> /dev/null' % locals()
      run(cmd)
  
  
  @task
  def du(inpath):
      """
      fab hdfs.du:/sample
      """
      cmd = '/usr/bin/hadoop fs -du -h %(inpath)s 2> /dev/null' % locals()
      run(cmd)
  
  
  @task
- def text(inpath, count=5):
+ def text(inpath, count=0):
      """
      fab hdfs.text:/sample/hani_news.head.txt.gz,5
      """
+     if count == 0:
+         cmd = '/usr/bin/hadoop fs -text %(inpath)s 2> /dev/null' % locals()
+     else:
-     cmd = '/usr/bin/hadoop fs -text %(inpath)s 2> /dev/null | head -n %(count)s' % locals()
+         cmd = '/usr/bin/hadoop fs -text %(inpath)s 2> /dev/null | head -n %(count)s' % locals()
      run(cmd)
  
Change default value for line number
## Code Before:

__author__ = 'Dongjoon Hyun (dongjoon@apache.org)'
__license__ = 'Apache License'
__version__ = '0.2'

from fabric.api import *


@task
def ls(inpath='/'):
    """
    fab hdfs.ls:/sample
    """
    cmd = '/usr/bin/hadoop fs -ls %(inpath)s 2> /dev/null' % locals()
    run(cmd)


@task
def count(inpath):
    """
    fab hdfs.count:/data/text/newsgroup
    """
    cmd = '/usr/bin/hadoop fs -count %(inpath)s 2> /dev/null' % locals()
    run(cmd)


@task
def du(inpath):
    """
    fab hdfs.du:/sample
    """
    cmd = '/usr/bin/hadoop fs -du -h %(inpath)s 2> /dev/null' % locals()
    run(cmd)


@task
def text(inpath, count=5):
    """
    fab hdfs.text:/sample/hani_news.head.txt.gz,5
    """
    cmd = '/usr/bin/hadoop fs -text %(inpath)s 2> /dev/null | head -n %(count)s' % locals()
    run(cmd)

## Instruction:
Change default value for line number
## Code After:

__author__ = 'Dongjoon Hyun (dongjoon@apache.org)'
__license__ = 'Apache License'
__version__ = '0.2'

from fabric.api import *


@task
def ls(inpath='/'):
    """
    fab hdfs.ls:/sample
    """
    cmd = '/usr/bin/hadoop fs -ls %(inpath)s 2> /dev/null' % locals()
    run(cmd)


@task
def count(inpath):
    """
    fab hdfs.count:/data/text/newsgroup
    """
    cmd = '/usr/bin/hadoop fs -count %(inpath)s 2> /dev/null' % locals()
    run(cmd)


@task
def du(inpath):
    """
    fab hdfs.du:/sample
    """
    cmd = '/usr/bin/hadoop fs -du -h %(inpath)s 2> /dev/null' % locals()
    run(cmd)


@task
def text(inpath, count=0):
    """
    fab hdfs.text:/sample/hani_news.head.txt.gz,5
    """
    if count == 0:
        cmd = '/usr/bin/hadoop fs -text %(inpath)s 2> /dev/null' % locals()
    else:
        cmd = '/usr/bin/hadoop fs -text %(inpath)s 2> /dev/null | head -n %(count)s' % locals()
    run(cmd)
