public class PipesParser extends Object implements Closeable
Constructor and Description |
---|
PipesParser(PipesConfig pipesConfig) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
PipesResult |
parse(FetchEmitTuple t) |
public PipesParser(PipesConfig pipesConfig)
public PipesResult parse(FetchEmitTuple t) throws InterruptedException, PipesException, IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.