co.cask.cdap.format

Class GrokRecordFormat

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.GrokRecordFormat

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

GrokRecordFormat. Grok parses a string and outputs a map of field name (string) to value (string).

Field Summary

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

schema

Constructor Summary

Constructors

Constructor and Description
GrokRecordFormat()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	addPattern(oi.thekraken.grok.api.Grok grok, String resource)
protected void	addPatterns(oi.thekraken.grok.api.Grok grok)
protected void	configure(Map<String,String> settings)
protected String	determinePattern(Map<String,String> settings)
protected co.cask.cdap.api.data.schema.Schema	getDefaultSchema()
String	getPattern()
co.cask.cdap.api.data.format.StructuredRecord	read(StreamEvent event)
static Map<String,String>	settings(String pattern)
protected void	validateSchema(co.cask.cdap.api.data.schema.Schema desiredSchema)

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

getSchema, initialize

Methods inherited from class java.lang.Object

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

Constructor Detail

GrokRecordFormat

public GrokRecordFormat()

Method Detail

settings

public static Map<String,String> settings(String pattern)

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

configure

protected void configure(Map<String,String> settings)

Overrides:

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

addPatterns

protected void addPatterns(oi.thekraken.grok.api.Grok grok)

determinePattern

protected String determinePattern(Map<String,String> settings)

addPattern

protected void addPattern(oi.thekraken.grok.api.Grok grok,
              String resource)

getPattern

public String getPattern()