Package com.logicalclocks.hsfs.flink.engine

Class PojoToAvroRecord<T>

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.api.common.functions.RichMapFunction<T,org.apache.avro.generic.GenericRecord>

com.logicalclocks.hsfs.flink.engine.PojoToAvroRecord<T>

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.MapFunction<T,org.apache.avro.generic.GenericRecord>, org.apache.flink.api.common.functions.RichFunction, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.avro.generic.GenericRecord>

public class PojoToAvroRecord<T>
extends org.apache.flink.api.common.functions.RichMapFunction<T,org.apache.avro.generic.GenericRecord>
implements org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.avro.generic.GenericRecord>

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
PojoToAvroRecord(String featureGroupSchema, String encodedFeatureGroupSchema, Map<String,String> complexFeatureSchemas)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.avro.generic.GenericRecord>	getProducedType()
void	init()
org.apache.avro.generic.GenericRecord	map(T input)

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

Methods inherited from class java.lang.Object

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

Constructor Details

PojoToAvroRecord

public PojoToAvroRecord(String featureGroupSchema,
 String encodedFeatureGroupSchema,
 Map<String,String> complexFeatureSchemas)

Method Details

init

public void init()
          throws Exception

Throws:

Exception

map

public org.apache.avro.generic.GenericRecord map(T input)
                                          throws Exception

Specified by:

map in interface org.apache.flink.api.common.functions.MapFunction<T,org.apache.avro.generic.GenericRecord>

Specified by:

map in class org.apache.flink.api.common.functions.RichMapFunction<T,org.apache.avro.generic.GenericRecord>

Throws:

Exception

getProducedType

public org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.avro.generic.GenericRecord> getProducedType()

Specified by:

getProducedType in interface org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>