public static class dVMP.ParallelVBMapInference extends org.apache.flink.api.common.functions.RichFlatMapFunction<DataOnMemory<DataInstance>,DataPosterior>
Constructor and Description |
---|
ParallelVBMapInference() |
Modifier and Type | Method and Description |
---|---|
void |
flatMap(DataOnMemory<DataInstance> dataBatch,
org.apache.flink.util.Collector<DataPosterior> out) |
void |
open(org.apache.flink.configuration.Configuration parameters) |
public void flatMap(DataOnMemory<DataInstance> dataBatch, org.apache.flink.util.Collector<DataPosterior> out)
flatMap
in interface org.apache.flink.api.common.functions.FlatMapFunction<DataOnMemory<DataInstance>,DataPosterior>
flatMap
in class org.apache.flink.api.common.functions.RichFlatMapFunction<DataOnMemory<DataInstance>,DataPosterior>
Copyright © 2017. All rights reserved.