org.apache.hawq.pxf.api

Class FragmentsStats

java.lang.Object

org.apache.hawq.pxf.api.FragmentsStats

public class FragmentsStats
extends java.lang.Object

FragmentsStats holds statistics for a given path.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	FragmentsStats.SizeAndUnit Container for size and unit
static class	FragmentsStats.SizeUnit Enum to represent unit (Bytes/KB/MB/GB/TB)

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_FRAGMENT_SIZE Default fragment size.

Constructor Summary

Constructors

Constructor and Description
FragmentsStats(long fragmentsNumber, long firstFragmentSize, long totalSize) Constructs an FragmentsStats.

Method Summary

Modifier and Type	Method and Description
static java.lang.String	dataToJSON(FragmentsStats stats) Given a FragmentsStats, serialize it in JSON to be used as the result string for HAWQ.
static java.lang.String	dataToString(FragmentsStats stats, java.lang.String datapath) Given a stats structure, convert it to be readable.
FragmentsStats.SizeAndUnit	getFirstFragmentSize() Returns the size in bytes of the first fragment.
long	getFragmentsNumber() Returns number of fragments for a given data source.
FragmentsStats.SizeAndUnit	getTotalSize() Returns the total size of a given source.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_FRAGMENT_SIZE

public static final long DEFAULT_FRAGMENT_SIZE

Default fragment size. Assuming a fragment is equivalent to a block in HDFS, we guess a full fragment size is 64MB.

See Also:

Constant Field Values

Constructor Detail

FragmentsStats

public FragmentsStats(long fragmentsNumber,
                      long firstFragmentSize,
                      long totalSize)

Constructs an FragmentsStats.

Parameters:

fragmentsNumber - number of fragments

firstFragmentSize - first fragment size (in bytes)

totalSize - total size (in bytes)

Method Detail

dataToJSON

public static java.lang.String dataToJSON(FragmentsStats stats)
                                   throws java.io.IOException

Given a FragmentsStats, serialize it in JSON to be used as the result string for HAWQ. An example result is as follows: {"PXFFragmentsStats":{"fragmentsNumber":3,"firstFragmentSize":{"size"=67108864,"unit":"B"},"totalSize":{"size"=200000000,"unit"="B"}}}

Parameters:

stats - the data to be serialized

Returns:

the result in json format

Throws:

java.io.IOException - if converting to JSON format failed

dataToString

public static java.lang.String dataToString(FragmentsStats stats,
                                            java.lang.String datapath)

Given a stats structure, convert it to be readable. Intended for debugging purposes only.

Parameters:

stats - the data to be stringify

datapath - the data path part of the original URI (e.g., table name, *.csv, etc.)

Returns:

the stringified data

getFragmentsNumber

public long getFragmentsNumber()

Returns number of fragments for a given data source.

Returns:

number of fragments

getFirstFragmentSize

public FragmentsStats.SizeAndUnit getFirstFragmentSize()

Returns the size in bytes of the first fragment.

Returns:

first fragment size (in byte)

getTotalSize

public FragmentsStats.SizeAndUnit getTotalSize()

Returns the total size of a given source. Usually it means the aggregation of all its fragments size.

Returns:

total size