public class PipesClient extends Object implements Closeable
Constructor and Description |
---|
PipesClient(PipesConfigBase pipesConfig) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
int |
getFilesProcessed() |
PipesResult |
process(FetchEmitTuple t) |
public PipesClient(PipesConfigBase pipesConfig)
public int getFilesProcessed()
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public PipesResult process(FetchEmitTuple t) throws IOException
IOException
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.