org.wikimedia.gobblin.converter

Class TimestampedRecordConverterWrapper<I,O>

java.lang.Object

org.apache.gobblin.converter.Converter<String,String,TimestampedRecord<I>,TimestampedRecord<O>>

org.wikimedia.gobblin.converter.TimestampedRecordConverterWrapper<I,O>

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.gobblin.records.RecordStreamProcessor<String,String,TimestampedRecord<I>,TimestampedRecord<O>>, org.apache.gobblin.util.FinalState

public class TimestampedRecordConverterWrapper<I,O>
extends org.apache.gobblin.converter.Converter<String,String,TimestampedRecord<I>,TimestampedRecord<O>>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.gobblin.records.RecordStreamProcessor

org.apache.gobblin.records.RecordStreamProcessor.StreamProcessingException

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONVERTER_TIMESTAMPED_RECORD_WRAPPED

Constructor Summary

Constructors

Constructor and Description
TimestampedRecordConverterWrapper()

Method Summary

Modifier and Type	Method and Description
Iterable<TimestampedRecord<O>>	convertRecord(String outputSchema, TimestampedRecord<I> inputRecord, org.apache.gobblin.configuration.WorkUnitState workUnit)
String	convertSchema(String inputSchema, org.apache.gobblin.configuration.WorkUnitState workUnit)
org.apache.gobblin.converter.Converter<String,String,TimestampedRecord<I>,TimestampedRecord<O>>	init(org.apache.gobblin.configuration.WorkUnitState workUnit)

Methods inherited from class org.apache.gobblin.converter.Converter

close, convertRecordEnvelope, getFinalState, getInitializer, getMessageHandler, processStream

Methods inherited from class java.lang.Object

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

Field Detail

CONVERTER_TIMESTAMPED_RECORD_WRAPPED

public static final String CONVERTER_TIMESTAMPED_RECORD_WRAPPED

See Also:

Constant Field Values

Constructor Detail

TimestampedRecordConverterWrapper

public TimestampedRecordConverterWrapper()

Method Detail

init

public org.apache.gobblin.converter.Converter<String,String,TimestampedRecord<I>,TimestampedRecord<O>> init(org.apache.gobblin.configuration.WorkUnitState workUnit)

Overrides:

init in class org.apache.gobblin.converter.Converter<String,String,TimestampedRecord<I>,TimestampedRecord<O>>

convertSchema

public String convertSchema(String inputSchema,
                            org.apache.gobblin.configuration.WorkUnitState workUnit)
                     throws org.apache.gobblin.converter.SchemaConversionException

Specified by:

convertSchema in class org.apache.gobblin.converter.Converter<String,String,TimestampedRecord<I>,TimestampedRecord<O>>

Throws:

org.apache.gobblin.converter.SchemaConversionException

convertRecord

public Iterable<TimestampedRecord<O>> convertRecord(String outputSchema,
                                                    TimestampedRecord<I> inputRecord,
                                                    org.apache.gobblin.configuration.WorkUnitState workUnit)
                                             throws org.apache.gobblin.converter.DataConversionException

Specified by:

convertRecord in class org.apache.gobblin.converter.Converter<String,String,TimestampedRecord<I>,TimestampedRecord<O>>

Throws:

org.apache.gobblin.converter.DataConversionException