Uses of Class
org.wikimedia.gobblin.TimestampedRecord

Packages that use TimestampedRecord

Package	Description
org.wikimedia.gobblin.converter
org.wikimedia.gobblin.kafka
org.wikimedia.gobblin.writer
org.wikimedia.gobblin.writer.partitioner

Uses of TimestampedRecord in org.wikimedia.gobblin.converter

Methods in org.wikimedia.gobblin.converter that return types with arguments of type TimestampedRecord

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

Methods in org.wikimedia.gobblin.converter with parameters of type TimestampedRecord

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

Uses of TimestampedRecord in org.wikimedia.gobblin.kafka

Methods in org.wikimedia.gobblin.kafka that return TimestampedRecord

Modifier and Type	Method and Description
protected TimestampedRecord<P>	Kafka1TimestampedRecordExtractor.decodeKafkaMessage(org.apache.gobblin.kafka.client.KafkaConsumerRecord message) We need to override this protected method as the kafka timestamp information is not available in the KafkaExtractor.decodeRecord(ByteArrayBasedKafkaRecord) abstract method.

Uses of TimestampedRecord in org.wikimedia.gobblin.writer

Methods in org.wikimedia.gobblin.writer with parameters of type TimestampedRecord

Modifier and Type	Method and Description
void	TimestampedRecordWriterWrapper.write(TimestampedRecord<P> untypedRecord)

Uses of TimestampedRecord in org.wikimedia.gobblin.writer.partitioner

Methods in org.wikimedia.gobblin.writer.partitioner with parameters of type TimestampedRecord

Modifier and Type	Method and Description
long	TimestampedRecordTimeBasedWriterPartitioner.getRecordTimestamp(TimestampedRecord<P> rec)