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