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 Closeableclose in interface AutoCloseableIOExceptionpublic PipesResult process(FetchEmitTuple t) throws IOException
IOExceptionCopyright © 2007–2021 The Apache Software Foundation. All rights reserved.