public static class EsFactory.EsScheme extends Scheme
| Modifier and Type | Method and Description |
|---|---|
void |
sink(FlowProcess flowProcess,
SinkCall sinkCall) |
void |
sinkConfInit(FlowProcess flowProcess,
Tap tap,
Object conf) |
boolean |
source(FlowProcess flowProcess,
SourceCall sourceCall) |
void |
sourceConfInit(FlowProcess flowProcess,
Tap tap,
Object conf) |
equals, getNumSinkParts, getSinkFields, getSourceFields, getTrace, hashCode, isSink, isSource, isSymmetrical, presentSinkFields, presentSinkFieldsInternal, presentSourceFields, presentSourceFieldsInternal, retrieveSinkFields, retrieveSourceFields, setNumSinkParts, setSinkFields, setSourceFields, sinkCleanup, sinkPrepare, sourceCleanup, sourcePrepare, toStringpublic void sourceConfInit(FlowProcess flowProcess, Tap tap, Object conf)
sourceConfInit in class Schemepublic void sinkConfInit(FlowProcess flowProcess, Tap tap, Object conf)
sinkConfInit in class Schemepublic boolean source(FlowProcess flowProcess, SourceCall sourceCall) throws IOException
source in class SchemeIOExceptionpublic void sink(FlowProcess flowProcess, SinkCall sinkCall) throws IOException
sink in class SchemeIOException