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,
java.lang.Object conf) |
boolean |
source(FlowProcess flowProcess,
SourceCall sourceCall) |
void |
sourceConfInit(FlowProcess flowProcess,
Tap tap,
java.lang.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, java.lang.Object conf)
sourceConfInit in class Schemepublic void sinkConfInit(FlowProcess flowProcess, Tap tap, java.lang.Object conf)
sinkConfInit in class Schemepublic boolean source(FlowProcess flowProcess, SourceCall sourceCall) throws java.io.IOException
public void sink(FlowProcess flowProcess, SinkCall sinkCall) throws java.io.IOException