本文整理了Java中cz.seznam.euphoria.core.client.operator.FlatMap.named()
方法的一些代码示例,展示了FlatMap.named()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。FlatMap.named()
方法的具体详情如下:
包路径:cz.seznam.euphoria.core.client.operator.FlatMap
类名称:FlatMap
方法名:named
[英]Starts building a named FlatMap operator.
[中]开始构建命名的FlatMap操作符。
代码示例来源:origin: seznam/euphoria
DataSource<String> datasource = new SimpleHadoopTextFileSource(uri.toString());
Dataset<String> in = flow.createInput(datasource);
return FlatMap.named("PARSE-INPUT")
.of(in)
.using(new UnaryFunctor<String, Pair<Long, String>>() {
代码示例来源:origin: seznam/euphoria
/**
* Collects Avro record as JSON string
*
* @param outSink
* @param inSource
* @throws Exception
*/
public static void runFlow(
DataSink<String> outSink,
DataSource<Pair<AvroKey<GenericData.Record>, NullWritable>> inSource)
throws Exception {
Flow flow = Flow.create("simple read avro");
Dataset<Pair<AvroKey<GenericData.Record>, NullWritable>> input = flow.createInput(inSource);
final Dataset<String> output =
FlatMap.named("avro2csv").of(input).using(AvroSourceTest::apply).output();
output.persist(outSink);
Executor executor = new LocalExecutor();
executor.submit(flow).get();
}
代码示例来源:origin: seznam/euphoria
return FlatMap.named("FORMAT-OUTPUT")
.of(aggregated)
.using(((Pair<String, Long> elem, Collector<String> context) -> {
代码示例来源:origin: seznam/euphoria
final Dataset<String> words = FlatMap.named("TOKENIZER")
.of(lines)
.using((String line, Collector<String> c) ->
代码示例来源:origin: seznam/euphoria
@Test
public void testBuild() {
Flow flow = Flow.create("TEST");
Dataset<String> dataset = Util.createMockDataset(flow, 1);
Dataset<String> mapped = FlatMap.named("FlatMap1")
.of(dataset)
.using((String s, Collector<String> c) -> c.collect(s))
.output();
assertEquals(flow, mapped.getFlow());
assertEquals(1, flow.size());
FlatMap map = (FlatMap) flow.operators().iterator().next();
assertEquals(flow, map.getFlow());
assertEquals("FlatMap1", map.getName());
assertNotNull(map.getFunctor());
assertEquals(mapped, map.output());
assertNull(map.getEventTimeExtractor());
}
代码示例来源:origin: seznam/euphoria
@Test
public void testBuild_WithCounters() {
Flow flow = Flow.create("TEST");
Dataset<String> dataset = Util.createMockDataset(flow, 1);
Dataset<String> mapped = FlatMap.named("FlatMap1")
.of(dataset)
.using((String s, Collector<String> c) -> {
c.getCounter("my-counter").increment();
c.collect(s);
})
.output();
assertEquals(flow, mapped.getFlow());
assertEquals(1, flow.size());
FlatMap map = (FlatMap) flow.operators().iterator().next();
assertEquals(flow, map.getFlow());
assertEquals("FlatMap1", map.getName());
assertNotNull(map.getFunctor());
assertEquals(mapped, map.output());
}
代码示例来源:origin: seznam/euphoria
@Test
public void testBuild_EventTimeExtractor() {
Flow flow = Flow.create("TEST");
Dataset<String> dataset = Util.createMockDataset(flow, 1);
Dataset<BigDecimal> mapped = FlatMap.named("FlatMap2")
.of(dataset)
.using((String s, Collector<BigDecimal> c) -> c.collect(null))
.eventTimeBy(Long::parseLong) // ~ consuming the original input elements
.output();
assertEquals(flow, mapped.getFlow());
assertEquals(1, flow.size());
FlatMap map = (FlatMap) flow.operators().iterator().next();
assertEquals(flow, map.getFlow());
assertEquals("FlatMap2", map.getName());
assertNotNull(map.getFunctor());
assertEquals(mapped, map.output());
assertNotNull(map.getEventTimeExtractor());
}
内容来源于网络,如有侵权,请联系作者删除!