public static class EsFactory.EsScheme
extends cascading.scheme.Scheme
| Modifier and Type | Method and Description |
|---|---|
void |
sink(cascading.flow.FlowProcess flowProcess,
cascading.scheme.SinkCall sinkCall) |
void |
sinkConfInit(cascading.flow.FlowProcess flowProcess,
cascading.tap.Tap tap,
java.lang.Object conf) |
boolean |
source(cascading.flow.FlowProcess flowProcess,
cascading.scheme.SourceCall sourceCall) |
void |
sourceConfInit(cascading.flow.FlowProcess flowProcess,
cascading.tap.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(cascading.flow.FlowProcess flowProcess,
cascading.tap.Tap tap,
java.lang.Object conf)
sourceConfInit in class cascading.scheme.Schemepublic void sinkConfInit(cascading.flow.FlowProcess flowProcess,
cascading.tap.Tap tap,
java.lang.Object conf)
sinkConfInit in class cascading.scheme.Schemepublic boolean source(cascading.flow.FlowProcess flowProcess,
cascading.scheme.SourceCall sourceCall)
throws java.io.IOException
source in class cascading.scheme.Schemejava.io.IOExceptionpublic void sink(cascading.flow.FlowProcess flowProcess,
cascading.scheme.SinkCall sinkCall)
throws java.io.IOException
sink in class cascading.scheme.Schemejava.io.IOException