public class LineReadWriteUtil extends Object
Modifier and Type | Method and Description |
---|---|
String |
convertResultToString(StreamsDatum entry) |
static LineReadWriteUtil |
getInstance() |
static LineReadWriteUtil |
getInstance(LineReadWriteConfiguration configuration) |
Map<String,Object> |
parseMap(String field) |
org.joda.time.DateTime |
parseTs(String field) |
StreamsDatum |
processLine(String line) |
public static LineReadWriteUtil getInstance()
public static LineReadWriteUtil getInstance(LineReadWriteConfiguration configuration)
public StreamsDatum processLine(String line)
public String convertResultToString(StreamsDatum entry)
public org.joda.time.DateTime parseTs(String field)
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.