public class CSVOutputUtils
extends java.lang.Object
If setting the optional generic String value, can embed a list by encapsulating in quotations: i.e., "thing1,thing2,thing3"
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
EMPTYFIELD |
Constructor and Description |
---|
CSVOutputUtils() |
Modifier and Type | Method and Description |
---|---|
static java.lang.String[] |
extractCSVOutput(java.lang.String value) |
static java.lang.String[] |
extractCSVOutput(org.apache.hadoop.io.Text value) |
static java.lang.String |
extractCSVOutputByFieldNum(java.lang.String csvOut,
int fieldNum)
Used for testing
|
static java.lang.String |
extractCSVOutputDomain(org.apache.hadoop.io.Text value) |
static void |
extractCSVOutputIdentity(org.apache.hadoop.io.Text key,
org.apache.hadoop.io.Text value,
org.apache.hadoop.io.Text input) |
static void |
extractCSVOutputIdentityStripFirstField(org.apache.hadoop.io.Text value,
org.apache.hadoop.io.Text input) |
static java.lang.String |
extractCSVOutputIP(org.apache.hadoop.io.Text value) |
static java.lang.String |
extractCSVOutputLineDomain(java.lang.String csvOut)
Used for testing -- input is a full csv line:
|
static java.lang.String |
extractCSVOutputLineFreq(java.lang.String csvOut)
Used for testing -- input is a full csv line:
|
static java.lang.String |
extractCSVOutputTimestamp(org.apache.hadoop.io.Text value) |
static org.apache.hadoop.io.Text |
setCSVOutput(java.lang.String domain,
java.lang.String ip,
java.lang.String timestamp) |
static org.apache.hadoop.io.Text |
setCSVOutput(java.lang.String domain,
java.lang.String ip,
java.lang.String timestamp,
java.lang.String generic) |
static void |
setCSVOutput(org.apache.hadoop.io.Text value,
java.lang.String domain,
java.lang.String ip,
java.lang.String timestamp) |
static void |
setCSVOutput(org.apache.hadoop.io.Text value,
java.lang.String domain,
java.lang.String ip,
java.lang.String timestamp,
java.lang.String generic) |
static java.lang.String |
setFullCSVLine(int frequency,
java.lang.String domain,
java.lang.String ip,
java.lang.String timestamp)
Used for testing
|
static java.lang.String |
setFullCSVLine(int frequency,
java.lang.String domain,
java.lang.String ip,
java.lang.String timestamp,
java.lang.String generic)
Used for testing
|
static java.lang.String |
setFullCSVLine(java.lang.String frequency,
java.lang.String domain,
java.lang.String ip,
java.lang.String timestamp)
Used for testing
|
public static org.apache.hadoop.io.Text setCSVOutput(java.lang.String domain, java.lang.String ip, java.lang.String timestamp)
public static org.apache.hadoop.io.Text setCSVOutput(java.lang.String domain, java.lang.String ip, java.lang.String timestamp, java.lang.String generic)
public static void setCSVOutput(org.apache.hadoop.io.Text value, java.lang.String domain, java.lang.String ip, java.lang.String timestamp)
public static void setCSVOutput(org.apache.hadoop.io.Text value, java.lang.String domain, java.lang.String ip, java.lang.String timestamp, java.lang.String generic)
public static java.lang.String[] extractCSVOutput(org.apache.hadoop.io.Text value)
public static java.lang.String[] extractCSVOutput(java.lang.String value)
public static void extractCSVOutputIdentity(org.apache.hadoop.io.Text key, org.apache.hadoop.io.Text value, org.apache.hadoop.io.Text input)
public static void extractCSVOutputIdentityStripFirstField(org.apache.hadoop.io.Text value, org.apache.hadoop.io.Text input)
public static java.lang.String extractCSVOutputDomain(org.apache.hadoop.io.Text value)
public static java.lang.String extractCSVOutputIP(org.apache.hadoop.io.Text value)
public static java.lang.String extractCSVOutputTimestamp(org.apache.hadoop.io.Text value)
public static java.lang.String extractCSVOutputByFieldNum(java.lang.String csvOut, int fieldNum)
public static java.lang.String extractCSVOutputLineDomain(java.lang.String csvOut)
public static java.lang.String extractCSVOutputLineFreq(java.lang.String csvOut)
public static java.lang.String setFullCSVLine(int frequency, java.lang.String domain, java.lang.String ip, java.lang.String timestamp)
public static java.lang.String setFullCSVLine(int frequency, java.lang.String domain, java.lang.String ip, java.lang.String timestamp, java.lang.String generic)
public static java.lang.String setFullCSVLine(java.lang.String frequency, java.lang.String domain, java.lang.String ip, java.lang.String timestamp)