co.cask.cdap.format

Class CombinedLogRecordFormat

java.lang.Object

co.cask.cdap.api.data.format.RecordFormat<StreamEvent,T>

co.cask.cdap.spi.stream.AbstractStreamEventRecordFormat<co.cask.cdap.api.data.format.StructuredRecord>

co.cask.cdap.format.CombinedLogRecordFormat

public class CombinedLogRecordFormat
extends AbstractStreamEventRecordFormat<co.cask.cdap.api.data.format.StructuredRecord>

Stream record format that interprets stream body as data in Combined Log Format. CLF format: remote_host remote_login auth_user [date] "request" status content_length referrer user_agent Sample CLF data: 220.181.108.77 - - [01/Feb/2015:06:59:57 +0000] "GET / HTTP/1.1" 301 295 "-" "Mozilla/5.0 (compatible; Baiduspider/2.0; +http://www.baidu.com/search/spider.html)"

Field Summary

Fields inherited from class co.cask.cdap.api.data.format.RecordFormat

schema

Constructor Summary

Constructors

Constructor and Description
CombinedLogRecordFormat()

Method Summary

Methods

Modifier and Type	Method and Description
protected co.cask.cdap.api.data.schema.Schema	getDefaultSchema()
co.cask.cdap.api.data.format.StructuredRecord	read(StreamEvent event)
protected void	validateSchema(co.cask.cdap.api.data.schema.Schema desiredSchema)

Methods inherited from class co.cask.cdap.api.data.format.RecordFormat

configure, getSchema, initialize

Methods inherited from class java.lang.Object

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

Constructor Detail

CombinedLogRecordFormat

public CombinedLogRecordFormat()

Method Detail

read

public co.cask.cdap.api.data.format.StructuredRecord read(StreamEvent event)
                                                   throws co.cask.cdap.api.data.format.UnexpectedFormatException

Specified by:

read in class co.cask.cdap.api.data.format.RecordFormat<StreamEvent,co.cask.cdap.api.data.format.StructuredRecord>

Throws:

co.cask.cdap.api.data.format.UnexpectedFormatException

getDefaultSchema

protected co.cask.cdap.api.data.schema.Schema getDefaultSchema()

Specified by:

getDefaultSchema in class co.cask.cdap.api.data.format.RecordFormat<StreamEvent,co.cask.cdap.api.data.format.StructuredRecord>

validateSchema

protected void validateSchema(co.cask.cdap.api.data.schema.Schema desiredSchema)
                       throws co.cask.cdap.api.data.schema.UnsupportedTypeException

Specified by:

validateSchema in class co.cask.cdap.api.data.format.RecordFormat<StreamEvent,co.cask.cdap.api.data.format.StructuredRecord>

Throws:

co.cask.cdap.api.data.schema.UnsupportedTypeException